Changeset 9591265 in mainline

Timestamp:

2007-06-28T19:45:36Z (17 years ago)

Author:

Jakub Jermar <jakub@…>

Branches:

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

Children:

f2f0392

Parents:

12f91130

Message:

More psthread/fibril cleanup.

File:

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

uspace/lib/libc/generic/async.c

@@ -36 +36 @@
  * Asynchronous library
  *
- * The aim of this library is facilitating writing programs utilizing 
- * the asynchronous nature of HelenOS IPC, yet using a normal way
- * of programming. 
- *
- * You should be able to write very simple multithreaded programs, 
- * the async framework will automatically take care of most synchronization
- * problems.
+ * The aim of this library is facilitating writing programs utilizing the
+ * asynchronous nature of HelenOS IPC, yet using a normal way of programming. 
+ *
+ * You should be able to write very simple multithreaded programs, the async
+ * framework will automatically take care of most synchronization problems.
  *
  * Default semantics:
- * - send() - send asynchronously. If the kernel refuses to send more
- *            messages, [ try to get responses from kernel, if nothing
- *            found, might try synchronous ]
- *
- * Example of use:
+ * - async_send_*():    send asynchronously. If the kernel refuses to send
+ *                      more messages, [ try to get responses from kernel, if
+ *                      nothing found, might try synchronous ]
+ *
+ * Example of use (pseudo C):
  * 
  * 1) Multithreaded client application
- *  fibril_create(fibril1);
- *  fibril_create(fibril2);
- *  ...
+ *
+ * fibril_create(fibril1, ...);
+ * fibril_create(fibril2, ...);
+ * ...
  *  
- *  fibril1() {
- *        conn = ipc_connect_me_to();
- *        c1 = send(conn);
- *        c2 = send(conn);
- *        wait_for(c1);
- *        wait_for(c2);
- *  }
+ * int fibril1(void *arg)
+ * {
+ *      conn = ipc_connect_me_to();
+ *      c1 = async_send(conn);
+ *      c2 = async_send(conn);
+ *      async_wait_for(c1);
+ *      async_wait_for(c2);
+ *      ...
+ * }
  *
  *
  * 2) Multithreaded server application
- * main() {
- *      async_manager();
+ * main()
+ * {
+ *      async_manager();
  * }
  * 
  *
- * 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);
- *       ....
+ * client_connection(icallid, *icall)
+ * {
+ *      if (want_refuse) {
+ *              ipc_answer_fast(icallid, ELIMIT, 0, 0);
+ *              return;
+ *      }
+ *      ipc_answer_fast(icallid, EOK, 0, 0);
+ *
+ *      callid = async_get_call(&call);
+ *      handle_call(callid, call);
+ *      ipc_answer_fast(callid, 1, 2, 3);
+ *
+ *      callid = async_get_call(&call);
+ *      ....
  * }
  *
  */
+
 #include <futex.h>
 #include <async.h>
@@ -568 +572 @@
  * exist per thread. The particular implementation may change,
  * currently one async_manager is started automatically per kernel
- * thread except main thread. 
- */
-static int async_manager_thread(void *arg)
+ * thread except the main thread. 
+ */
+static int async_manager_fibril(void *arg)
 {
         futex_up(&async_futex);
@@ -585 +589 @@
         fid_t fid;
 
-        fid = fibril_create(async_manager_thread, NULL);
+        fid = fibril_create(async_manager_fibril, NULL);
         fibril_add_manager(fid);
 }