Changeset adb49f58 in mainline for uspace/srv/ns/task.c

Timestamp:

2009-07-06T20:16:15Z (15 years ago)

Author:

Jiri Svoboda <jirik.svoboda@…>

Branches:

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

Children:

95bc57c

Parents:

0315679

Message:

Allow to determine whether a task returned value before terminatign.

File:

• uspace/srv/ns/task.c (modified) (9 diffs)

uspace/srv/ns/task.c

@@ -57 +57 @@
 typedef struct {
         link_t link;
-        task_id_t id;    /**< Task ID. */
-        int retval;
-        bool destroyed;
+        task_id_t id;   /**< Task ID. */
+        bool finished;  /**< Task is done. */
+        bool have_rval; /**< Task returned a value. */
+        int retval;     /**< The return value. */
 } hashed_task_t;
 
@@ -212 +213 @@
 {
         link_t *cur;
+        task_exit_t texit;
         
 loop:
@@ -227 +229 @@
                 
                 hashed_task_t *ht = hash_table_get_instance(link, hashed_task_t, link);
-                if (!ht->destroyed)
+                if (!ht->finished)
                         continue;
                 
-                if (!(pr->callid & IPC_CALLID_NOTIFICATION))
-                        ipc_answer_1(pr->callid, EOK, ht->retval);
-                
+                if (!(pr->callid & IPC_CALLID_NOTIFICATION)) {
+                        texit = ht->have_rval ? TASK_EXIT_NORMAL :
+                            TASK_EXIT_UNEXPECTED;
+                        ipc_answer_2(pr->callid, EOK, texit,
+                            ht->retval);
+                }
+
                 hash_table_remove(&task_hash_table, keys, 2);
                 list_remove(cur);
@@ -243 +249 @@
 {
         ipcarg_t retval;
+        task_exit_t texit;
+
         unsigned long keys[2] = {
                 LOWER32(id),
@@ -258 +266 @@
         }
 
-        if (!ht->destroyed) {
+        if (!ht->finished) {
                 /* Add to pending list */
                 pending_wait_t *pr =
@@ -277 +285 @@
         
 out:
-        if (!(callid & IPC_CALLID_NOTIFICATION))
-                ipc_answer_1(callid, retval, ht->retval);
+        if (!(callid & IPC_CALLID_NOTIFICATION)) {
+                texit = ht->have_rval ? TASK_EXIT_NORMAL : TASK_EXIT_UNEXPECTED;
+                ipc_answer_2(callid, retval, texit, ht->retval);
+        }
 }
 
@@ -319 +329 @@
         link_initialize(&ht->link);
         ht->id = id;
-        ht->destroyed = false;
+        ht->finished = false;
+        ht->have_rval = false;
         ht->retval = -1;
         hash_table_insert(&task_hash_table, keys, &ht->link);
@@ -343 +354 @@
             hash_table_get_instance(link, hashed_task_t, link) : NULL;
         
-        if ((ht == NULL) || ht->destroyed)
+        if ((ht == NULL) || ht->finished)
                 return EINVAL;
 
+        ht->finished = true;
+        ht->have_rval = true;
         ht->retval = IPC_GET_ARG1(*call);
 
@@ -372 +385 @@
         hashed_task_t *ht =
             hash_table_get_instance(link, hashed_task_t, link);
-        assert(ht != NULL);
-
-        ht->destroyed = true;
+        if (ht == NULL)
+                return EOK;
+
+        ht->finished = true;
 
         return EOK;