Changeset 35f2bb1 in mainline

Timestamp:

2017-11-23T21:15:13Z (7 years ago)

Author:

Jakub Jermar <jakub@…>

Branches:

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

Children:

40e5d66

Parents:

d51a0d6

Message:

Remove support for queuing of unsent calls

Support for temporary IPC failures was removed before 0.7.1 so this code
is no longer needed and can be removed.

File:

• uspace/lib/c/generic/ipc.c (modified) (4 diffs)

uspace/lib/c/generic/ipc.c

@@ -50 +50 @@
 
 /**
- * Structures of this type are used for keeping track
- * of sent asynchronous calls and queing unsent calls.
+ * Structures of this type are used for keeping track of sent asynchronous calls.
  */
 typedef struct {
@@ -72 +71 @@
 
 LIST_INITIALIZE(dispatched_calls);
-
-/** List of asynchronous calls that were not accepted by kernel.
- *
- * Protected by async_futex, because if the call is not accepted
- * by the kernel, the async framework is used automatically.
- *
- */
-LIST_INITIALIZE(queued_calls);
 
 static futex_t ipc_futex = FUTEX_INITIALIZER;
@@ -294 +285 @@
         
         return __SYSCALL2(SYS_IPC_ANSWER_SLOW, callid, (sysarg_t) &data);
-}
-
-/** Try to dispatch queued calls from the async queue.
- *
- */
-static void dispatch_queued_calls(void)
-{
-        /** @todo
-         * Integrate intelligently ipc_futex so that it is locked during
-         * ipc_call_async_*() until it is added to dispatched_calls.
-         */
-        
-        futex_down(&async_futex);
-        
-        while (!list_empty(&queued_calls)) {
-                async_call_t *call =
-                    list_get_instance(list_first(&queued_calls), async_call_t, list);
-                ipc_callid_t callid =
-                    ipc_call_async_internal(call->u.msg.phoneid, &call->u.msg.data);
-                
-                list_remove(&call->list);
-                
-                futex_up(&async_futex);
-                
-                assert(call->fid);
-                fibril_add_ready(call->fid);
-                
-                if (callid == (ipc_callid_t) IPC_CALLRET_FATAL) {
-                        if (call->callback)
-                                call->callback(call->private, ENOENT, NULL);
-                        
-                        free(call);
-                } else {
-                        call->u.callid = callid;
-                        
-                        futex_lock(&ipc_futex);
-                        list_append(&call->list, &dispatched_calls);
-                        futex_unlock(&ipc_futex);
-                }
-                
-                futex_down(&async_futex);
-        }
-        
-        futex_up(&async_futex);
 }
 
@@ -400 +347 @@
         
         /* Handle received answers */
-        if (callid & IPC_CALLID_ANSWERED) {
+        if (callid & IPC_CALLID_ANSWERED)
                 handle_answer(callid, call);
-                dispatch_queued_calls();
-        }
         
         return callid;