Changeset 9db9b10 in mainline for uspace/lib/libc/generic/async.c

Timestamp:

2009-06-03T19:16:07Z (16 years ago)

Author:

Martin Decky <martin@…>

Branches:

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

Children:

937aeee

Parents:

e77994dd

Message:

async framework: add generic support for processing pending operations (in a separate fibril)
coding style

File:

• uspace/lib/libc/generic/async.c (modified) (9 diffs)

uspace/lib/libc/generic/async.c

@@ -179 +179 @@
 static void default_client_connection(ipc_callid_t callid, ipc_call_t *call);
 static void default_interrupt_received(ipc_callid_t callid, ipc_call_t *call);
+static void default_pending(void);
 
 /**
@@ -191 +192 @@
 static async_client_conn_t interrupt_received = default_interrupt_received;
 
+/**
+ * Pointer to a fibril function that will be used to handle pending
+ * operations.
+ */
+static async_pending_t pending = default_pending;
 
 static hash_table_t conn_hash_table;
 static LIST_INITIALIZE(timeout_list);
-
 
 #define CONN_HASH_TABLE_CHAINS  32
@@ -371 +376 @@
         
         fid_t fid = fibril_create(notification_fibril, msg);
+        fibril_add_ready(fid);
+        
+        futex_up(&async_futex);
+        return true;
+}
+
+/** Pending fibril.
+ *
+ * After each call the pending operations are executed in a separate
+ * fibril. The function pending() is c.
+ *
+ * @param arg Unused.
+ *
+ * @return Always zero.
+ *
+ */
+static int pending_fibril(void *arg)
+{
+        pending();
+        
+        return 0;
+}
+
+/** Process pending actions.
+ *
+ * A new fibril is created which would process the pending operations.
+ *
+ * @return False if an error occured.
+ *         True if the execution was passed to the pending fibril.
+ *
+ */
+static bool process_pending(void)
+{
+        futex_down(&async_futex);
+        
+        fid_t fid = fibril_create(pending_fibril, NULL);
         fibril_add_ready(fid);
         
@@ -473 +514 @@
 }
 
+/** Default fibril function that gets called to handle pending operations.
+ *
+ * This function is defined as a weak symbol - to be redefined in user code.
+ *
+ */
+static void default_pending(void)
+{
+}
+
 /** Wrapper for client connection fibril.
  *
@@ -564 +614 @@
         
         /* Add connection to the connection hash table */
-        ipcarg_t key = conn->in_phone_hash;
+        unsigned long key = conn->in_phone_hash;
         
         futex_down(&async_futex);
@@ -589 +639 @@
         if ((callid & IPC_CALLID_NOTIFICATION)) {
                 process_notification(callid, call);
-                return;
+                goto out;
         }
         
@@ -598 +648 @@
                 async_new_connection(IPC_GET_ARG5(*call), callid, call,
                     client_connection);
-                return;
+                goto out;
         }
         
         /* Try to route the call through the connection hash table */
         if (route_call(callid, call))
-                return;
+                goto out;
         
         /* Unknown call from unknown phone - hang it up */
         ipc_answer_0(callid, EHANGUP);
+        return;
+        
+out:
+        process_pending();
 }
 
@@ -760 +814 @@
 static void reply_received(void *arg, int retval, ipc_call_t *data)
 {
+        futex_down(&async_futex);
+        
         amsg_t *msg = (amsg_t *) arg;
         msg->retval = retval;
         
-        futex_down(&async_futex);
-        
         /* Copy data after futex_down, just in case the call was detached */
-        if (msg->dataptr)
+        if ((msg->dataptr) && (data))
                 *msg->dataptr = *data;
         
@@ -993 +1047 @@
 {
         interrupt_received = intr;
+}
+
+/** Setter for pending function pointer.
+ *
+ * @param pend Function that will implement a new pending
+ *             operations fibril.
+ */
+void async_set_pending(async_pending_t pend)
+{
+        pending = pend;
 }