sched: Introduce task_status().

Before struct task can be made private to sched.c we must eliminate
code which directly accesses the fields of this structure. The last
offender is ->error: in many places we check this field to detect
whether some task is in an error condition.

This patch provides a public accessor function, task_status(),
for this purpose. All users of ->error are modified to call this
function instead.

diff --git a/audiod.c b/audiod.c
index 461efaffbbb0b09ac4359d9b08b6751c7cc45f77..ee1364433e77de965e715fe59692040e6e590989 100644 (file)
--- a/audiod.c
+++ b/audiod.c
@@ -593,7 +593,7 @@ static bool receiver_running(void)
 
                if (!s->receiver_node)
                        continue;
 
                if (!s->receiver_node)
                        continue;

-               if (s->receiver_node->task->error >= 0)
+               if (task_status(s->receiver_node->task) >= 0)

                        return true;
                if (ss1 == ss2)
                        return true;
                        return true;
                if (ss1 == ss2)
                        return true;


@@ -620,7 +620,7 @@ struct btr_node *audiod_get_btr_root(void)
                struct timeval rstime;
                if (!s->receiver_node)
                        continue;
                struct timeval rstime;
                if (!s->receiver_node)
                        continue;

-               if (s->receiver_node->task->error < 0)
+               if (task_status(s->receiver_node->task) < 0)

                        continue;
                btr_get_node_start(s->receiver_node->btrn, &rstime);
                if (newest_slot >= 0 && tv_diff(&rstime, &newest_rstime, NULL) < 0)
                        continue;
                btr_get_node_start(s->receiver_node->btrn, &rstime);
                if (newest_slot >= 0 && tv_diff(&rstime, &newest_rstime, NULL) < 0)


@@ -1109,17 +1109,17 @@ static bool must_close_slot(int slot_num)
 
        if (s->format < 0)
                return false;
 
        if (s->format < 0)
                return false;

-       if (s->receiver_node && s->receiver_node->task->error >= 0)
+       if (s->receiver_node && task_status(s->receiver_node->task) >= 0)

                return false;
        for (i = 0; i < a->num_filters; i++)
                return false;
        for (i = 0; i < a->num_filters; i++)

-               if (s->fns && s->fns[i].task->error >= 0)
+               if (s->fns && task_status(s->fns[i].task) >= 0)

                        return false;
        if (a->num_writers > 0) {
                for (i = 0; i < a->num_writers; i++)
                        return false;
        if (a->num_writers > 0) {
                for (i = 0; i < a->num_writers; i++)

-                       if (s->wns && s->wns[i].task->error >= 0)
+                       if (s->wns && task_status(s->wns[i].task) >= 0)

                                return false;
        } else {
                                return false;
        } else {

-               if (s->wns && s->wns[0].task->error >= 0)
+               if (s->wns && task_status(s->wns[0].task) >= 0)

                        return false;
        }
        return true;
                        return false;
        }
        return true;


