Changeset e8039a86 in mainline for kernel/generic/src/ipc/ops/stchngath.c

Timestamp:

2012-08-20T23:21:41Z (13 years ago)

Author:

Jakub Jermar <jakub@…>

Branches:

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

Children:

0343a1b

Parents:

642dc72

Message:

Separate system IPC logic into dedicated ops structure hooks.

File:

• kernel/generic/src/ipc/ops/stchngath.c (modified) (1 diff)

kernel/generic/src/ipc/ops/stchngath.c

@@ -34 +34 @@
 
 #include <ipc/sysipc_ops.h>
+#include <ipc/ipc.h>
+#include <ipc/ipcrsc.h>
+#include <synch/mutex.h>
+#include <proc/task.h>
+#include <abi/errno.h>
+#include <macros.h>
+
+static int request_preprocess(call_t *call, phone_t *phone)
+{
+        phone_t *sender_phone;
+        task_t *other_task_s;
+
+        if (phone_get(IPC_GET_ARG5(call->data), &sender_phone) != EOK)
+                return ENOENT;
+
+        mutex_lock(&sender_phone->lock);
+        if (sender_phone->state != IPC_PHONE_CONNECTED) {
+                mutex_unlock(&sender_phone->lock);
+                return EINVAL;
+        }
+
+        other_task_s = sender_phone->callee->task;
+
+        mutex_unlock(&sender_phone->lock);
+
+        /* Remember the third party task hash. */
+        IPC_SET_ARG5(call->data, (sysarg_t) other_task_s);
+
+        return EOK;
+}
+
+static int answer_preprocess(call_t *answer, ipc_data_t *olddata)
+{
+        int rc = EOK;
+
+        if (!IPC_GET_RETVAL(answer->data)) {
+                /* The recipient authorized the change of state. */
+                phone_t *recipient_phone;
+                task_t *other_task_s;
+                task_t *other_task_r;
+
+                rc = phone_get(IPC_GET_ARG1(answer->data),
+                    &recipient_phone);
+                if (rc != EOK) {
+                        IPC_SET_RETVAL(answer->data, ENOENT);
+                        return ENOENT;
+                }
+
+                mutex_lock(&recipient_phone->lock);
+                if (recipient_phone->state != IPC_PHONE_CONNECTED) {
+                        mutex_unlock(&recipient_phone->lock);
+                        IPC_SET_RETVAL(answer->data, EINVAL);
+                        return EINVAL;
+                }
+
+                other_task_r = recipient_phone->callee->task;
+                other_task_s = (task_t *) IPC_GET_ARG5(*olddata);
+
+                /*
+                 * See if both the sender and the recipient meant the
+                 * same third party task.
+                 */
+                if (other_task_r != other_task_s) {
+                        IPC_SET_RETVAL(answer->data, EINVAL);
+                        rc = EINVAL;
+                } else {
+                        rc = event_task_notify_5(other_task_r,
+                            EVENT_TASK_STATE_CHANGE, false,
+                            IPC_GET_ARG1(*olddata),
+                            IPC_GET_ARG2(*olddata),
+                            IPC_GET_ARG3(*olddata),
+                            LOWER32(olddata->task_id),
+                            UPPER32(olddata->task_id));
+                        IPC_SET_RETVAL(answer->data, rc);
+                }
+
+                mutex_unlock(&recipient_phone->lock);
+        }
+
+        return rc;
+}
 
 sysipc_ops_t ipc_m_state_change_authorize_ops = {
-        .request_preprocess = null_request_preprocess,
+        .request_preprocess = request_preprocess,
         .request_process = null_request_process,
-        .answer_preprocess = null_answer_preprocess,
+        .answer_preprocess = answer_preprocess,
         .answer_process = null_answer_process,
 };