WebSVN – HelenOS-historic – Diff – /uspace/trunk/libc/generic/async.c

 void client_connection(ipc_callid_t callid, ipc_call_t *call)
+{
     ipc_answer_fast(callid, ENOENT, 0, 0);
+}
+/** 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
+ *
  * When new connection arrives, thread with this function is created.
  * It calls client_connection and does final cleanup.
+ *
  * Creates new thread for connection, fills in connection
  * structures and inserts it into the hash table, so that
  * later we can easily do routing of messages to particular
  * 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
  * @param cthread Thread function that should be called upon
  *                opening the connection
  * @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 *))
+{
     pstid_t ptid;
     connection_t *conn;
     unsigned long key;
     conn = malloc(sizeof(*conn));
     if (!conn) {
         ipc_answer_fast(callid, ENOMEM, 0, 0);
         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);
     conn->callid = callid;
     conn->call = *call;
     conn->active = 1; /* We will activate it asap */
+}
 /** Handle call that was received */
 static void handle_call(ipc_callid_t callid, ipc_call_t *call)
+{
-    if (route_call(callid, call))
+    /* Unrouted call - do some default behaviour */
-        return;
     switch (IPC_GET_METHOD(*call)) {
     case IPC_M_INTERRUPT:
+        interrupt_received(call);
-        break;
+        return;
     case IPC_M_CONNECT_ME_TO:
         /* Open new connection with thread etc. */
-        async_new_connection(callid, call, client_connection);
+        async_new_connection(IPC_GET_ARG3(*call), callid, call, client_connection);
-        break;
+        return;
-    default:
-        ipc_answer_fast(callid, EHANGUP, 0, 0);
+    }
+    /* Try to route call through connection tables */
+    if (route_call(callid, call))
+        return;
+    /* Unknown call from unknown phone - hang it up */
+    ipc_answer_fast(callid, EHANGUP, 0, 0);
+}
 /** Fire all timeouts that expired */
 static void handle_expired_timeouts(void)
+{
     free(msg);
     return 0;
+}
+/** 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);
+}

Subversion Repositories HelenOS-historic

(root)/uspace/trunk/libc/generic/async.c – Rev 1441 → 1452