Changeset 0b99e40 in mainline for libc/generic/async.c

Timestamp:

2006-05-28T18:22:10Z (19 years ago)

Author:

Ondrej Palkovsky <ondrap@…>

Branches:

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

Children:

2d1fde3b

Parents:

7f5b37a

Message:

Rough implementation of gettimeofday.
IPC_M_RECV_AS doesn't allow us to specify additional user parametrs. That
doesn't seem to be very configurable :-/

File:

• libc/generic/async.c (modified) (4 diffs)

libc/generic/async.c

@@ -332 +332 @@
         ipc_call_t call;
         ipc_callid_t callid;
+        int timeout;
 
         while (1) {
@@ -340 +341 @@
                         continue;
                 }
-                callid = ipc_wait_cycle(&call,SYNCH_NO_TIMEOUT,SYNCH_BLOCKING);
+/*
+                if (expires)
+                        timeout = .... ;
+                else
+*/
+                        timeout = SYNCH_NO_TIMEOUT;
+                callid = ipc_wait_cycle(&call, timeout, SYNCH_BLOCKING);
+
+                if (!callid) {
+//                      handle_expired_timeouts.......;
+                        continue;
+                }
 
                 if (callid & IPC_CALLID_ANSWERED)
@@ -405 +417 @@
         if (msg->dataptr)
                 *msg->dataptr = *data; 
-        
+
+        /* TODO: memory barrier?? */
         msg->done = 1;
         if (! msg->active) {
@@ -461 +474 @@
         free(msg);
 }
+
+
+/* int async_wait_timeout(aid_t amsgid, ipcarg_t *retval, int timeout) */
+/* { */
+/*      amsg_t *msg = (amsg_t *) amsgid; */
+/*      connection_t *conn; */
+
+/*      futex_down(&async_futex); */
+/*      if (msg->done) { */
+/*              futex_up(&async_futex); */
+/*              goto done; */
+/*      } */
+
+/*      msg->ptid = psthread_get_id(); */
+/*      msg->active = 0; */
+/*      msg->expires = gettime() + timeout; */
+/*      setup_timeouts_etc...(); */
+
+/*      /\* Leave locked async_futex when entering this function *\/ */
+/*      psthread_schedule_next_adv(PS_TO_MANAGER); */
+/*      /\* futex is up automatically after psthread_schedule_next...*\/ */
+
+/*      if (!msg->done) */
+/*              return casy-casy; */
+
+/*      /\* TODO: When memory barrier in reply_received, we can skip this *\/ */
+/*      futex_down(&async_futex); */
+/*      futex_up(&async_futex); */
+/* done: */
+        
+/*      if (retval) */
+/*              *retval = msg->retval; */
+/*      free(msg); */
+/* } */
+