Changes in kernel/generic/src/ipc/ipc.c [466e95f7:e9fe33b] in mainline

File:

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

kernel/generic/src/ipc/ipc.c

@@ -255 +255 @@
 }
 
-static void _ipc_call_actions_internal(phone_t *phone, call_t *call)
+/** Simulate sending back a message.
+ *
+ * Most errors are better handled by forming a normal backward
+ * message and sending it as a normal answer.
+ *
+ * @param phone Phone structure the call should appear to come from.
+ * @param call  Call structure to be answered.
+ * @param err   Return value to be used for the answer.
+ *
+ */
+void ipc_backsend_err(phone_t *phone, call_t *call, sysarg_t err)
 {
         task_t *caller = phone->caller;
@@ -269 +279 @@
 
         call->data.phone = phone;
-        call->data.task_id = caller->taskid;
-}
-
-/** Simulate sending back a message.
- *
- * Most errors are better handled by forming a normal backward
- * message and sending it as a normal answer.
- *
- * @param phone Phone structure the call should appear to come from.
- * @param call  Call structure to be answered.
- * @param err   Return value to be used for the answer.
- *
- */
-void ipc_backsend_err(phone_t *phone, call_t *call, sysarg_t err)
-{
-        _ipc_call_actions_internal(phone, call);
+
         IPC_SET_RETVAL(call->data, err);
         _ipc_answer_free_call(call, false);
@@ -305 +300 @@
         irq_spinlock_unlock(&caller->lock, true);
         
-        if (!(call->flags & IPC_CALL_FORWARDED))
-                _ipc_call_actions_internal(phone, call);
+        if (!(call->flags & IPC_CALL_FORWARDED)) {
+                atomic_inc(&phone->active_calls);
+                call->caller_phone = phone;
+                call->sender = caller;
+
+                call->active = true;
+                spinlock_lock(&caller->active_calls_lock);
+                list_append(&call->ta_link, &caller->active_calls);
+                spinlock_unlock(&caller->active_calls_lock);
+
+                call->data.phone = phone;
+                call->data.task_id = caller->taskid;
+        }
         
         irq_spinlock_lock(&box->lock, true);
@@ -512 +518 @@
 
                 irq_spinlock_unlock(&box->lock, true);
-
-                if (lst == &box->calls)
-                        SYSIPC_OP(request_process, call, box);
 
                 ipc_data_t old = call->data;
@@ -640 +643 @@
         atomic_dec(&call->caller_phone->active_calls);
 
-        SYSIPC_OP(request_forget, call);
+        sysipc_ops_t *ops = sysipc_ops_get(call->request_method);
+        if (ops->request_forget)
+                ops->request_forget(call);
 
         ipc_call_release(call);
@@ -708 +713 @@
             SYNCH_FLAGS_NONE);
         ASSERT(call->flags & (IPC_CALL_ANSWERED | IPC_CALL_NOTIF));
-
-        SYSIPC_OP(answer_process, call);
-
         ipc_call_free(call);
         goto restart;
@@ -752 +754 @@
         
         /* Answer all messages in 'calls' and 'dispatched_calls' queues */
-        ipc_cleanup_call_list(&TASK->answerbox, &TASK->answerbox.calls);
         ipc_cleanup_call_list(&TASK->answerbox,
             &TASK->answerbox.dispatched_calls);
+        ipc_cleanup_call_list(&TASK->answerbox, &TASK->answerbox.calls);
 
         ipc_forget_all_active_calls();