2 * Copyright (C) 2008-2012 Andre Noll <maan@systemlinux.org>
4 * Licensed under the GPL v2. For licencing details see COPYING.
7 /** \file afh.c Paraslash's standalone audio format handler tool. */
14 #include "afh.cmdline.h"
20 static struct afh_args_info conf
;
21 /** The list of all status items */
22 const char *status_item_list
[] = {STATUS_ITEM_ARRAY
};
27 INIT_STDERR_LOGGING(loglevel
)
29 static void print_info(int audio_format_num
, struct afh_info
*afhi
)
31 printf("%s: %dkbit/s\n" /* bitrate */
32 "%s: %s\n" /* format */
33 "%s: %dHz\n" /* frequency */
34 "%s: %d\n" /* channels */
35 "%s: %lu\n" /* seconds total */
36 "%s: %lu: %lu\n" /* chunk time */
37 "%s: %lu\n" /* num chunks */
38 "%s: %s\n" /* techinfo */
39 "%s: %s\n" /* artist */
40 "%s: %s\n" /* title */
42 "%s: %s\n" /* album */
43 "%s: %s\n", /* comment */
44 status_item_list
[SI_BITRATE
], afhi
->bitrate
,
45 status_item_list
[SI_FORMAT
], audio_format_name(audio_format_num
),
46 status_item_list
[SI_FREQUENCY
], afhi
->frequency
,
47 status_item_list
[SI_CHANNELS
], afhi
->channels
,
48 status_item_list
[SI_SECONDS_TOTAL
], afhi
->seconds_total
,
49 status_item_list
[SI_CHUNK_TIME
], (long unsigned)afhi
->chunk_tv
.tv_sec
,
50 (long unsigned)afhi
->chunk_tv
.tv_usec
,
51 status_item_list
[SI_NUM_CHUNKS
], afhi
->chunks_total
,
52 status_item_list
[SI_TECHINFO
], afhi
->techinfo
? afhi
->techinfo
: "",
53 status_item_list
[SI_ARTIST
], afhi
->tags
.artist
? afhi
->tags
.artist
: "",
54 status_item_list
[SI_TITLE
], afhi
->tags
.title
? afhi
->tags
.title
: "",
55 status_item_list
[SI_YEAR
], afhi
->tags
.year
? afhi
->tags
.year
: "",
56 status_item_list
[SI_ALBUM
], afhi
->tags
.album
? afhi
->tags
.album
: "",
57 status_item_list
[SI_COMMENT
], afhi
->tags
.comment
? afhi
->tags
.comment
: ""
61 static void print_chunk_table(struct afh_info
*afhi
)
65 if (!conf
.human_given
) {
66 printf("chunk_table: ");
67 for (i
= 0; i
<= afhi
->chunks_total
; i
++)
68 printf("%u ", afhi
->chunk_table
[i
]);
72 for (i
= 1; i
<= afhi
->chunks_total
; i
++) {
74 long unsigned from
, to
;
75 tv_scale(i
- 1, &afhi
->chunk_tv
, &tv
);
77 tv_scale(i
, &afhi
->chunk_tv
, &tv
);
79 printf("%d [%lu.%03lu - %lu.%03lu] %u - %u (%u)\n", i
- 1,
80 from
/ 1000, from
% 1000, to
/ 1000, to
% 1000,
81 afhi
->chunk_table
[i
- 1], afhi
->chunk_table
[i
],
82 afhi
->chunk_table
[i
] - afhi
->chunk_table
[i
- 1]);
86 static int cat_file(struct afh_info
*afhi
, int audio_format_id
,
87 void *audio_file_data
, size_t audio_file_size
)
90 struct timeval stream_start
;
91 long unsigned i
, first_chunk
, last_chunk
;
96 if (conf
.begin_chunk_arg
< 0) {
97 if (-conf
.begin_chunk_arg
> afhi
->chunks_total
)
98 return -ERRNO_TO_PARA_ERROR(EINVAL
);
99 first_chunk
= afhi
->chunks_total
+ conf
.begin_chunk_arg
;
101 first_chunk
= conf
.begin_chunk_arg
;
102 if (conf
.end_chunk_given
) {
103 if (conf
.end_chunk_arg
< 0) {
104 if (-conf
.end_chunk_arg
> afhi
->chunks_total
)
105 return -ERRNO_TO_PARA_ERROR(EINVAL
);
106 last_chunk
= afhi
->chunks_total
+ conf
.end_chunk_arg
;
108 if (conf
.end_chunk_arg
>= afhi
->chunks_total
)
109 return -ERRNO_TO_PARA_ERROR(EINVAL
);
110 last_chunk
= conf
.end_chunk_arg
;
113 last_chunk
= afhi
->chunks_total
- 1;
114 if (first_chunk
>= last_chunk
)
115 return -ERRNO_TO_PARA_ERROR(EINVAL
);
116 if (!afhi
->chunks_total
)
118 /* eliminate the possibility of short writes */
119 ret
= mark_fd_blocking(STDOUT_FILENO
);
122 if (first_chunk
> 0 && !conf
.no_header_given
) {
123 afh_get_header(afhi
, audio_format_id
, audio_file_data
, audio_file_size
,
126 PARA_INFO_LOG("writing header (%zu bytes)\n", size
);
127 ret
= write(STDOUT_FILENO
, header
, size
); /* FIXME */
128 afh_free_header(header
, audio_format_id
);
132 return -E_AFH_SHORT_WRITE
;
135 PARA_NOTICE_LOG("writing chunks %lu - %lu\n", first_chunk
, last_chunk
);
136 gettimeofday(&stream_start
, NULL
);
137 for (i
= first_chunk
; i
<= last_chunk
; i
++) {
138 struct timeval now
, diff
, next_chunk
;
139 afh_get_chunk(i
, afhi
, audio_file_data
, &buf
, &size
);
140 PARA_DEBUG_LOG("chunk %lu: size %zu\n", i
, size
);
141 if (conf
.just_in_time_given
) {
142 compute_chunk_time(i
- first_chunk
, &afhi
->chunk_tv
,
143 &stream_start
, &next_chunk
);
144 gettimeofday(&now
, NULL
);
145 ret
= tv_diff(&next_chunk
, &now
, &diff
);
147 ret
= para_select(1, NULL
, NULL
, &diff
);
154 PARA_INFO_LOG("writing chunk %lu\n", i
);
155 ret
= write_all(STDOUT_FILENO
, buf
, &size
);
163 * The main function of para_afh.
165 * \param argc Usual argument count.
166 * \param argv Usual argument vector.
168 * \return \p EXIT_FAILURE or \p EXIT_SUCCESS.
170 int main(int argc
, char **argv
)
172 int i
, ret
, audio_format_num
, fd
;
173 void *audio_file_data
;
174 size_t audio_file_size
;
175 struct afh_info afhi
;
177 afh_cmdline_parser(argc
, argv
, &conf
);
178 HANDLE_VERSION_FLAG("afh", conf
);
179 loglevel
= get_loglevel_by_name(conf
.loglevel_arg
);
181 if (conf
.inputs_num
== 0)
183 if (conf
.stream_given
&& conf
.inputs_num
!= 1)
186 for (i
= 0; i
< conf
.inputs_num
; i
++) {
188 ret
= mmap_full_file(conf
.inputs
[i
], O_RDONLY
, &audio_file_data
,
189 &audio_file_size
, &fd
);
192 ret
= compute_afhi(conf
.inputs
[i
], audio_file_data
, audio_file_size
,
197 audio_format_num
= ret
;
198 if (conf
.stream_given
)
199 ret
= cat_file(&afhi
, audio_format_num
,
200 audio_file_data
, audio_file_size
);
202 printf("File %d: %s\n", i
+ 1, conf
.inputs
[i
]);
203 print_info(audio_format_num
, &afhi
);
204 if (conf
.chunk_table_given
)
205 print_chunk_table(&afhi
);
209 free(afhi
.tags
.artist
);
210 free(afhi
.tags
.title
);
211 free(afhi
.tags
.year
);
212 free(afhi
.tags
.album
);
213 free(afhi
.tags
.comment
);
214 free(afhi
.chunk_table
);
215 ret2
= para_munmap(audio_file_data
, audio_file_size
);
216 if (ret2
< 0 && ret
>= 0)
223 PARA_ERROR_LOG("%s\n", para_strerror(-ret
));
224 return ret
< 0? EXIT_FAILURE
: EXIT_SUCCESS
;