Changes in kernel/generic/src/proc/task.c [c46bfbc:feeac0d] in mainline

File:

• kernel/generic/src/proc/task.c (modified) (17 diffs)

kernel/generic/src/proc/task.c

@@ -36 +36 @@
  */
 
-#include <assert.h>
 #include <proc/thread.h>
 #include <proc/task.h>
@@ -42 +41 @@
 #include <mm/slab.h>
 #include <atomic.h>
-#include <synch/futex.h>
 #include <synch/spinlock.h>
 #include <synch/waitq.h>
@@ -50 +48 @@
 #include <adt/btree.h>
 #include <adt/list.h>
-#include <cap/cap.h>
 #include <ipc/ipc.h>
 #include <ipc/ipcrsc.h>
@@ -58 +55 @@
 #include <func.h>
 #include <str.h>
+#include <memstr.h>
 #include <syscall/copy.h>
 #include <macros.h>
@@ -84 +82 @@
 static void task_kill_internal(task_t *);
 static int tsk_constructor(void *, unsigned int);
-static size_t tsk_destructor(void *obj);
 
 /** Initialize kernel tasks support.
@@ -94 +91 @@
         avltree_create(&tasks_tree);
         task_slab = slab_cache_create("task_t", sizeof(task_t), 0,
-            tsk_constructor, tsk_destructor, 0);
+            tsk_constructor, NULL, 0);
 }
 
@@ -161 +158 @@
 {
         task_t *task = (task_t *) obj;
-
-        int rc = caps_task_alloc(task);
-        if (rc != EOK)
-                return rc;
         
         atomic_set(&task->refcount, 0);
@@ -170 +163 @@
         
         irq_spinlock_initialize(&task->lock, "task_t_lock");
+        mutex_initialize(&task->futexes_lock, MUTEX_PASSIVE);
         
         list_initialize(&task->threads);
@@ -175 +169 @@
         ipc_answerbox_init(&task->answerbox, task);
         
+        size_t i;
+        for (i = 0; i < IPC_MAX_PHONES; i++)
+                ipc_phone_init(&task->phones[i], task);
+
         spinlock_initialize(&task->active_calls_lock, "active_calls_lock");
         list_initialize(&task->active_calls);
-                
+        
 #ifdef CONFIG_UDEBUG
         /* Init kbox stuff */
@@ -188 +186 @@
 }
 
-size_t tsk_destructor(void *obj)
-{
-        task_t *task = (task_t *) obj;
-        
-        caps_task_free(task);
-        return 0;
-}
-
 /** Create new task with no threads.
  *
@@ -213 +203 @@
         
         task->container = CONTAINER;
-        task->perms = 0;
+        task->capabilities = 0;
         task->ucycles = 0;
         task->kcycles = 0;
-
-        caps_task_init(task);
 
         task->ipc_info.call_sent = 0;
@@ -240 +228 @@
         
         if ((ipc_phone_0) &&
-            (container_check(ipc_phone_0->task->container, task->container))) {
-                cap_handle_t phone_handle = phone_alloc(task);
-                kobject_t *phone_obj = kobject_get(task, phone_handle,
-                    KOBJECT_TYPE_PHONE);
-                (void) ipc_phone_connect(phone_obj->phone, ipc_phone_0);
-        }
-        
-        futex_task_init(task);
+            (container_check(ipc_phone_0->task->container, task->container)))
+                (void) ipc_phone_connect(&task->phones[0], ipc_phone_0);
+        
+        btree_create(&task->futexes);
         
         /*
@@ -288 +272 @@
          * Free up dynamically allocated state.
          */
-        futex_task_deinit(task);
+        btree_destroy(&task->futexes);
         
         /*
@@ -436 +420 @@
 task_t *task_find_by_id(task_id_t id)
 {
-        assert(interrupts_disabled());
-        assert(irq_spinlock_locked(&tasks_lock));
+        ASSERT(interrupts_disabled());
+        ASSERT(irq_spinlock_locked(&tasks_lock));
 
         avltree_node_t *node =
@@ -460 +444 @@
 void task_get_accounting(task_t *task, uint64_t *ucycles, uint64_t *kcycles)
 {
-        assert(interrupts_disabled());
-        assert(irq_spinlock_locked(&task->lock));
+        ASSERT(interrupts_disabled());
+        ASSERT(irq_spinlock_locked(&task->lock));
 
         /* Accumulated values of task */
@@ -619 +603 @@
         if (*additional)
                 printf("%-8" PRIu64 " %9" PRIu64 "%c %9" PRIu64 "%c "
-                    "%9" PRIua "\n", task->taskid, ucycles, usuffix, kcycles,
+                    "%9" PRIua, task->taskid, ucycles, usuffix, kcycles,
                     ksuffix, atomic_get(&task->refcount));
         else
@@ -625 +609 @@
                     task->taskid, task->name, task->container, task, task->as);
 #endif
+        
+        if (*additional) {
+                size_t i;
+                for (i = 0; i < IPC_MAX_PHONES; i++) {
+                        if (task->phones[i].callee)
+                                printf(" %zu:%p", i, task->phones[i].callee);
+                }
+                printf("\n");
+        }
         
         irq_spinlock_unlock(&task->lock, false);