Changeset 48bcf49 in mainline for kernel/generic/src/ipc/ops/conctmeto.c

Timestamp:

2017-09-28T22:08:15Z (8 years ago)

Author:

Jakub Jermar <jakub@…>

Branches:

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

Children:

6636fb19

Parents:

dd20cbb

Message:

Introduce reference-counted kobjects

Capabilities are thus reduced to task-local names for references to kobjects.

File:

• kernel/generic/src/ipc/ops/conctmeto.c (modified) (5 diffs)

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

@@ -1 +1 @@
 /*
  * Copyright (c) 2006 Ondrej Palkovsky
- * Copyright (c) 2012 Jakub Jermar 
+ * Copyright (c) 2012 Jakub Jermar
  * All rights reserved.
  *
@@ -42 +42 @@
 static int request_preprocess(call_t *call, phone_t *phone)
 {
-        int cap = phone_alloc(TASK);
+        cap_handle_t phone_handle = phone_alloc(TASK);
 
         /* Remember the phone capability or the error. */
-        call->priv = cap;
-        if (cap < 0)
-                return ELIMIT;
-                
+        call->priv = phone_handle;
+        if (phone_handle < 0)
+                return phone_handle;
+
         /* Set arg5 for server */
-        IPC_SET_ARG5(call->data, (sysarg_t) phone_get_current(cap));
+        kobject_t *phone_obj = kobject_get(TASK, phone_handle,
+            KOBJECT_TYPE_PHONE);
+        /* Hand over phone_obj's reference to ARG5 */
+        IPC_SET_ARG5(call->data, (sysarg_t) phone_obj->phone);
 
         return EOK;
@@ -57 +60 @@
 static int request_forget(call_t *call)
 {
-        phone_dealloc(call->priv);
+        cap_handle_t phone_handle = (cap_handle_t) call->priv;
+        phone_dealloc(phone_handle);
+        /* Hand over reference from ARG5 to phone->kobject */
+        phone_t *phone = (phone_t *) IPC_GET_ARG5(call->data);
+        /* Drop phone_obj's reference */
+        kobject_put(phone->kobject);
         return EOK;
 }
@@ -63 +71 @@
 static int answer_preprocess(call_t *answer, ipc_data_t *olddata)
 {
+        /* Hand over reference from ARG5 to phone */
         phone_t *phone = (phone_t *) IPC_GET_ARG5(*olddata);
 
         /* If the user accepted call, connect */
-        if (IPC_GET_RETVAL(answer->data) == EOK)
+        if (IPC_GET_RETVAL(answer->data) == EOK) {
+                /* Hand over reference from phone to the answerbox */
                 (void) ipc_phone_connect(phone, &TASK->answerbox);
+        } else {
+                kobject_put(phone->kobject);
+        }
 
         return EOK;
@@ -74 +87 @@
 static int answer_process(call_t *answer)
 {
-        int cap = (int) answer->priv;
+        cap_handle_t phone_handle = (cap_handle_t) answer->priv;
 
         if (IPC_GET_RETVAL(answer->data)) {
-                if (cap >= 0) {
+                if (phone_handle >= 0) {
                         /*
                          * The phone was indeed allocated and now needs
                          * to be deallocated.
                          */
-                        phone_dealloc(cap);
+                        phone_dealloc(phone_handle);
                 }
         } else {
-                IPC_SET_ARG5(answer->data, cap);
+                IPC_SET_ARG5(answer->data, phone_handle);
         }