Changes in uspace/lib/c/generic/async.c [9934f7d:3815efb] in mainline

File:

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

uspace/lib/c/generic/async.c

@@ -160 +160 @@
         
         /** Messages that should be delivered to this fibril. */
-        link_t msg_queue;
+        list_t msg_queue;
         
         /** Identification of the opening call. */
@@ -213 +213 @@
  * This function is defined as a weak symbol - to be redefined in user code.
  *
- * @param callid        Hash of the incoming call.
- * @param call          Data of the incoming call.
- * @param arg           Local argument
+ * @param callid Hash of the incoming call.
+ * @param call   Data of the incoming call.
+ * @param arg    Local argument
  *
  */
@@ -228 +228 @@
  * This function is defined as a weak symbol - to be redefined in user code.
  *
- * @param callid        Hash of the incoming call.
- * @param call          Data of the incoming call.
- * @param arg           Local argument.
+ * @param callid Hash of the incoming call.
+ * @param call   Data of the incoming call.
+ * @param arg    Local argument.
  *
  */
@@ -361 +361 @@
         wd->to_event.inlist = true;
         
-        link_t *tmp = timeout_list.next;
-        while (tmp != &timeout_list) {
+        link_t *tmp = timeout_list.head.next;
+        while (tmp != &timeout_list.head) {
                 awaiter_t *cur
                     = list_get_instance(tmp, awaiter_t, to_event.link);
@@ -372 +372 @@
         }
         
-        list_append(&wd->to_event.link, tmp);
+        list_insert_before(&wd->to_event.link, tmp);
 }
 
@@ -569 +569 @@
         }
         
-        msg_t *msg = list_get_instance(conn->msg_queue.next, msg_t, link);
+        msg_t *msg = list_get_instance(list_first(&conn->msg_queue), msg_t, link);
         list_remove(&msg->link);
         
@@ -675 +675 @@
         while (!list_empty(&fibril_connection->msg_queue)) {
                 msg_t *msg =
-                    list_get_instance(fibril_connection->msg_queue.next, msg_t,
-                    link);
+                    list_get_instance(list_first(&fibril_connection->msg_queue),
+                    msg_t, link);
                 
                 list_remove(&msg->link);
@@ -709 +709 @@
  * @param cfibril       Fibril function that should be called upon opening the
  *                      connection.
- * @param carg          Extra argument to pass to the connection fibril
+ * @param carg          Extra argument to pass to the connection fibril
  *
  * @return New fibril id or NULL on failure.
@@ -806 +806 @@
         futex_down(&async_futex);
         
-        link_t *cur = timeout_list.next;
-        while (cur != &timeout_list) {
+        link_t *cur = list_first(&timeout_list);
+        while (cur != NULL) {
                 awaiter_t *waiter =
                     list_get_instance(cur, awaiter_t, to_event.link);
@@ -813 +813 @@
                 if (tv_gt(&waiter->to_event.expires, &tv))
                         break;
-                
-                cur = cur->next;
                 
                 list_remove(&waiter->to_event.link);
@@ -828 +826 @@
                         fibril_add_ready(waiter->fid);
                 }
+                
+                cur = list_first(&timeout_list);
         }
         
@@ -854 +854 @@
                 suseconds_t timeout;
                 if (!list_empty(&timeout_list)) {
-                        awaiter_t *waiter = list_get_instance(timeout_list.next,
-                            awaiter_t, to_event.link);
+                        awaiter_t *waiter = list_get_instance(
+                            list_first(&timeout_list), awaiter_t, to_event.link);
                         
                         struct timeval tv;
@@ -1731 +1731 @@
                  */
                 exch = (async_exch_t *)
-                    list_get_instance(sess->exch_list.next, async_exch_t, sess_link);
+                    list_get_instance(list_first(&sess->exch_list),
+                    async_exch_t, sess_link);
+                
                 list_remove(&exch->sess_link);
                 list_remove(&exch->global_link);
@@ -1743 +1745 @@
                         exch = (async_exch_t *) malloc(sizeof(async_exch_t));
                         if (exch != NULL) {
-                                list_initialize(&exch->sess_link);
-                                list_initialize(&exch->global_link);
+                                link_initialize(&exch->sess_link);
+                                link_initialize(&exch->global_link);
                                 exch->sess = sess;
                                 exch->phone = sess->phone;
@@ -1761 +1763 @@
                                 exch = (async_exch_t *) malloc(sizeof(async_exch_t));
                                 if (exch != NULL) {
-                                        list_initialize(&exch->sess_link);
-                                        list_initialize(&exch->global_link);
+                                        link_initialize(&exch->sess_link);
+                                        link_initialize(&exch->global_link);
                                         exch->sess = sess;
                                         exch->phone = phone;
@@ -1774 +1776 @@
                                  */
                                 exch = (async_exch_t *)
-                                    list_get_instance(inactive_exch_list.next, async_exch_t,
-                                    global_link);
+                                    list_get_instance(list_first(&inactive_exch_list),
+                                    async_exch_t, global_link);
+                                
                                 list_remove(&exch->sess_link);
                                 list_remove(&exch->global_link);