static int open_current_receiver(struct sched *s)
{
- int i;
struct timeval diff;
- char *audio_format = stat_task->stat_item_values[SI_FORMAT];
+ int cafn = stat_task->current_audio_format_num;
- if (!audio_format || !stat_task->pcd)
- return 0;
- i = get_audio_format_num(audio_format + strlen(
- status_item_list[SI_FORMAT]) + 1);
- if (i < 0)
+ if (cafn < 0 || !stat_task->pcd)
return 0;
- if (receiver_running(i))
+ if (receiver_running(cafn))
return 0;
- if (tv_diff(now, &afi[i].restart_barrier, &diff) < 0) {
+ if (tv_diff(now, &afi[cafn].restart_barrier, &diff) < 0) {
s->timeout = diff;
return 0;
}
- return open_receiver(i) < 0? 0 : 1;
+ return open_receiver(cafn) < 0? 0 : 1;
}
static unsigned compute_time_diff(const struct timeval *status_time)
if (stat_task->clock_diff_count)
stat_task->clock_diff_count--;
break;
+ case SI_FORMAT:
+ stat_task->current_audio_format_num = get_audio_format_num(
+ line + ilen + 1);
}
return 1;
}
a = &afi[sl->format];
if (!sl->receiver_node)
continue;
+ if ((!a->num_filters || sl->fc) && sl->wng)
+ continue; /* everything already started */
if (!a->num_filters) {
if (sl->receiver_node->loaded && !sl->wng) {
open_writers(i);
s->timeout = min_delay;
continue;
}
- if (!sl->fc || !*sl->fc->out_loaded || sl->wng)
+ if (sl->wng || !sl->fc || !*sl->fc->out_loaded)
continue;
if (tv_diff(now, &initial_delay_barrier, &diff) > 0) {
open_writers(i);
return 1;
}
+/* does not unlink socket on errors */
static int audiod_get_socket(void)
{
struct sockaddr_un unix_addr;
- int fd;
+ int ret, fd;
if (conf.socket_given)
socket_name = para_strdup(conf.socket_arg);
PARA_NOTICE_LOG("local socket: %s\n", socket_name);
if (conf.force_given)
unlink(socket_name);
- fd = create_local_socket(socket_name, &unix_addr,
- S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IWOTH);
- if (fd < 0) {
- PARA_EMERG_LOG("can not connect to socket\n");
- exit(EXIT_FAILURE); /* do not unlink socket */
- }
+ ret = create_local_socket(socket_name, &unix_addr,
+ S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IWOTH);
+ if (ret < 0)
+ goto err;
+ fd = ret;
if (listen(fd , 5) < 0) {
- PARA_EMERG_LOG("can not listen on socket\n");
- exit(EXIT_FAILURE); /* do not unlink socket */
+ ret = -ERRNO_TO_PARA_ERROR(errno);
+ goto err;
}
- mark_fd_nonblocking(fd);
+ ret = mark_fd_nonblocking(fd);
+ if (ret < 0)
+ goto err;
return fd;
+err:
+ PARA_EMERG_LOG("%s\n", para_strerror(-ret));
+ exit(EXIT_FAILURE);
}
static void signal_event_handler(struct task *t)
st->task.private_data = st;
st->sa_time_diff_sign = 1;
st->clock_diff_count = conf.clock_diff_count_arg;
+ st->current_audio_format_num = -1;
sprintf(st->task.status, "status task");
}