Changeset 47c9a8c in mainline for uspace/lib/c/generic/fibril_synch.c

Timestamp:

2012-04-13T20:21:32Z (12 years ago)

Author:

Jakub Jermar <jakub@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

ab9f443

Parents:

87608a5

Message:

Small improvements in the async framework.

• Provide functions for initialization of amsg_t and awaiter_t.
• Add async_forget() to mark messages that can be discarded right on their arrival because the recipient is no longer interested in the reply.
• Add a couple of asserts to make sure that the async_wait_for(), async_wait_timeout() and async_forget() are not used inappropriately.

File:

• uspace/lib/c/generic/fibril_synch.c (modified) (4 diffs)

uspace/lib/c/generic/fibril_synch.c

@@ -112 +112 @@
                 awaiter_t wdata;
 
+                awaiter_initialize(&wdata);
                 wdata.fid = fibril_get_id();
-                wdata.active = false;
                 wdata.wu_event.inlist = true;
-                link_initialize(&wdata.wu_event.link);
                 list_append(&wdata.wu_event.link, &fm->waiters);
                 check_for_deadlock(&fm->oi);
@@ -205 +204 @@
                 awaiter_t wdata;
 
+                awaiter_initialize(&wdata);
                 wdata.fid = (fid_t) f;
-                wdata.active = false;
                 wdata.wu_event.inlist = true;
-                link_initialize(&wdata.wu_event.link);
                 f->flags &= ~FIBRIL_WRITER;
                 list_append(&wdata.wu_event.link, &frw->waiters);
@@ -233 +231 @@
                 awaiter_t wdata;
 
+                awaiter_initialize(&wdata);
                 wdata.fid = (fid_t) f;
-                wdata.active = false;
                 wdata.wu_event.inlist = true;
-                link_initialize(&wdata.wu_event.link);
                 f->flags |= FIBRIL_WRITER;
                 list_append(&wdata.wu_event.link, &frw->waiters);
@@ -375 +372 @@
                 return ETIMEOUT;
 
+        awaiter_initialize(&wdata);
         wdata.fid = fibril_get_id();
-        wdata.active = false;
-        
         wdata.to_event.inlist = timeout > 0;
-        wdata.to_event.occurred = false;
-        link_initialize(&wdata.to_event.link);
-
         wdata.wu_event.inlist = true;
-        link_initialize(&wdata.wu_event.link);
 
         futex_down(&async_futex);