X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=afh.c;h=fad93c49cdca17f54558c2c6cdc25646773bea11;hp=84a061b9288f040a3b1a7d644565f17e8be90a97;hb=4e3d8370476eee8537d8dc325d588fca43928098;hpb=80e46ec589d14be2fa4b0704f613a04ecb1b64c4;ds=inline diff --git a/afh.c b/afh.c index 84a061b9..fad93c49 100644 --- a/afh.c +++ b/afh.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2008 Andre Noll + * Copyright (C) 2008-2009 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -7,6 +7,7 @@ /** \file afh.c Paraslash's standalone audio format handler tool. */ #include +#include #include "para.h" #include "string.h" @@ -20,28 +21,12 @@ static struct afh_args_info conf; const char *status_item_list[] = {STATUS_ITEM_ARRAY}; INIT_AFH_ERRLISTS; -INIT_STDERR_LOGGING(conf.loglevel_arg) -int main(int argc, char **argv) -{ - int i, ret; - void *audio_file_data; - size_t audio_file_size; - struct afh_info afhi; +static int loglevel; +INIT_STDERR_LOGGING(loglevel) - afh_cmdline_parser(argc, argv, &conf); - HANDLE_VERSION_FLAG("afh", conf); - ret = -E_AFH_SYNTAX; - if (conf.inputs_num != 1) - goto out; - afh_init(); - ret = mmap_full_file(conf.inputs[0], O_RDONLY, &audio_file_data, - &audio_file_size, NULL); - if (ret < 0) - goto out; - ret = compute_afhi(conf.inputs[0], audio_file_data, audio_file_size, &afhi); - if (ret < 0) - goto out; +static void print_info(int audio_format_num, struct afh_info *afhi) +{ printf("%s: %dkbit/s\n" /* bitrate */ "%s: %s\n" /* format */ "%s: %dHz\n" /* frequency */ @@ -50,24 +35,145 @@ int main(int argc, char **argv) "%s" /* tag info */ "%s: %lu: %lu\n" /* chunk time */ "%s: %lu\n", /* num chunks */ - status_item_list[SI_BITRATE], afhi.bitrate, - status_item_list[SI_FORMAT], audio_format_name(ret), - status_item_list[SI_FREQUENCY], afhi.frequency, - status_item_list[SI_CHANNELS], afhi.channels, - status_item_list[SI_SECONDS_TOTAL], afhi.seconds_total, - afhi.info_string, - status_item_list[SI_CHUNK_TIME], (long unsigned)afhi.chunk_tv.tv_sec, - (long unsigned)afhi.chunk_tv.tv_usec, - status_item_list[SI_NUM_CHUNKS], afhi.chunks_total + status_item_list[SI_BITRATE], afhi->bitrate, + status_item_list[SI_FORMAT], audio_format_name(audio_format_num), + status_item_list[SI_FREQUENCY], afhi->frequency, + status_item_list[SI_CHANNELS], afhi->channels, + status_item_list[SI_SECONDS_TOTAL], afhi->seconds_total, + afhi->info_string, + status_item_list[SI_CHUNK_TIME], (long unsigned)afhi->chunk_tv.tv_sec, + (long unsigned)afhi->chunk_tv.tv_usec, + status_item_list[SI_NUM_CHUNKS], afhi->chunks_total ); - ret = 1; - if (!conf.chunk_table_given) - goto out; +} + +static void print_chunk_table(struct afh_info *afhi) +{ + int i; + printf("chunk_table: "); - for (i = 0; i <= afhi.chunks_total; i++) - printf("%u ", afhi.chunk_table[i]); + for (i = 0; i <= afhi->chunks_total; i++) + printf("%u ", afhi->chunk_table[i]); printf("\n"); - ret = 1; +} + +static int cat_file(void *audio_file_data, struct afh_info *afhi) +{ + int ret; + struct timeval stream_start; + long unsigned i, first_chunk, last_chunk; + const char *buf; + size_t size; + + + if (conf.begin_chunk_arg < 0) { + if (-conf.begin_chunk_arg > afhi->chunks_total) + return -ERRNO_TO_PARA_ERROR(EINVAL); + first_chunk = afhi->chunks_total + conf.begin_chunk_arg; + } else + first_chunk = conf.begin_chunk_arg; + if (conf.end_chunk_given) { + if (conf.end_chunk_arg < 0) { + if (-conf.end_chunk_arg > afhi->chunks_total) + return -ERRNO_TO_PARA_ERROR(EINVAL); + last_chunk = afhi->chunks_total + conf.end_chunk_arg; + } else { + if (conf.end_chunk_arg >= afhi->chunks_total) + return -ERRNO_TO_PARA_ERROR(EINVAL); + last_chunk = conf.end_chunk_arg; + } + } else + last_chunk = afhi->chunks_total - 1; + if (first_chunk >= last_chunk) + return -ERRNO_TO_PARA_ERROR(EINVAL); + if (!afhi->chunks_total) + return 1; + afh_get_header(afhi, audio_file_data, &buf, &size); + if (size && first_chunk && !conf.no_header_given) { + PARA_INFO_LOG("writing audio file header (%zu bytes)\n", size); + ret = write(STDOUT_FILENO, buf, size); + if (ret < 0) + return ret; + if (ret != size) + return -E_AFH_SHORT_WRITE; + } + PARA_NOTICE_LOG("writing chunks %lu - %lu\n", first_chunk, last_chunk); + gettimeofday(&stream_start, NULL); + for (i = first_chunk; i <= last_chunk; i++) { + struct timeval now, diff, next_chunk; + afh_get_chunk(i, afhi, audio_file_data, &buf, &size); + PARA_DEBUG_LOG("chunk %lu: size %zu\n", i, size); + if (conf.just_in_time_given) { + compute_chunk_time(i - first_chunk, &afhi->chunk_tv, + &stream_start, &next_chunk); + gettimeofday(&now, NULL); + ret = tv_diff(&next_chunk, &now, &diff); + if (ret > 0) { + ret = para_select(1, NULL, NULL, &diff); + if (ret < 0) + return ret; + } + } + if (!size) + continue; + PARA_INFO_LOG("writing chunk %lu\n", i); + ret = write_all(STDOUT_FILENO, buf, &size); + if (ret < 0) + return ret; + } + return 1; +} + +/** + * The main function of para_afh. + * + * \param argc Usual argument count. + * \param argv Usual argument vector. + * + * \return \p EXIT_FAILURE or \p EXIT_SUCCESS. + */ +int main(int argc, char **argv) +{ + int i, ret, audio_format_num, fd; + void *audio_file_data; + size_t audio_file_size; + struct afh_info afhi; + + afh_cmdline_parser(argc, argv, &conf); + HANDLE_VERSION_FLAG("afh", conf); + loglevel = get_loglevel_by_name(conf.loglevel_arg); + ret = -E_AFH_SYNTAX; + if (conf.inputs_num == 0) + goto out; + if (conf.stream_given && conf.inputs_num != 1) + goto out; + afh_init(); + for (i = 0; i < conf.inputs_num; i++) { + int ret2; + ret = mmap_full_file(conf.inputs[i], O_RDONLY, &audio_file_data, + &audio_file_size, &fd); + if (ret < 0) + goto out; + ret = compute_afhi(conf.inputs[i], audio_file_data, audio_file_size, + fd, &afhi); + if (ret < 0) + goto out; + audio_format_num = ret; + if (conf.stream_given) + ret = cat_file(audio_file_data, &afhi); + else { + printf("File %d: %s\n", i + 1, conf.inputs[i]); + print_info(audio_format_num, &afhi); + if (conf.chunk_table_given) + print_chunk_table(&afhi); + printf("\n"); + } + ret2 = para_munmap(audio_file_data, audio_file_size); + if (ret2 < 0 && ret >= 0) + ret = ret2; + if (ret < 0) + break; + } out: if (ret < 0) PARA_ERROR_LOG("%s\n", para_strerror(-ret));