Changeset 53ca318 in mainline for libc/generic/async.c

Timestamp:

2006-05-23T11:01:31Z (19 years ago)

Author:

Ondrej Palkovsky <ondrap@…>

Branches:

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

Children:

8c6b45f

Parents:

07d960a

Message:

Small updates to asynchronous framework.

File:

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

libc/generic/async.c

@@ -61 +61 @@
  * 2) Multithreaded server application
  * main() {
- *      wait_for_connection(new_connection);
+ *      async_manager();
  * }
  * 
  *
- * new_connection(int connection) {
- *       accept(connection);
- *       msg = get_msg();
- *       handle(msg);
- *       answer(msg);
- *
- *       msg = get_msg();
+ * client_connection(icallid, *icall) {
+ *       if (want_refuse) {
+ *           ipc_answer_fast(icallid, ELIMIT, 0, 0);
+ *           return;
+ *       }
+ *       ipc_answer_fast(icallid, 0, 0, 0);
+ *
+ *       callid = async_get_call(&call);
+ *       handle(callid, call);
+ *       ipc_answer_fast(callid, 1,2,3);
+ *
+ *       callid = async_get_call(&call);
  *       ....
  * }
@@ -105 +110 @@
         ipc_callid_t callid;
         ipc_call_t call;
+        void (*cthread)(ipc_callid_t,ipc_call_t *);
 } connection_t;
 
@@ -226 +232 @@
         /* Setup thread local connection pointer */
         PS_connection = (connection_t *)arg;
-        client_connection(PS_connection->callid, &PS_connection->call);
+        PS_connection->cthread(PS_connection->callid, &PS_connection->call);
 
         /* Remove myself from connection hash table */
@@ -248 +254 @@
  * later we can easily do routing of messages to particular
  * threads.
- */
-static void new_connection(ipc_callid_t callid, ipc_call_t *call)
+ *
+ * @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,
+                             void (*cthread)(ipc_callid_t,ipc_call_t *))
 {
         pstid_t ptid;
@@ -258 +271 @@
         if (!conn) {
                 ipc_answer_fast(callid, ENOMEM, 0, 0);
-                return;
+                return NULL;
         }
         conn->in_phone_hash = IPC_GET_ARG3(*call);
@@ -266 +279 @@
         conn->call = *call;
         conn->active = 1; /* We will activate it asap */
+        conn->cthread = cthread;
         list_initialize(&conn->link);
         if (!conn->ptid) {
                 free(conn);
                 ipc_answer_fast(callid, ENOMEM, 0, 0);
-                return;
+                return NULL;
         }
         key = conn->in_phone_hash;
@@ -279 +293 @@
 
         psthread_add_ready(conn->ptid);
+
+        return conn->ptid;
 }
 
@@ -292 +308 @@
         case IPC_M_CONNECT_ME_TO:
                 /* Open new connection with thread etc. */
-                new_connection(callid, call);
+                async_new_connection(callid, call, client_connection);
                 break;
         default: