Changeset 116d1ef4 in mainline for generic/src/ipc/ipc.c

Timestamp:

2006-06-02T12:26:50Z (19 years ago)

Author:

Jakub Jermar <jakub@…>

Branches:

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

Children:

d0c5901

Parents:

01ebbdf

Message:

Replace nonblocking argument of waitq_sleep_timeout with flags that specify mode of operation.
Now a flag can be used to specify interruptible sleep.
Modify waitq_interrupt_sleep() to only interrupt threads that used this flag.
O

File:

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

generic/src/ipc/ipc.c

@@ -143 +143 @@
 
         ipc_call(phone, request);
-        ipc_wait_for_call(&sync_box, SYNCH_NO_TIMEOUT, SYNCH_BLOCKING);
+        ipc_wait_for_call(&sync_box, SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NONE);
 }
 
@@ -306 +306 @@
  * @param usec Timeout in microseconds. See documentation for waitq_sleep_timeout() for
  *             decription of its special meaning.
- * @param nonblocking Blocking vs. non-blocking operation mode switch. See documentation
- *                    for waitq_sleep_timeout() for description of its special meaning.
+ * @param flags Select mode of sleep operation. See documentation for waitq_sleep_timeout()i
+ *              for description of its special meaning.
  * @return Recived message address
  * - to distinguish between call and answer, look at call->flags
  */
-call_t * ipc_wait_for_call(answerbox_t *box, __u32 usec, int nonblocking)
+call_t * ipc_wait_for_call(answerbox_t *box, __u32 usec, int flags)
 {
         call_t *request;
@@ -318 +318 @@
 
 restart:
-        rc = waitq_sleep_timeout(&box->wq, usec, nonblocking);
+        rc = waitq_sleep_timeout(&box->wq, usec, flags);
         if (SYNCH_FAILED(rc))
                 return NULL;
@@ -413 +413 @@
         /* Wait for all async answers to arrive */
         while (atomic_get(&task->active_calls)) {
-                call = ipc_wait_for_call(&task->answerbox, SYNCH_NO_TIMEOUT, SYNCH_BLOCKING);
+                call = ipc_wait_for_call(&task->answerbox, SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NONE);
                 ASSERT((call->flags & IPC_CALL_ANSWERED) || (call->flags & IPC_CALL_NOTIF));
                 ASSERT(! (call->flags & IPC_CALL_STATIC_ALLOC));