Changeset ca687ad in mainline for generic/src/ipc/ipc.c

Timestamp:

2006-03-31T13:53:36Z (19 years ago)

Author:

Ondrej Palkovsky <ondrap@…>

Branches:

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

Children:

0cb56f5d

Parents:

296cc1b

Message:

Completed ipc_cleanup, it should be somehow integrated into
cleanup of task. The function can sleep.

File:

• generic/src/ipc/ipc.c (modified) (3 diffs)

generic/src/ipc/ipc.c

@@ -323 +323 @@
                 list_append(&request->list, &box->dispatched_calls);
         } else {
+                /* This can happen regularly after ipc_cleanup, remove
+                 * the warning in the future when the IPC is
+                 * more debugged */
                 printf("WARNING: Spurious IPC wakeup.\n");
                 spinlock_unlock(&box->lock);
@@ -340 +343 @@
 }
 
+/** Answer all calls from list with EHANGUP msg */
+static void ipc_cleanup_call_list(link_t *lst)
+{
+        call_t *call;
+
+        while (!list_empty(lst)) {
+                call = list_get_instance(lst->next, call_t, list);
+                list_remove(&call->list);
+
+                IPC_SET_RETVAL(call->data, EHANGUP);
+                _ipc_answer_free_call(call);
+        }
+}
+
 /** Cleans up all IPC communication of the given task
  *
@@ -347 +364 @@
 {
         int i;
-
+        call_t *call;
+        phone_t *phone;
+        
         /* Disconnect all our phones ('ipc_phone_hangup') */
         for (i=0;i < IPC_MAX_PHONES; i++)
                 ipc_phone_hangup(&task->phones[i]);
 
-        /* Disconnect all phones connected to answerbox */
+        /* Disconnect all phones connected to our answerbox */
+restart_phones:
+        spinlock_lock(&task->answerbox.lock);
+        while (!list_empty(&task->answerbox.connected_phones)) {
+                phone = list_get_instance(task->answerbox.connected_phones.next,
+                                          phone_t,
+                                          list);
+                if (! spinlock_trylock(&phone->lock)) {
+                        spinlock_unlock(&task->answerbox.lock);
+                        goto restart_phones;
+                }
+                
+                /* Disconnect phone */
+                phone->callee = NULL;
+                list_remove(&phone->list);
+
+                spinlock_unlock(&phone->lock);
+        }
 
         /* Answer all messages in 'calls' and 'dispatched_calls' queues */
+        spinlock_lock(&task->answerbox.lock);
+        ipc_cleanup_call_list(&task->answerbox.dispatched_calls);
+        ipc_cleanup_call_list(&task->answerbox.calls);
+        spinlock_unlock(&task->answerbox.lock);
         
         /* Wait for all async answers to arrive */
-}
+        while (atomic_get(&task->active_calls)) {
+                call = ipc_wait_for_call(&task->answerbox, 0);
+                ASSERT(call->flags & IPC_CALL_ANSWERED);
+                ASSERT(! (call->flags & IPC_CALL_STATIC_ALLOC));
+                
+                atomic_dec(&task->active_calls);
+                ipc_call_free(call);
+        }
+}