@@ -1235,7 +1235,7 @@ static int status_post_select(struct sched *s, struct task *t)
        if (audiod_status == AUDIOD_OFF) {
                if (!st->ct)
                        goto out;
        if (audiod_status == AUDIOD_OFF) {
                if (!st->ct)
                        goto out;

-               if (st->ct->task->error >= 0) {
+               if (task_status(st->ct->task) >= 0) {

                        task_notify(st->ct->task, E_AUDIOD_OFF);
                        goto out;
                }
                        task_notify(st->ct->task, E_AUDIOD_OFF);
                        goto out;
                }

diff --git a/client.c b/client.c
index 88b1e93a024f7028709614be0b2e763d1091697d..5573d037794d8b34049200b9bb32322074a39cbb 100644 (file)
--- a/client.c
+++ b/client.c
@@ -536,9 +536,10 @@ struct supervisor_task {
 static int supervisor_post_select(struct sched *s, struct task *t)
 {
        struct supervisor_task *svt = task_context(t);
 static int supervisor_post_select(struct sched *s, struct task *t)
 {
        struct supervisor_task *svt = task_context(t);

+       int ret = task_status(ct->task);

 
 

-       if (ct->task->error < 0)
-               return ct->task->error;
+       if (ret < 0)
+               return ret;

        if (!svt->stdout_task_started && ct->status == CL_EXECUTING) {
                stdout_task_register(&sot, s);
                svt->stdout_task_started = true;
        if (!svt->stdout_task_started && ct->status == CL_EXECUTING) {
                stdout_task_register(&sot, s);
                svt->stdout_task_started = true;


@@ -606,16 +607,19 @@ int main(int argc, char *argv[])
        }, &sched);
 
        ret = schedule(&sched);
        }, &sched);
 
        ret = schedule(&sched);

-       if (ret >= 0 && ct->task->error < 0) {
-               switch (ct->task->error) {
-               /* these are not errors */
-               case -E_SERVER_CMD_SUCCESS:
-               case -E_EOF:
-               case -E_SERVER_EOF:
-               case -E_BTR_EOF:
-                       ret = 0;
-                       break;
-               default: ret = -E_SERVER_CMD_FAILURE;
+       if (ret >= 0) {
+               ret = task_status(ct->task);
+               if (ret < 0) {
+                       switch (ret) {
+                       /* these are not errors */
+                       case -E_SERVER_CMD_SUCCESS:
+                       case -E_EOF:
+                       case -E_SERVER_EOF:
+                       case -E_BTR_EOF:
+                               ret = 0;
+                               break;
+                       default: ret = -E_SERVER_CMD_FAILURE;
+                       }

                }
        }
        sched_shutdown(&sched);
                }
        }
        sched_shutdown(&sched);

diff --git a/interactive.c b/interactive.c
index 6a1db53620cfa60f1061cc2bcf185aee2659373b..c5cdf12ea3781d9bc0b5ca860f2a642d6161dafa 100644 (file)
--- a/interactive.c
+++ b/interactive.c
@@ -52,7 +52,7 @@ static struct i9e_private i9e_private, *i9ep = &i9e_private;
  */
 int i9e_get_error(void)
 {
  */
 int i9e_get_error(void)
 {

-       return i9ep->task->error;
+       return task_status(i9ep->task);

 }
 
 static bool is_prefix(const char *partial, const char *full, size_t len)
 }
 
 static bool is_prefix(const char *partial, const char *full, size_t len)

diff --git a/play.c b/play.c
index f4202d2865c4357365a44f6ede33c8128be00568..088a1bff0919edac79444b63d32cc72673464523 100644 (file)
--- a/play.c
+++ b/play.c
@@ -247,12 +247,12 @@ static int get_playback_error(struct play_task *pt)
 
        if (!pt->wn.task)
                return 0;
 
        if (!pt->wn.task)
                return 0;

-       err = pt->wn.task->error;
+       err = task_status(pt->wn.task);

        if (err >= 0)
                return 0;
        if (err >= 0)
                return 0;

-       if (pt->fn.task->error >= 0)
+       if (task_status(pt->fn.task) >= 0)

                return 0;
                return 0;

-       if (pt->rn.task->error >= 0)
+       if (task_status(pt->rn.task) >= 0)

                return 0;
        if (err == -E_BTR_EOF || err == -E_RECV_EOF || err == -E_EOF
                        || err == -E_WRITE_COMMON_EOF)
                return 0;
        if (err == -E_BTR_EOF || err == -E_RECV_EOF || err == -E_EOF
                        || err == -E_WRITE_COMMON_EOF)

diff --git a/sched.c b/sched.c
index 1b83b704fb48599d7c44ba540bc90b90e040be9b..fb0d4d63eacda82cb4e0779d72daa56c2634a324 100644 (file)
--- a/sched.c
+++ b/sched.c
@@ -315,6 +315,25 @@ int task_get_notification(const struct task *t)
        return t->notification;
 }
 
        return t->notification;
 }
 

+/**
+ * Return the status value of a task.
+ *
+ * \param t The task to get the status value from.
+ *
+ * \return Zero if task does not exist, one if task is running, negative error
+ * code if task has terminated.
+ */
+int task_status(const struct task *t)
+{
+       if (!t)
+               return 0;
+       if (t->dead)
+               return 0;
+       if (t->error >= 0)
+               return 1;
+       return t->error;
+}
+

 /**
  * Set the notification value of all tasks of a scheduler instance.
  *
 /**
  * Set the notification value of all tasks of a scheduler instance.
  *

diff --git a/sched.h b/sched.h
index db6ee7dc3a21a6a87037a3bad331d4ae081e271a..6a35f0e8e56a2f7fa4609ce63906d57981dbff0b 100644 (file)
--- a/sched.h
+++ b/sched.h
@@ -103,6 +103,7 @@ char *get_task_list(struct sched *s);
 void task_notify(struct task *t, int err);
 void task_notify_all(struct sched *s, int err);
 int task_get_notification(const struct task *t);
 void task_notify(struct task *t, int err);
 void task_notify_all(struct sched *s, int err);
 int task_get_notification(const struct task *t);

+int task_status(const struct task *t);

 int task_reap(struct task **tptr);
 void sched_min_delay(struct sched *s);
 void sched_request_timeout(struct timeval *to, struct sched *s);
 int task_reap(struct task **tptr);
 void sched_min_delay(struct sched *s);
 void sched_request_timeout(struct timeval *to, struct sched *s);

diff --git a/write.c b/write.c
index 15bbb4a6399dd0739b41d3ee6c7b73e4c6af5fbc..440778407b3c8388e278a0cd79f505fe016c28ce 100644 (file)
--- a/write.c
+++ b/write.c
@@ -123,16 +123,17 @@ static int setup_and_schedule(void)
        s.default_timeout.tv_usec = 50000;
        ret = schedule(&s);
        if (ret >= 0) {
        s.default_timeout.tv_usec = 50000;
        ret = schedule(&s);
        if (ret >= 0) {

-               int j;
+               int j, ts;

                for (j = 0; j < i; j++) {
                for (j = 0; j < i; j++) {

-                       struct task *t = wns[j].task;
-                       assert(t->error < 0);
-                       if (t->error != -E_WRITE_COMMON_EOF
-                                       && t->error != -E_BTR_EOF) {
-                               PARA_ERROR_LOG("%s: %s\n", t->status,
-                                       para_strerror(-t->error));
+                       struct writer_node *wn = wns + j;
+                       ts = task_status(wn->task);
+                       assert(ts < 0);
+                       if (ts != -E_WRITE_COMMON_EOF && ts != -E_BTR_EOF) {
+                               const char *name = writer_names[wn->writer_num];
+                               PARA_ERROR_LOG("%s: %s\n", name,
+                                       para_strerror(-ts));

                                if (ret >= 0)
                                if (ret >= 0)

-                                       ret = t->error;
+                                       ret = ts;

                        }
                }
        }
                        }
                }
        }