WebSVN – HelenOS – Diff – /branches/dd/uspace/lib/libc/generic/async.c

 /** Identifier of the incoming connection handled by the current fibril. */
 fibril_local connection_t *FIBRIL_connection;
 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);
 /**
  * Pointer to a fibril function that will be used to handle connections.
  */
 static async_client_conn_t client_connection = default_client_connection;
  * Pointer to a fibril function that will be used to handle interrupt
  * notifications.
  */
 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
     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);
-    futex_up(&async_futex);
-    return true;
-}
 /** Return new incoming message for the current (fibril-local) connection.
+ *
  * @param call  Storage where the incoming call data will be stored.
  * @param usecs Timeout in microseconds. Zero denotes no timeout.
+ *
  */
 static void default_interrupt_received(ipc_callid_t callid, ipc_call_t *call)
+{
+}
-/** 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.
+ *
  * When a new connection arrives, a fibril with this implementing function is
  * created. It calls client_connection() and does the final cleanup.
+ *
     /* Unknown call from unknown phone - hang it up */
     ipc_answer_0(callid, EHANGUP);
     return;
 out:
-    process_pending();
+    ;
+}
 /** Fire all timeouts that expired. */
 static void handle_expired_timeouts(void)
+{
 /** Initialize the async framework.
+ *
  * @return Zero on success or an error code.
  */
-int _async_init(void)
+int __async_init(void)
+{
     if (!hash_table_create(&conn_hash_table, CONN_HASH_TABLE_CHAINS, 1,
         &conn_hash_table_ops)) {
         printf("%s: cannot create hash table\n", "async");
         return ENOMEM;
 void async_set_interrupt_received(async_client_conn_t intr)
+{
     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;
-}
 /** Pseudo-synchronous message sending - fast version.
+ *
  * Send message asynchronously and return only after the reply arrives.
+ *
  * This function can only transfer 4 register payload arguments. For

Subversion Repositories HelenOS

(root)/branches/dd/uspace/lib/libc/generic/async.c @ 4687 – Rev 4537 → 4668