- ret = client_open(argc, argv, &st->ct);
- }
- set_stat_task_restart_barrier();
- if (ret < 0)
- return;
- s->timeout.tv_sec = 0;
- s->timeout.tv_usec = 1;
-}
-
-static void status_post_select(__a_unused struct sched *s, struct task *t)
-{
- struct status_task *st = container_of(t, struct status_task, task);
- unsigned bytes_left;
-
- if (!st->ct || st->ct->status != CL_RECEIVING)
- return;
- if (st->ct && audiod_status == AUDIOD_OFF) {
- unregister_task(&st->ct->task);
- close_stat_pipe();
- st->clock_diff_count = conf.clock_diff_count_arg;
- return;
- }
- bytes_left = for_each_line(st->ct->buf, st->ct->loaded,
- &check_stat_line, NULL);
- if (st->ct->loaded != bytes_left) {
- st->last_status_read = *now;
- st->ct->loaded = bytes_left;
- } else {
- struct timeval diff;
- tv_diff(now, &st->last_status_read, &diff);
- if (diff.tv_sec > 61)
- close_stat_pipe();
+ client_open(argc, argv, &st->ct);
+ set_stat_task_restart_barrier(5);