Changeset 44c6d88d in mainline for libc/generic/async.c

Timestamp:

2006-05-30T17:23:33Z (19 years ago)

Author:

Ondrej Palkovsky <ondrap@…>

Branches:

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

Children:

eaf34f7

Parents:

79460ae

Message:

Added some additional functionality.

File:

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

libc/generic/async.c

@@ -270 +270 @@
 }
 
+/** Function that gets created on interrupt receival
+ *
+ * This function is defined as a weak symbol - to be redefined in
+ * user code.
+ */
+void interrupt_received(ipc_call_t *call)
+{
+}
+
+
 /** Wrapper for client connection thread
  *
@@ -309 +319 @@
  * threads.
  *
+ * @param in_phone_hash Identification of the incoming connection
  * @param callid Callid of the IPC_M_CONNECT_ME_TO packet
  * @param call Call data of the opening packet
@@ -315 +326 @@
  * @return New thread id
  */
-pstid_t async_new_connection(ipc_callid_t callid, ipc_call_t *call,
+pstid_t async_new_connection(ipcarg_t in_phone_hash,ipc_callid_t callid, 
+                             ipc_call_t *call,
                              void (*cthread)(ipc_callid_t,ipc_call_t *))
 {
@@ -327 +339 @@
                 return NULL;
         }
-        conn->in_phone_hash = IPC_GET_ARG3(*call);
+        conn->in_phone_hash = in_phone_hash;
         list_initialize(&conn->msg_queue);
         conn->ptid = psthread_create(connection_thread, conn);
@@ -354 +366 @@
 static void handle_call(ipc_callid_t callid, ipc_call_t *call)
 {
+        /* Unrouted call - do some default behaviour */
+        switch (IPC_GET_METHOD(*call)) {
+        case IPC_M_INTERRUPT:
+                interrupt_received(call);
+                return;
+        case IPC_M_CONNECT_ME_TO:
+                /* Open new connection with thread etc. */
+                async_new_connection(IPC_GET_ARG3(*call), callid, call, client_connection);
+                return;
+        }
+
+        /* Try to route call through connection tables */
         if (route_call(callid, call))
                 return;
 
-        switch (IPC_GET_METHOD(*call)) {
-        case IPC_M_INTERRUPT:
-                break;
-        case IPC_M_CONNECT_ME_TO:
-                /* Open new connection with thread etc. */
-                async_new_connection(callid, call, client_connection);
-                break;
-        default:
-                ipc_answer_fast(callid, EHANGUP, 0, 0);
-        }
+        /* Unknown call from unknown phone - hang it up */
+        ipc_answer_fast(callid, EHANGUP, 0, 0);
 }
 
@@ -622 +638 @@
 }
 
+/** Wait specified time, but in the meantime handle incoming events
+ *
+ * @param timeout Time in microseconds to wait
+ */
+void async_usleep(suseconds_t timeout)
+{
+        amsg_t *msg;
+        
+        msg = malloc(sizeof(*msg));
+        if (!msg)
+                return;
+
+        msg->ptid = psthread_get_id();
+        msg->active = 0;
+        msg->has_timeout = 1;
+
+        gettimeofday(&msg->expires, NULL);
+        tv_add(&msg->expires, timeout);
+
+        futex_down(&async_futex);
+        insert_timeout(msg);
+        /* Leave locked async_futex when entering this function */
+        psthread_schedule_next_adv(PS_TO_MANAGER);
+        /* futex is up automatically after psthread_schedule_next...*/
+        free(msg);
+}