X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=audiod_command.c;h=5bd511df7693a1c6713b2c95917791a1a72d2d39;hp=fe8143ba928651e1aef5ccdb22d70e4200f0672f;hb=ff3b3cccbb2d8900270fddadcdb3bbc2f1d85f98;hpb=122af971c336b33df2e7233d3cea3287bbdae712 diff --git a/audiod_command.c b/audiod_command.c index fe8143ba..5bd511df 100644 --- a/audiod_command.c +++ b/audiod_command.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2005-2008 Andre Noll + * Copyright (C) 2005-2009 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -14,6 +14,7 @@ #include "list.h" #include "close_on_fork.h" #include "sched.h" +#include "ggo.h" #include "filter.h" #include "grab_client.cmdline.h" #include "grab_client.h" @@ -45,20 +46,22 @@ __malloc static char *audiod_status_string(void) return make_message("%s: %s\n", status_item_list[SI_AUDIOD_STATUS], status); } -static struct timeval *wstime(void) +static int get_play_time_slot_num(void) { - int i; - struct timeval *max = NULL; + int i, oldest = -1; + FOR_EACH_SLOT(i) { struct slot_info *s = &slot[i]; if (!s->wng) continue; - if (max && tv_diff(&s->wstime, max, NULL) <= 0) + if (oldest >= 0 && tv_diff(&s->wstime, &slot[oldest].wstime, + NULL) > 0) continue; - max = &s->wstime; + oldest = i; } - return max; + return oldest; } + __malloc static char *decoder_flags(void) { int i; @@ -163,59 +166,61 @@ int com_kill(int fd, int argc, char **argv) return ret; } -int com_stat(int fd, __a_unused int argc, __a_unused char **argv) +int com_stat(int fd, int argc, char **argv) { int i, ret; char *buf = NULL; - long unsigned mask = ~0LU; + uint64_t mask = 0; + const uint64_t one = 1; if (argc > 1) { - mask = 0; for (i = 1; i < argc; i++) { ret = stat_item_valid(argv[i]); if (ret < 0) return ret; - mask |= (1 << ret); + mask |= (one << ret); } - } - PARA_INFO_LOG("mask: 0x%lx\n", mask); - if (mask & (1 << SI_PLAY_TIME)) { - struct timeval *t = wstime(); - char *ts = get_time_string(t); + } else + mask--; /* set all bits */ + PARA_INFO_LOG("mask: 0x%llx\n", (long long unsigned)mask); + if (mask & (one << SI_PLAY_TIME)) { + int slot_num = get_play_time_slot_num(); + char *ts = get_time_string(slot_num); if (ts) { + PARA_ERROR_LOG("play time: %s\n", ts); ret = client_write(fd, ts); + free(ts); if (ret < 0) goto out; - free(ts); } } - if (mask & (1 << SI_AUDIOD_UPTIME)) { + if (mask & (one << SI_AUDIOD_UPTIME)) { char *tmp, *us = uptime_str(); tmp = make_message("%s: %s\n", status_item_list[SI_AUDIOD_UPTIME], us); free(us); ret = client_write(fd, tmp); + free(tmp); if (ret < 0) goto out; - free(tmp); } - if (mask & (1 << SI_AUDIOD_STATUS)) { + if (mask & (one << SI_AUDIOD_STATUS)) { char *s = audiod_status_string(); ret = client_write(fd, s); + free(s); if (ret < 0) goto out; - free(s); } - if (mask & (1 << SI_DECODER_FLAGS)) { + if (mask & (one << SI_DECODER_FLAGS)) { char *df = decoder_flags(); ret = client_write(fd, df); + free(df); if (ret < 0) goto out; - free(df); } FOR_EACH_STATUS_ITEM(i) { char *tmp, *v; - if (!((1 << i) & mask)) + if (!((one << i) & mask)) continue; v = stat_item_values[i]; tmp = make_message("%s%s%s", buf? buf: "", @@ -378,7 +383,6 @@ int handle_connect(int accept_fd) ret = check_perms(uid); if (ret < 0) goto out; - ret = -E_INVALID_AUDIOD_CMD; cmd = para_strdup(buf); p = strchr(cmd, '\n'); if (!p) @@ -422,11 +426,11 @@ out: */ void audiod_status_dump(void) { - struct timeval *t = wstime(); + int slot_num = get_play_time_slot_num(); char *old, *new, *tmp; old = stat_item_values[SI_PLAY_TIME]; - new = get_time_string(t); + new = get_time_string(slot_num); if (new) { if (!old || strcmp(old, new)) { free(old);