Changeset cac458f in mainline for kernel/generic/src/ipc/ipc.c

Timestamp:

2011-06-22T01:59:39Z (14 years ago)

Author:

Petr Koupy <petr.koupy@…>

Branches:

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

Children:

41e2118

Parents:

79506d6 (diff), f1fae414 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge libposix changes.

File:

• kernel/generic/src/ipc/ipc.c (modified) (11 diffs)

kernel/generic/src/ipc/ipc.c

@@ -128 +128 @@
         list_initialize(&box->answers);
         list_initialize(&box->irq_notifs);
-        list_initialize(&box->irq_head);
+        list_initialize(&box->irq_list);
         box->task = task;
 }
@@ -183 +183 @@
          */
         irq_spinlock_lock(&TASK->lock, true);
-        list_append(&sync_box->sync_box_link, &TASK->sync_box_head);
+        list_append(&sync_box->sync_box_link, &TASK->sync_boxes);
         irq_spinlock_unlock(&TASK->lock, true);
         
@@ -450 +450 @@
                 irq_spinlock_lock(&box->irq_lock, false);
                 
-                request = list_get_instance(box->irq_notifs.next, call_t, link);
+                request = list_get_instance(list_first(&box->irq_notifs),
+                    call_t, link);
                 list_remove(&request->link);
                 
@@ -459 +460 @@
                 
                 /* Handle asynchronous answers */
-                request = list_get_instance(box->answers.next, call_t, link);
+                request = list_get_instance(list_first(&box->answers),
+                    call_t, link);
                 list_remove(&request->link);
                 atomic_dec(&request->data.phone->active_calls);
@@ -467 +469 @@
                 
                 /* Handle requests */
-                request = list_get_instance(box->calls.next, call_t, link);
+                request = list_get_instance(list_first(&box->calls),
+                    call_t, link);
                 list_remove(&request->link);
                 
@@ -494 +497 @@
  *
  */
-void ipc_cleanup_call_list(link_t *lst)
+void ipc_cleanup_call_list(list_t *lst)
 {
         while (!list_empty(lst)) {
-                call_t *call = list_get_instance(lst->next, call_t, link);
+                call_t *call = list_get_instance(list_first(lst), call_t, link);
                 if (call->buffer)
                         free(call->buffer);
@@ -526 +529 @@
         irq_spinlock_lock(&box->lock, true);
         while (!list_empty(&box->connected_phones)) {
-                phone = list_get_instance(box->connected_phones.next,
+                phone = list_get_instance(list_first(&box->connected_phones),
                     phone_t, link);
                 if (SYNCH_FAILED(mutex_trylock(&phone->lock))) {
@@ -606 +609 @@
         /* Wait for all answers to interrupted synchronous calls to arrive */
         ipl_t ipl = interrupts_disable();
-        while (!list_empty(&TASK->sync_box_head)) {
-                answerbox_t *box = list_get_instance(TASK->sync_box_head.next,
-                    answerbox_t, sync_box_link);
+        while (!list_empty(&TASK->sync_boxes)) {
+                answerbox_t *box = list_get_instance(
+                    list_first(&TASK->sync_boxes), answerbox_t, sync_box_link);
                 
                 list_remove(&box->sync_box_link);
@@ -743 +746 @@
 #endif
         
-        link_t *cur;
-        
         printf(" --- incomming calls ---\n");
-        for (cur = task->answerbox.calls.next; cur != &task->answerbox.calls;
-            cur = cur->next) {
+        list_foreach(task->answerbox.calls, cur) {
                 call_t *call = list_get_instance(cur, call_t, link);
                 
@@ -767 +767 @@
         
         printf(" --- dispatched calls ---\n");
-        for (cur = task->answerbox.dispatched_calls.next;
-            cur != &task->answerbox.dispatched_calls;
-            cur = cur->next) {
+        list_foreach(task->answerbox.dispatched_calls, cur) {
                 call_t *call = list_get_instance(cur, call_t, link);
                 
@@ -789 +787 @@
         
         printf(" --- incoming answers ---\n");
-        for (cur = task->answerbox.answers.next;
-            cur != &task->answerbox.answers;
-            cur = cur->next) {
+        list_foreach(task->answerbox.answers, cur) {
                 call_t *call = list_get_instance(cur, call_t, link);