Line | Branch | Exec | Source |
---|---|---|---|
1 | /* | ||
2 | * This file is part of FFmpeg. | ||
3 | * | ||
4 | * FFmpeg is free software; you can redistribute it and/or | ||
5 | * modify it under the terms of the GNU Lesser General Public | ||
6 | * License as published by the Free Software Foundation; either | ||
7 | * version 2.1 of the License, or (at your option) any later version. | ||
8 | * | ||
9 | * FFmpeg is distributed in the hope that it will be useful, | ||
10 | * but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
11 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | ||
12 | * Lesser General Public License for more details. | ||
13 | * | ||
14 | * You should have received a copy of the GNU Lesser General Public | ||
15 | * License along with FFmpeg; if not, write to the Free Software | ||
16 | * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA | ||
17 | */ | ||
18 | |||
19 | #include <float.h> | ||
20 | #include <stdint.h> | ||
21 | |||
22 | #include "ffmpeg.h" | ||
23 | |||
24 | #include "libavutil/avassert.h" | ||
25 | #include "libavutil/avstring.h" | ||
26 | #include "libavutil/display.h" | ||
27 | #include "libavutil/error.h" | ||
28 | #include "libavutil/intreadwrite.h" | ||
29 | #include "libavutil/opt.h" | ||
30 | #include "libavutil/parseutils.h" | ||
31 | #include "libavutil/pixdesc.h" | ||
32 | #include "libavutil/time.h" | ||
33 | #include "libavutil/timestamp.h" | ||
34 | #include "libavutil/thread.h" | ||
35 | #include "libavutil/threadmessage.h" | ||
36 | |||
37 | #include "libavcodec/packet.h" | ||
38 | |||
39 | #include "libavformat/avformat.h" | ||
40 | |||
41 | static const char *const opt_name_discard[] = {"discard", NULL}; | ||
42 | static const char *const opt_name_reinit_filters[] = {"reinit_filter", NULL}; | ||
43 | static const char *const opt_name_fix_sub_duration[] = {"fix_sub_duration", NULL}; | ||
44 | static const char *const opt_name_canvas_sizes[] = {"canvas_size", NULL}; | ||
45 | static const char *const opt_name_guess_layout_max[] = {"guess_layout_max", NULL}; | ||
46 | static const char *const opt_name_ts_scale[] = {"itsscale", NULL}; | ||
47 | static const char *const opt_name_hwaccels[] = {"hwaccel", NULL}; | ||
48 | static const char *const opt_name_hwaccel_devices[] = {"hwaccel_device", NULL}; | ||
49 | static const char *const opt_name_hwaccel_output_formats[] = {"hwaccel_output_format", NULL}; | ||
50 | static const char *const opt_name_autorotate[] = {"autorotate", NULL}; | ||
51 | static const char *const opt_name_display_rotations[] = {"display_rotation", NULL}; | ||
52 | static const char *const opt_name_display_hflips[] = {"display_hflip", NULL}; | ||
53 | static const char *const opt_name_display_vflips[] = {"display_vflip", NULL}; | ||
54 | |||
55 | typedef struct Demuxer { | ||
56 | InputFile f; | ||
57 | |||
58 | /* number of times input stream should be looped */ | ||
59 | int loop; | ||
60 | /* actual duration of the longest stream in a file at the moment when | ||
61 | * looping happens */ | ||
62 | int64_t duration; | ||
63 | /* time base of the duration */ | ||
64 | AVRational time_base; | ||
65 | |||
66 | /* number of streams that the user was warned of */ | ||
67 | int nb_streams_warn; | ||
68 | |||
69 | AVThreadMessageQueue *in_thread_queue; | ||
70 | int thread_queue_size; | ||
71 | pthread_t thread; | ||
72 | int non_blocking; | ||
73 | } Demuxer; | ||
74 | |||
75 | typedef struct DemuxMsg { | ||
76 | AVPacket *pkt; | ||
77 | int looping; | ||
78 | |||
79 | // repeat_pict from the demuxer-internal parser | ||
80 | int repeat_pict; | ||
81 | } DemuxMsg; | ||
82 | |||
83 | 460441 | static Demuxer *demuxer_from_ifile(InputFile *f) | |
84 | { | ||
85 | 460441 | return (Demuxer*)f; | |
86 | } | ||
87 | |||
88 | ✗ | static void report_new_stream(Demuxer *d, const AVPacket *pkt) | |
89 | { | ||
90 | ✗ | AVStream *st = d->f.ctx->streams[pkt->stream_index]; | |
91 | |||
92 | ✗ | if (pkt->stream_index < d->nb_streams_warn) | |
93 | ✗ | return; | |
94 | ✗ | av_log(NULL, AV_LOG_WARNING, | |
95 | "New %s stream %d:%d at pos:%"PRId64" and DTS:%ss\n", | ||
96 | ✗ | av_get_media_type_string(st->codecpar->codec_type), | |
97 | ✗ | d->f.index, pkt->stream_index, | |
98 | ✗ | pkt->pos, av_ts2timestr(pkt->dts, &st->time_base)); | |
99 | ✗ | d->nb_streams_warn = pkt->stream_index + 1; | |
100 | } | ||
101 | |||
102 | 6 | static void ifile_duration_update(Demuxer *d, InputStream *ist, | |
103 | int64_t last_duration) | ||
104 | { | ||
105 | /* the total duration of the stream, max_pts - min_pts is | ||
106 | * the duration of the stream without the last frame */ | ||
107 |
1/2✓ Branch 0 taken 6 times.
✗ Branch 1 not taken.
|
6 | if (ist->max_pts > ist->min_pts && |
108 |
1/2✓ Branch 0 taken 6 times.
✗ Branch 1 not taken.
|
6 | ist->max_pts - (uint64_t)ist->min_pts < INT64_MAX - last_duration) |
109 | 6 | last_duration += ist->max_pts - ist->min_pts; | |
110 | |||
111 |
3/4✓ Branch 0 taken 4 times.
✓ Branch 1 taken 2 times.
✓ Branch 2 taken 4 times.
✗ Branch 3 not taken.
|
10 | if (!d->duration || |
112 | 4 | av_compare_ts(d->duration, d->time_base, | |
113 | 4 | last_duration, ist->st->time_base) < 0) { | |
114 | 6 | d->duration = last_duration; | |
115 | 6 | d->time_base = ist->st->time_base; | |
116 | } | ||
117 | 6 | } | |
118 | |||
119 | 6 | static int seek_to_start(Demuxer *d) | |
120 | { | ||
121 | 6 | InputFile *ifile = &d->f; | |
122 | 6 | AVFormatContext *is = ifile->ctx; | |
123 | InputStream *ist; | ||
124 | int ret; | ||
125 | |||
126 | 6 | ret = avformat_seek_file(is, -1, INT64_MIN, is->start_time, is->start_time, 0); | |
127 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6 times.
|
6 | if (ret < 0) |
128 | ✗ | return ret; | |
129 | |||
130 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6 times.
|
6 | if (ifile->audio_duration_queue_size) { |
131 | /* duration is the length of the last frame in a stream | ||
132 | * when audio stream is present we don't care about | ||
133 | * last video frame length because it's not defined exactly */ | ||
134 | ✗ | int got_durations = 0; | |
135 | |||
136 | ✗ | while (got_durations < ifile->audio_duration_queue_size) { | |
137 | LastFrameDuration dur; | ||
138 | ✗ | ret = av_thread_message_queue_recv(ifile->audio_duration_queue, &dur, 0); | |
139 | ✗ | if (ret < 0) | |
140 | ✗ | return ret; | |
141 | ✗ | got_durations++; | |
142 | |||
143 | ✗ | ist = ifile->streams[dur.stream_idx]; | |
144 | ✗ | ifile_duration_update(d, ist, dur.duration); | |
145 | } | ||
146 | } else { | ||
147 |
2/2✓ Branch 0 taken 6 times.
✓ Branch 1 taken 6 times.
|
12 | for (int i = 0; i < ifile->nb_streams; i++) { |
148 | 6 | int64_t duration = 0; | |
149 | 6 | ist = ifile->streams[i]; | |
150 | |||
151 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6 times.
|
6 | if (ist->framerate.num) { |
152 | ✗ | duration = av_rescale_q(1, av_inv_q(ist->framerate), ist->st->time_base); | |
153 |
2/2✓ Branch 0 taken 2 times.
✓ Branch 1 taken 4 times.
|
6 | } else if (ist->st->avg_frame_rate.num) { |
154 | 2 | duration = av_rescale_q(1, av_inv_q(ist->st->avg_frame_rate), ist->st->time_base); | |
155 | } else { | ||
156 | 4 | duration = 1; | |
157 | } | ||
158 | |||
159 | 6 | ifile_duration_update(d, ist, duration); | |
160 | } | ||
161 | } | ||
162 | |||
163 |
1/2✓ Branch 0 taken 6 times.
✗ Branch 1 not taken.
|
6 | if (d->loop > 0) |
164 | 6 | d->loop--; | |
165 | |||
166 | 6 | return ret; | |
167 | } | ||
168 | |||
169 | 456070 | static void ts_fixup(Demuxer *d, AVPacket *pkt, int *repeat_pict) | |
170 | { | ||
171 | 456070 | InputFile *ifile = &d->f; | |
172 | 456070 | InputStream *ist = ifile->streams[pkt->stream_index]; | |
173 | 456070 | const int64_t start_time = ifile->start_time_effective; | |
174 | int64_t duration; | ||
175 | |||
176 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 456070 times.
|
456070 | if (debug_ts) { |
177 | ✗ | av_log(NULL, AV_LOG_INFO, "demuxer -> ist_index:%d:%d type:%s " | |
178 | "pkt_pts:%s pkt_pts_time:%s pkt_dts:%s pkt_dts_time:%s duration:%s duration_time:%s\n", | ||
179 | ifile->index, pkt->stream_index, | ||
180 | ✗ | av_get_media_type_string(ist->st->codecpar->codec_type), | |
181 | ✗ | av_ts2str(pkt->pts), av_ts2timestr(pkt->pts, &ist->st->time_base), | |
182 | ✗ | av_ts2str(pkt->dts), av_ts2timestr(pkt->dts, &ist->st->time_base), | |
183 | ✗ | av_ts2str(pkt->duration), av_ts2timestr(pkt->duration, &ist->st->time_base)); | |
184 | } | ||
185 | |||
186 |
4/4✓ Branch 0 taken 403370 times.
✓ Branch 1 taken 52700 times.
✓ Branch 2 taken 270516 times.
✓ Branch 3 taken 132854 times.
|
456070 | if (!ist->wrap_correction_done && start_time != AV_NOPTS_VALUE && |
187 |
2/2✓ Branch 0 taken 365 times.
✓ Branch 1 taken 270151 times.
|
270516 | ist->st->pts_wrap_bits < 64) { |
188 | int64_t stime, stime2; | ||
189 | |||
190 | 365 | stime = av_rescale_q(start_time, AV_TIME_BASE_Q, ist->st->time_base); | |
191 | 365 | stime2= stime + (1ULL<<ist->st->pts_wrap_bits); | |
192 | 365 | ist->wrap_correction_done = 1; | |
193 | |||
194 |
5/6✓ Branch 0 taken 333 times.
✓ Branch 1 taken 32 times.
✓ Branch 2 taken 296 times.
✓ Branch 3 taken 37 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 296 times.
|
365 | if(stime2 > stime && pkt->dts != AV_NOPTS_VALUE && pkt->dts > stime + (1LL<<(ist->st->pts_wrap_bits-1))) { |
195 | ✗ | pkt->dts -= 1ULL<<ist->st->pts_wrap_bits; | |
196 | ✗ | ist->wrap_correction_done = 0; | |
197 | } | ||
198 |
5/6✓ Branch 0 taken 333 times.
✓ Branch 1 taken 32 times.
✓ Branch 2 taken 289 times.
✓ Branch 3 taken 44 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 289 times.
|
365 | if(stime2 > stime && pkt->pts != AV_NOPTS_VALUE && pkt->pts > stime + (1LL<<(ist->st->pts_wrap_bits-1))) { |
199 | ✗ | pkt->pts -= 1ULL<<ist->st->pts_wrap_bits; | |
200 | ✗ | ist->wrap_correction_done = 0; | |
201 | } | ||
202 | } | ||
203 | |||
204 |
2/2✓ Branch 0 taken 417591 times.
✓ Branch 1 taken 38479 times.
|
456070 | if (pkt->dts != AV_NOPTS_VALUE) |
205 | 417591 | pkt->dts += av_rescale_q(ifile->ts_offset, AV_TIME_BASE_Q, ist->st->time_base); | |
206 |
2/2✓ Branch 0 taken 415485 times.
✓ Branch 1 taken 40585 times.
|
456070 | if (pkt->pts != AV_NOPTS_VALUE) |
207 | 415485 | pkt->pts += av_rescale_q(ifile->ts_offset, AV_TIME_BASE_Q, ist->st->time_base); | |
208 | |||
209 |
2/2✓ Branch 0 taken 415485 times.
✓ Branch 1 taken 40585 times.
|
456070 | if (pkt->pts != AV_NOPTS_VALUE) |
210 | 415485 | pkt->pts *= ist->ts_scale; | |
211 |
2/2✓ Branch 0 taken 417591 times.
✓ Branch 1 taken 38479 times.
|
456070 | if (pkt->dts != AV_NOPTS_VALUE) |
212 | 417591 | pkt->dts *= ist->ts_scale; | |
213 | |||
214 | 456070 | duration = av_rescale_q(d->duration, d->time_base, ist->st->time_base); | |
215 |
2/2✓ Branch 0 taken 415485 times.
✓ Branch 1 taken 40585 times.
|
456070 | if (pkt->pts != AV_NOPTS_VALUE) { |
216 | 415485 | pkt->pts += duration; | |
217 | 415485 | ist->max_pts = FFMAX(pkt->pts, ist->max_pts); | |
218 | 415485 | ist->min_pts = FFMIN(pkt->pts, ist->min_pts); | |
219 | } | ||
220 | |||
221 |
2/2✓ Branch 0 taken 417591 times.
✓ Branch 1 taken 38479 times.
|
456070 | if (pkt->dts != AV_NOPTS_VALUE) |
222 | 417591 | pkt->dts += duration; | |
223 | |||
224 | 456070 | *repeat_pict = -1; | |
225 |
4/4✓ Branch 0 taken 129282 times.
✓ Branch 1 taken 326788 times.
✓ Branch 2 taken 57389 times.
✓ Branch 3 taken 71893 times.
|
585352 | if (ist->st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO && |
226 | 129282 | av_stream_get_parser(ist->st)) | |
227 | 57389 | *repeat_pict = av_stream_get_parser(ist->st)->repeat_pict; | |
228 | 456070 | } | |
229 | |||
230 | 6481 | static void thread_set_name(InputFile *f) | |
231 | { | ||
232 | char name[16]; | ||
233 | 6481 | snprintf(name, sizeof(name), "dmx%d:%s", f->index, f->ctx->iformat->name); | |
234 | 6481 | ff_thread_setname(name); | |
235 | 6481 | } | |
236 | |||
237 | 6481 | static void *input_thread(void *arg) | |
238 | { | ||
239 | 6481 | Demuxer *d = arg; | |
240 | 6481 | InputFile *f = &d->f; | |
241 | AVPacket *pkt; | ||
242 | 6481 | unsigned flags = d->non_blocking ? AV_THREAD_MESSAGE_NONBLOCK : 0; | |
243 | 6481 | int ret = 0; | |
244 | |||
245 | 6481 | pkt = av_packet_alloc(); | |
246 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6481 times.
|
6481 | if (!pkt) { |
247 | ✗ | ret = AVERROR(ENOMEM); | |
248 | ✗ | goto finish; | |
249 | } | ||
250 | |||
251 | 6481 | thread_set_name(f); | |
252 | |||
253 | 453004 | while (1) { | |
254 | 459485 | DemuxMsg msg = { NULL }; | |
255 | |||
256 | 459485 | ret = av_read_frame(f->ctx, pkt); | |
257 | |||
258 |
2/2✓ Branch 0 taken 1 times.
✓ Branch 1 taken 459484 times.
|
459485 | if (ret == AVERROR(EAGAIN)) { |
259 | 1 | av_usleep(10000); | |
260 | 7 | continue; | |
261 | } | ||
262 |
2/2✓ Branch 0 taken 3414 times.
✓ Branch 1 taken 456070 times.
|
459484 | if (ret < 0) { |
263 |
2/2✓ Branch 0 taken 6 times.
✓ Branch 1 taken 3408 times.
|
3414 | if (d->loop) { |
264 | /* signal looping to the consumer thread */ | ||
265 | 6 | msg.looping = 1; | |
266 | 6 | ret = av_thread_message_queue_send(d->in_thread_queue, &msg, 0); | |
267 |
1/2✓ Branch 0 taken 6 times.
✗ Branch 1 not taken.
|
6 | if (ret >= 0) |
268 | 6 | ret = seek_to_start(d); | |
269 |
1/2✓ Branch 0 taken 6 times.
✗ Branch 1 not taken.
|
6 | if (ret >= 0) |
270 | 6 | continue; | |
271 | |||
272 | /* fallthrough to the error path */ | ||
273 | } | ||
274 | |||
275 |
2/2✓ Branch 0 taken 3338 times.
✓ Branch 1 taken 70 times.
|
3408 | if (ret == AVERROR_EOF) |
276 | 3338 | av_log(NULL, AV_LOG_VERBOSE, "EOF in input file %d\n", f->index); | |
277 | else | ||
278 | 70 | av_log(NULL, AV_LOG_ERROR, "Error demuxing input file %d: %s\n", | |
279 | 70 | f->index, av_err2str(ret)); | |
280 | |||
281 | 6481 | break; | |
282 | } | ||
283 | |||
284 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 456070 times.
|
456070 | if (do_pkt_dump) { |
285 | ✗ | av_pkt_dump_log2(NULL, AV_LOG_INFO, pkt, do_hex_dump, | |
286 | ✗ | f->ctx->streams[pkt->stream_index]); | |
287 | } | ||
288 | |||
289 | /* the following test is needed in case new streams appear | ||
290 | dynamically in stream : we ignore them */ | ||
291 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 456070 times.
|
456070 | if (pkt->stream_index >= f->nb_streams) { |
292 | ✗ | report_new_stream(d, pkt); | |
293 | ✗ | av_packet_unref(pkt); | |
294 | ✗ | continue; | |
295 | } | ||
296 | |||
297 |
2/2✓ Branch 0 taken 108 times.
✓ Branch 1 taken 455962 times.
|
456070 | if (pkt->flags & AV_PKT_FLAG_CORRUPT) { |
298 | 108 | av_log(NULL, exit_on_error ? AV_LOG_FATAL : AV_LOG_WARNING, | |
299 | "%s: corrupt input packet in stream %d\n", | ||
300 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 108 times.
|
108 | f->ctx->url, pkt->stream_index); |
301 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 108 times.
|
108 | if (exit_on_error) { |
302 | ✗ | av_packet_unref(pkt); | |
303 | ✗ | ret = AVERROR_INVALIDDATA; | |
304 | ✗ | break; | |
305 | } | ||
306 | } | ||
307 | |||
308 | 456070 | ts_fixup(d, pkt, &msg.repeat_pict); | |
309 | |||
310 | 456070 | msg.pkt = av_packet_alloc(); | |
311 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 456070 times.
|
456070 | if (!msg.pkt) { |
312 | ✗ | av_packet_unref(pkt); | |
313 | ✗ | ret = AVERROR(ENOMEM); | |
314 | ✗ | break; | |
315 | } | ||
316 | 456070 | av_packet_move_ref(msg.pkt, pkt); | |
317 | 456070 | ret = av_thread_message_queue_send(d->in_thread_queue, &msg, flags); | |
318 |
4/4✓ Branch 0 taken 495 times.
✓ Branch 1 taken 455575 times.
✓ Branch 2 taken 55 times.
✓ Branch 3 taken 440 times.
|
456070 | if (flags && ret == AVERROR(EAGAIN)) { |
319 | 55 | flags = 0; | |
320 | 55 | ret = av_thread_message_queue_send(d->in_thread_queue, &msg, flags); | |
321 | 55 | av_log(f->ctx, AV_LOG_WARNING, | |
322 | "Thread message queue blocking; consider raising the " | ||
323 | "thread_queue_size option (current value: %d)\n", | ||
324 | d->thread_queue_size); | ||
325 | } | ||
326 |
2/2✓ Branch 0 taken 3073 times.
✓ Branch 1 taken 452997 times.
|
456070 | if (ret < 0) { |
327 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 3073 times.
|
3073 | if (ret != AVERROR_EOF) |
328 | ✗ | av_log(f->ctx, AV_LOG_ERROR, | |
329 | "Unable to send packet to main thread: %s\n", | ||
330 | ✗ | av_err2str(ret)); | |
331 | 3073 | av_packet_free(&msg.pkt); | |
332 | 3073 | break; | |
333 | } | ||
334 | } | ||
335 | |||
336 | 6481 | finish: | |
337 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6481 times.
|
6481 | av_assert0(ret < 0); |
338 | 6481 | av_thread_message_queue_set_err_recv(d->in_thread_queue, ret); | |
339 | |||
340 | 6481 | av_packet_free(&pkt); | |
341 | |||
342 | 6481 | av_log(NULL, AV_LOG_VERBOSE, "Terminating demuxer thread %d\n", f->index); | |
343 | |||
344 | 6481 | return NULL; | |
345 | } | ||
346 | |||
347 | 6494 | static void thread_stop(Demuxer *d) | |
348 | { | ||
349 | 6494 | InputFile *f = &d->f; | |
350 | DemuxMsg msg; | ||
351 | |||
352 |
2/2✓ Branch 0 taken 13 times.
✓ Branch 1 taken 6481 times.
|
6494 | if (!d->in_thread_queue) |
353 | 13 | return; | |
354 | 6481 | av_thread_message_queue_set_err_send(d->in_thread_queue, AVERROR_EOF); | |
355 |
2/2✓ Branch 1 taken 3651 times.
✓ Branch 2 taken 6481 times.
|
10132 | while (av_thread_message_queue_recv(d->in_thread_queue, &msg, 0) >= 0) |
356 | 3651 | av_packet_free(&msg.pkt); | |
357 | |||
358 | 6481 | pthread_join(d->thread, NULL); | |
359 | 6481 | av_thread_message_queue_free(&d->in_thread_queue); | |
360 | 6481 | av_thread_message_queue_free(&f->audio_duration_queue); | |
361 | } | ||
362 | |||
363 | 6481 | static int thread_start(Demuxer *d) | |
364 | { | ||
365 | int ret; | ||
366 | 6481 | InputFile *f = &d->f; | |
367 | |||
368 |
1/2✓ Branch 0 taken 6481 times.
✗ Branch 1 not taken.
|
6481 | if (d->thread_queue_size <= 0) |
369 |
2/2✓ Branch 0 taken 146 times.
✓ Branch 1 taken 6335 times.
|
6481 | d->thread_queue_size = (nb_input_files > 1 ? 8 : 1); |
370 | |||
371 |
4/4✓ Branch 0 taken 146 times.
✓ Branch 1 taken 6335 times.
✓ Branch 2 taken 55 times.
✓ Branch 3 taken 91 times.
|
6627 | if (nb_input_files > 1 && |
372 |
2/2✓ Branch 0 taken 84 times.
✓ Branch 1 taken 62 times.
|
146 | (f->ctx->pb ? !f->ctx->pb->seekable : |
373 | 62 | strcmp(f->ctx->iformat->name, "lavfi"))) | |
374 | 55 | d->non_blocking = 1; | |
375 | 6481 | ret = av_thread_message_queue_alloc(&d->in_thread_queue, | |
376 | 6481 | d->thread_queue_size, sizeof(DemuxMsg)); | |
377 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6481 times.
|
6481 | if (ret < 0) |
378 | ✗ | return ret; | |
379 | |||
380 |
2/2✓ Branch 0 taken 2 times.
✓ Branch 1 taken 6479 times.
|
6481 | if (d->loop) { |
381 | 2 | int nb_audio_dec = 0; | |
382 | |||
383 |
2/2✓ Branch 0 taken 2 times.
✓ Branch 1 taken 2 times.
|
4 | for (int i = 0; i < f->nb_streams; i++) { |
384 | 2 | InputStream *ist = f->streams[i]; | |
385 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 2 times.
|
2 | nb_audio_dec += !!(ist->decoding_needed && |
386 | ✗ | ist->st->codecpar->codec_type == AVMEDIA_TYPE_AUDIO); | |
387 | } | ||
388 | |||
389 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 2 times.
|
2 | if (nb_audio_dec) { |
390 | ✗ | ret = av_thread_message_queue_alloc(&f->audio_duration_queue, | |
391 | nb_audio_dec, sizeof(LastFrameDuration)); | ||
392 | ✗ | if (ret < 0) | |
393 | ✗ | goto fail; | |
394 | ✗ | f->audio_duration_queue_size = nb_audio_dec; | |
395 | } | ||
396 | } | ||
397 | |||
398 |
1/2✗ Branch 1 not taken.
✓ Branch 2 taken 6481 times.
|
6481 | if ((ret = pthread_create(&d->thread, NULL, input_thread, d))) { |
399 | ✗ | av_log(NULL, AV_LOG_ERROR, "pthread_create failed: %s. Try to increase `ulimit -v` or decrease `ulimit -s`.\n", strerror(ret)); | |
400 | ✗ | ret = AVERROR(ret); | |
401 | ✗ | goto fail; | |
402 | } | ||
403 | |||
404 | 6481 | return 0; | |
405 | ✗ | fail: | |
406 | ✗ | av_thread_message_queue_free(&d->in_thread_queue); | |
407 | ✗ | return ret; | |
408 | } | ||
409 | |||
410 | 453947 | int ifile_get_packet(InputFile *f, AVPacket **pkt) | |
411 | { | ||
412 | 453947 | Demuxer *d = demuxer_from_ifile(f); | |
413 | InputStream *ist; | ||
414 | DemuxMsg msg; | ||
415 | int ret; | ||
416 | |||
417 |
2/2✓ Branch 0 taken 6481 times.
✓ Branch 1 taken 447466 times.
|
453947 | if (!d->in_thread_queue) { |
418 | 6481 | ret = thread_start(d); | |
419 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6481 times.
|
6481 | if (ret < 0) |
420 | ✗ | return ret; | |
421 | } | ||
422 | |||
423 |
3/4✓ Branch 0 taken 453947 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 704 times.
✓ Branch 3 taken 453243 times.
|
453947 | if (f->readrate || f->rate_emu) { |
424 | int i; | ||
425 | 1408 | int64_t file_start = copy_ts * ( | |
426 |
1/2✓ Branch 0 taken 704 times.
✗ Branch 1 not taken.
|
704 | (f->start_time_effective != AV_NOPTS_VALUE ? f->start_time_effective * !start_at_zero : 0) + |
427 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 704 times.
|
704 | (f->start_time != AV_NOPTS_VALUE ? f->start_time : 0) |
428 | ); | ||
429 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 704 times.
|
704 | float scale = f->rate_emu ? 1.0 : f->readrate; |
430 |
2/2✓ Branch 0 taken 704 times.
✓ Branch 1 taken 217 times.
|
921 | for (i = 0; i < f->nb_streams; i++) { |
431 | 704 | InputStream *ist = f->streams[i]; | |
432 | int64_t stream_ts_offset, pts, now; | ||
433 |
4/6✓ Branch 0 taken 703 times.
✓ Branch 1 taken 1 times.
✓ Branch 2 taken 703 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 703 times.
|
704 | if (!ist->nb_packets || (ist->decoding_needed && !ist->got_output)) continue; |
434 |
1/2✓ Branch 0 taken 703 times.
✗ Branch 1 not taken.
|
703 | stream_ts_offset = FFMAX(ist->first_dts != AV_NOPTS_VALUE ? ist->first_dts : 0, file_start); |
435 | 703 | pts = av_rescale(ist->dts, 1000000, AV_TIME_BASE); | |
436 | 703 | now = (av_gettime_relative() - ist->start) * scale + stream_ts_offset; | |
437 |
2/2✓ Branch 0 taken 487 times.
✓ Branch 1 taken 216 times.
|
703 | if (pts > now) |
438 | 487 | return AVERROR(EAGAIN); | |
439 | } | ||
440 | } | ||
441 | |||
442 | 453460 | ret = av_thread_message_queue_recv(d->in_thread_queue, &msg, | |
443 | 453460 | d->non_blocking ? | |
444 | AV_THREAD_MESSAGE_NONBLOCK : 0); | ||
445 |
2/2✓ Branch 0 taken 4108 times.
✓ Branch 1 taken 449352 times.
|
453460 | if (ret < 0) |
446 | 4108 | return ret; | |
447 |
2/2✓ Branch 0 taken 6 times.
✓ Branch 1 taken 449346 times.
|
449352 | if (msg.looping) |
448 | 6 | return 1; | |
449 | |||
450 | 449346 | ist = f->streams[msg.pkt->stream_index]; | |
451 | 449346 | ist->last_pkt_repeat_pict = msg.repeat_pict; | |
452 | |||
453 | 449346 | *pkt = msg.pkt; | |
454 | 449346 | return 0; | |
455 | } | ||
456 | |||
457 | 6937 | static void ist_free(InputStream **pist) | |
458 | { | ||
459 | 6937 | InputStream *ist = *pist; | |
460 | |||
461 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
|
6937 | if (!ist) |
462 | ✗ | return; | |
463 | |||
464 | 6937 | av_frame_free(&ist->decoded_frame); | |
465 | 6937 | av_packet_free(&ist->pkt); | |
466 | 6937 | av_dict_free(&ist->decoder_opts); | |
467 | 6937 | avsubtitle_free(&ist->prev_sub.subtitle); | |
468 | 6937 | av_frame_free(&ist->sub2video.frame); | |
469 | 6937 | av_freep(&ist->filters); | |
470 | 6937 | av_freep(&ist->hwaccel_device); | |
471 | 6937 | av_freep(&ist->dts_buffer); | |
472 | |||
473 | 6937 | avcodec_free_context(&ist->dec_ctx); | |
474 | 6937 | avcodec_parameters_free(&ist->par); | |
475 | |||
476 | 6937 | av_freep(pist); | |
477 | } | ||
478 | |||
479 | 6494 | void ifile_close(InputFile **pf) | |
480 | { | ||
481 | 6494 | InputFile *f = *pf; | |
482 | 6494 | Demuxer *d = demuxer_from_ifile(f); | |
483 | |||
484 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | if (!f) |
485 | ✗ | return; | |
486 | |||
487 | 6494 | thread_stop(d); | |
488 | |||
489 |
2/2✓ Branch 0 taken 6937 times.
✓ Branch 1 taken 6494 times.
|
13431 | for (int i = 0; i < f->nb_streams; i++) |
490 | 6937 | ist_free(&f->streams[i]); | |
491 | 6494 | av_freep(&f->streams); | |
492 | |||
493 | 6494 | avformat_close_input(&f->ctx); | |
494 | |||
495 | 6494 | av_freep(pf); | |
496 | } | ||
497 | |||
498 | 13754 | static const AVCodec *choose_decoder(const OptionsContext *o, AVFormatContext *s, AVStream *st, | |
499 | enum HWAccelID hwaccel_id, enum AVHWDeviceType hwaccel_device_type) | ||
500 | |||
501 | { | ||
502 | 13754 | char *codec_name = NULL; | |
503 | |||
504 |
6/20✓ Branch 1 taken 5302 times.
✓ Branch 2 taken 8 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 8 times.
✓ Branch 6 taken 5310 times.
✓ Branch 7 taken 13754 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 13754 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
19064 | MATCH_PER_STREAM_OPT(codec_names, str, codec_name, s, st); |
505 |
2/2✓ Branch 0 taken 5302 times.
✓ Branch 1 taken 8452 times.
|
13754 | if (codec_name) { |
506 | 5302 | const AVCodec *codec = find_codec_or_die(codec_name, st->codecpar->codec_type, 0); | |
507 | 5302 | st->codecpar->codec_id = codec->id; | |
508 |
1/4✗ Branch 0 not taken.
✓ Branch 1 taken 5302 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
5302 | if (recast_media && st->codecpar->codec_type != codec->type) |
509 | ✗ | st->codecpar->codec_type = codec->type; | |
510 | 5302 | return codec; | |
511 | } else { | ||
512 |
3/4✓ Branch 0 taken 5230 times.
✓ Branch 1 taken 3222 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 5230 times.
|
8452 | if (st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO && |
513 | ✗ | hwaccel_id == HWACCEL_GENERIC && | |
514 | hwaccel_device_type != AV_HWDEVICE_TYPE_NONE) { | ||
515 | const AVCodec *c; | ||
516 | ✗ | void *i = NULL; | |
517 | |||
518 | ✗ | while ((c = av_codec_iterate(&i))) { | |
519 | const AVCodecHWConfig *config; | ||
520 | |||
521 | ✗ | if (c->id != st->codecpar->codec_id || | |
522 | ✗ | !av_codec_is_decoder(c)) | |
523 | ✗ | continue; | |
524 | |||
525 | ✗ | for (int j = 0; config = avcodec_get_hw_config(c, j); j++) { | |
526 | ✗ | if (config->device_type == hwaccel_device_type) { | |
527 | ✗ | av_log(NULL, AV_LOG_VERBOSE, "Selecting decoder '%s' because of requested hwaccel method %s\n", | |
528 | ✗ | c->name, av_hwdevice_get_type_name(hwaccel_device_type)); | |
529 | ✗ | return c; | |
530 | } | ||
531 | } | ||
532 | } | ||
533 | } | ||
534 | |||
535 | 8452 | return avcodec_find_decoder(st->codecpar->codec_id); | |
536 | } | ||
537 | } | ||
538 | |||
539 | 1549 | static int guess_input_channel_layout(InputStream *ist) | |
540 | { | ||
541 | 1549 | AVCodecContext *dec = ist->dec_ctx; | |
542 | |||
543 |
2/2✓ Branch 0 taken 800 times.
✓ Branch 1 taken 749 times.
|
1549 | if (dec->ch_layout.order == AV_CHANNEL_ORDER_UNSPEC) { |
544 | char layout_name[256]; | ||
545 | |||
546 |
2/2✓ Branch 0 taken 4 times.
✓ Branch 1 taken 796 times.
|
800 | if (dec->ch_layout.nb_channels > ist->guess_layout_max) |
547 | 12 | return 0; | |
548 | 796 | av_channel_layout_default(&dec->ch_layout, dec->ch_layout.nb_channels); | |
549 |
2/2✓ Branch 0 taken 8 times.
✓ Branch 1 taken 788 times.
|
796 | if (dec->ch_layout.order == AV_CHANNEL_ORDER_UNSPEC) |
550 | 8 | return 0; | |
551 | 788 | av_channel_layout_describe(&dec->ch_layout, layout_name, sizeof(layout_name)); | |
552 | 788 | av_log(NULL, AV_LOG_WARNING, "Guessed Channel Layout for Input Stream " | |
553 | 788 | "#%d.%d : %s\n", ist->file_index, ist->st->index, layout_name); | |
554 | } | ||
555 | 1537 | return 1; | |
556 | } | ||
557 | |||
558 | 5256 | static void add_display_matrix_to_stream(const OptionsContext *o, | |
559 | AVFormatContext *ctx, AVStream *st) | ||
560 | { | ||
561 | 5256 | double rotation = DBL_MAX; | |
562 | 5256 | int hflip = -1, vflip = -1; | |
563 | 5256 | int hflip_set = 0, vflip_set = 0, rotation_set = 0; | |
564 | int32_t *buf; | ||
565 | |||
566 |
4/20✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 6 taken 1 times.
✓ Branch 7 taken 5256 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 5256 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
5257 | MATCH_PER_STREAM_OPT(display_rotations, dbl, rotation, ctx, st); |
567 |
2/20✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 5256 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 5256 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
5256 | MATCH_PER_STREAM_OPT(display_hflips, i, hflip, ctx, st); |
568 |
2/20✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 5256 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 5256 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
5256 | MATCH_PER_STREAM_OPT(display_vflips, i, vflip, ctx, st); |
569 | |||
570 | 5256 | rotation_set = rotation != DBL_MAX; | |
571 | 5256 | hflip_set = hflip != -1; | |
572 | 5256 | vflip_set = vflip != -1; | |
573 | |||
574 |
4/6✓ Branch 0 taken 5255 times.
✓ Branch 1 taken 1 times.
✓ Branch 2 taken 5255 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 5255 times.
✗ Branch 5 not taken.
|
5256 | if (!rotation_set && !hflip_set && !vflip_set) |
575 | 5255 | return; | |
576 | |||
577 | 1 | buf = (int32_t *)av_stream_new_side_data(st, AV_PKT_DATA_DISPLAYMATRIX, sizeof(int32_t) * 9); | |
578 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 1 times.
|
1 | if (!buf) { |
579 | ✗ | av_log(NULL, AV_LOG_FATAL, "Failed to generate a display matrix!\n"); | |
580 | ✗ | exit_program(1); | |
581 | } | ||
582 | |||
583 |
1/2✓ Branch 0 taken 1 times.
✗ Branch 1 not taken.
|
1 | av_display_rotation_set(buf, |
584 | rotation_set ? -(rotation) : -0.0f); | ||
585 | |||
586 |
2/4✗ Branch 0 not taken.
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 1 times.
|
1 | av_display_matrix_flip(buf, |
587 | hflip_set ? hflip : 0, | ||
588 | vflip_set ? vflip : 0); | ||
589 | } | ||
590 | |||
591 | /* Add all the streams from the given input file to the demuxer */ | ||
592 | 6494 | static void add_input_streams(const OptionsContext *o, Demuxer *d) | |
593 | { | ||
594 | 6494 | InputFile *f = &d->f; | |
595 | 6494 | AVFormatContext *ic = f->ctx; | |
596 | int i, ret; | ||
597 | |||
598 |
2/2✓ Branch 0 taken 6937 times.
✓ Branch 1 taken 6494 times.
|
13431 | for (i = 0; i < ic->nb_streams; i++) { |
599 | 6937 | AVStream *st = ic->streams[i]; | |
600 | 6937 | AVCodecParameters *par = st->codecpar; | |
601 | InputStream *ist; | ||
602 | 6937 | char *framerate = NULL, *hwaccel_device = NULL; | |
603 | 6937 | const char *hwaccel = NULL; | |
604 | 6937 | char *hwaccel_output_format = NULL; | |
605 | 6937 | char *codec_tag = NULL; | |
606 | char *next; | ||
607 | 6937 | char *discard_str = NULL; | |
608 | 6937 | const AVClass *cc = avcodec_get_class(); | |
609 | 6937 | const AVOption *discard_opt = av_opt_find(&cc, "skip_frame", NULL, | |
610 | 0, AV_OPT_SEARCH_FAKE_OBJ); | ||
611 | |||
612 | 6937 | ist = ALLOC_ARRAY_ELEM(f->streams, f->nb_streams); | |
613 | 6937 | ist->st = st; | |
614 | 6937 | ist->file_index = f->index; | |
615 | 6937 | ist->discard = 1; | |
616 | 6937 | st->discard = AVDISCARD_ALL; | |
617 | 6937 | ist->nb_samples = 0; | |
618 | 6937 | ist->first_dts = AV_NOPTS_VALUE; | |
619 | 6937 | ist->min_pts = INT64_MAX; | |
620 | 6937 | ist->max_pts = INT64_MIN; | |
621 | |||
622 | 6937 | ist->ts_scale = 1.0; | |
623 |
2/20✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 6937 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 6937 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
6937 | MATCH_PER_STREAM_OPT(ts_scale, dbl, ist->ts_scale, ic, st); |
624 | |||
625 | 6937 | ist->autorotate = 1; | |
626 |
2/20✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 6937 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 6937 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
6937 | MATCH_PER_STREAM_OPT(autorotate, i, ist->autorotate, ic, st); |
627 | |||
628 |
4/20✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 6 taken 2 times.
✓ Branch 7 taken 6937 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 6937 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
6939 | MATCH_PER_STREAM_OPT(codec_tags, str, codec_tag, ic, st); |
629 |
2/2✓ Branch 0 taken 2 times.
✓ Branch 1 taken 6935 times.
|
6937 | if (codec_tag) { |
630 | 2 | uint32_t tag = strtol(codec_tag, &next, 0); | |
631 |
1/2✓ Branch 0 taken 2 times.
✗ Branch 1 not taken.
|
2 | if (*next) |
632 | 2 | tag = AV_RL32(codec_tag); | |
633 | 2 | st->codecpar->codec_tag = tag; | |
634 | } | ||
635 | |||
636 |
2/2✓ Branch 0 taken 5256 times.
✓ Branch 1 taken 1681 times.
|
6937 | if (st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) { |
637 | 5256 | add_display_matrix_to_stream(o, ic, st); | |
638 | |||
639 |
4/20✓ Branch 1 taken 4976 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 6 taken 4976 times.
✓ Branch 7 taken 5256 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 5256 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
10232 | MATCH_PER_STREAM_OPT(hwaccels, str, hwaccel, ic, st); |
640 |
2/20✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 5256 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 5256 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
5256 | MATCH_PER_STREAM_OPT(hwaccel_output_formats, str, |
641 | hwaccel_output_format, ic, st); | ||
642 | |||
643 |
4/6✓ Branch 0 taken 5256 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 4976 times.
✓ Branch 3 taken 280 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 4976 times.
|
5256 | if (!hwaccel_output_format && hwaccel && !strcmp(hwaccel, "cuvid")) { |
644 | ✗ | av_log(NULL, AV_LOG_WARNING, | |
645 | "WARNING: defaulting hwaccel_output_format to cuda for compatibility " | ||
646 | "with old commandlines. This behaviour is DEPRECATED and will be removed " | ||
647 | "in the future. Please explicitly set \"-hwaccel_output_format cuda\".\n"); | ||
648 | ✗ | ist->hwaccel_output_format = AV_PIX_FMT_CUDA; | |
649 |
4/6✓ Branch 0 taken 5256 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 4976 times.
✓ Branch 3 taken 280 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 4976 times.
|
5256 | } else if (!hwaccel_output_format && hwaccel && !strcmp(hwaccel, "qsv")) { |
650 | ✗ | av_log(NULL, AV_LOG_WARNING, | |
651 | "WARNING: defaulting hwaccel_output_format to qsv for compatibility " | ||
652 | "with old commandlines. This behaviour is DEPRECATED and will be removed " | ||
653 | "in the future. Please explicitly set \"-hwaccel_output_format qsv\".\n"); | ||
654 | ✗ | ist->hwaccel_output_format = AV_PIX_FMT_QSV; | |
655 |
4/6✓ Branch 0 taken 5256 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 4976 times.
✓ Branch 3 taken 280 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 4976 times.
|
5256 | } else if (!hwaccel_output_format && hwaccel && !strcmp(hwaccel, "mediacodec")) { |
656 | // There is no real AVHWFrameContext implementation. Set | ||
657 | // hwaccel_output_format to avoid av_hwframe_transfer_data error. | ||
658 | ✗ | ist->hwaccel_output_format = AV_PIX_FMT_MEDIACODEC; | |
659 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 5256 times.
|
5256 | } else if (hwaccel_output_format) { |
660 | ✗ | ist->hwaccel_output_format = av_get_pix_fmt(hwaccel_output_format); | |
661 | ✗ | if (ist->hwaccel_output_format == AV_PIX_FMT_NONE) { | |
662 | ✗ | av_log(NULL, AV_LOG_FATAL, "Unrecognised hwaccel output " | |
663 | "format: %s", hwaccel_output_format); | ||
664 | } | ||
665 | } else { | ||
666 | 5256 | ist->hwaccel_output_format = AV_PIX_FMT_NONE; | |
667 | } | ||
668 | |||
669 |
2/2✓ Branch 0 taken 4976 times.
✓ Branch 1 taken 280 times.
|
5256 | if (hwaccel) { |
670 | // The NVDEC hwaccels use a CUDA device, so remap the name here. | ||
671 |
2/4✓ Branch 0 taken 4976 times.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✓ Branch 3 taken 4976 times.
|
4976 | if (!strcmp(hwaccel, "nvdec") || !strcmp(hwaccel, "cuvid")) |
672 | ✗ | hwaccel = "cuda"; | |
673 | |||
674 |
1/2✓ Branch 0 taken 4976 times.
✗ Branch 1 not taken.
|
4976 | if (!strcmp(hwaccel, "none")) |
675 | 4976 | ist->hwaccel_id = HWACCEL_NONE; | |
676 | ✗ | else if (!strcmp(hwaccel, "auto")) | |
677 | ✗ | ist->hwaccel_id = HWACCEL_AUTO; | |
678 | else { | ||
679 | ✗ | enum AVHWDeviceType type = av_hwdevice_find_type_by_name(hwaccel); | |
680 | ✗ | if (type != AV_HWDEVICE_TYPE_NONE) { | |
681 | ✗ | ist->hwaccel_id = HWACCEL_GENERIC; | |
682 | ✗ | ist->hwaccel_device_type = type; | |
683 | } | ||
684 | |||
685 | ✗ | if (!ist->hwaccel_id) { | |
686 | ✗ | av_log(NULL, AV_LOG_FATAL, "Unrecognized hwaccel: %s.\n", | |
687 | hwaccel); | ||
688 | ✗ | av_log(NULL, AV_LOG_FATAL, "Supported hwaccels: "); | |
689 | ✗ | type = AV_HWDEVICE_TYPE_NONE; | |
690 | ✗ | while ((type = av_hwdevice_iterate_types(type)) != | |
691 | AV_HWDEVICE_TYPE_NONE) | ||
692 | ✗ | av_log(NULL, AV_LOG_FATAL, "%s ", | |
693 | av_hwdevice_get_type_name(type)); | ||
694 | ✗ | av_log(NULL, AV_LOG_FATAL, "\n"); | |
695 | ✗ | exit_program(1); | |
696 | } | ||
697 | } | ||
698 | } | ||
699 | |||
700 |
2/20✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 5256 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 5256 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
5256 | MATCH_PER_STREAM_OPT(hwaccel_devices, str, hwaccel_device, ic, st); |
701 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 5256 times.
|
5256 | if (hwaccel_device) { |
702 | ✗ | ist->hwaccel_device = av_strdup(hwaccel_device); | |
703 | ✗ | if (!ist->hwaccel_device) | |
704 | ✗ | report_and_exit(AVERROR(ENOMEM)); | |
705 | } | ||
706 | |||
707 | 5256 | ist->hwaccel_pix_fmt = AV_PIX_FMT_NONE; | |
708 | } | ||
709 | |||
710 | 6937 | ist->dec = choose_decoder(o, ic, st, ist->hwaccel_id, ist->hwaccel_device_type); | |
711 | 6937 | ist->decoder_opts = filter_codec_opts(o->g->codec_opts, ist->st->codecpar->codec_id, ic, st, ist->dec); | |
712 | |||
713 | 6937 | ist->reinit_filters = -1; | |
714 |
2/20✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 6937 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 6937 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
6937 | MATCH_PER_STREAM_OPT(reinit_filters, i, ist->reinit_filters, ic, st); |
715 | |||
716 |
2/20✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 6937 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 6937 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
6937 | MATCH_PER_STREAM_OPT(discard, str, discard_str, ic, st); |
717 | 6937 | ist->user_set_discard = AVDISCARD_NONE; | |
718 | |||
719 |
1/4✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
6937 | if ((o->video_disable && ist->st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) || |
720 |
1/4✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
6937 | (o->audio_disable && ist->st->codecpar->codec_type == AVMEDIA_TYPE_AUDIO) || |
721 |
1/4✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
6937 | (o->subtitle_disable && ist->st->codecpar->codec_type == AVMEDIA_TYPE_SUBTITLE) || |
722 |
1/4✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
6937 | (o->data_disable && ist->st->codecpar->codec_type == AVMEDIA_TYPE_DATA)) |
723 | ✗ | ist->user_set_discard = AVDISCARD_ALL; | |
724 | |||
725 |
1/4✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
|
6937 | if (discard_str && av_opt_eval_int(&cc, discard_opt, discard_str, &ist->user_set_discard) < 0) { |
726 | ✗ | av_log(NULL, AV_LOG_ERROR, "Error parsing discard %s.\n", | |
727 | discard_str); | ||
728 | ✗ | exit_program(1); | |
729 | } | ||
730 | |||
731 | 6937 | ist->filter_in_rescale_delta_last = AV_NOPTS_VALUE; | |
732 | 6937 | ist->prev_pkt_pts = AV_NOPTS_VALUE; | |
733 | |||
734 | 6937 | ist->dec_ctx = avcodec_alloc_context3(ist->dec); | |
735 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
|
6937 | if (!ist->dec_ctx) |
736 | ✗ | report_and_exit(AVERROR(ENOMEM)); | |
737 | |||
738 | 6937 | ret = avcodec_parameters_to_context(ist->dec_ctx, par); | |
739 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
|
6937 | if (ret < 0) { |
740 | ✗ | av_log(NULL, AV_LOG_ERROR, "Error initializing the decoder context.\n"); | |
741 | ✗ | exit_program(1); | |
742 | } | ||
743 | |||
744 | 6937 | ist->decoded_frame = av_frame_alloc(); | |
745 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
|
6937 | if (!ist->decoded_frame) |
746 | ✗ | report_and_exit(AVERROR(ENOMEM)); | |
747 | |||
748 | 6937 | ist->pkt = av_packet_alloc(); | |
749 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
|
6937 | if (!ist->pkt) |
750 | ✗ | report_and_exit(AVERROR(ENOMEM)); | |
751 | |||
752 |
2/2✓ Branch 0 taken 91 times.
✓ Branch 1 taken 6846 times.
|
6937 | if (o->bitexact) |
753 | 91 | ist->dec_ctx->flags |= AV_CODEC_FLAG_BITEXACT; | |
754 | |||
755 |
4/5✓ Branch 0 taken 5256 times.
✓ Branch 1 taken 1549 times.
✓ Branch 2 taken 131 times.
✓ Branch 3 taken 1 times.
✗ Branch 4 not taken.
|
6937 | switch (par->codec_type) { |
756 | 5256 | case AVMEDIA_TYPE_VIDEO: | |
757 | // avformat_find_stream_info() doesn't set this for us anymore. | ||
758 | 5256 | ist->dec_ctx->framerate = st->avg_frame_rate; | |
759 | |||
760 |
4/20✓ Branch 1 taken 25 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 6 taken 25 times.
✓ Branch 7 taken 5256 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 5256 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
5281 | MATCH_PER_STREAM_OPT(frame_rates, str, framerate, ic, st); |
761 |
3/4✓ Branch 0 taken 25 times.
✓ Branch 1 taken 5231 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 25 times.
|
5256 | if (framerate && av_parse_video_rate(&ist->framerate, |
762 | framerate) < 0) { | ||
763 | ✗ | av_log(NULL, AV_LOG_ERROR, "Error parsing framerate %s.\n", | |
764 | framerate); | ||
765 | ✗ | exit_program(1); | |
766 | } | ||
767 | |||
768 | 5256 | ist->top_field_first = -1; | |
769 |
2/20✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 5256 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 5256 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
5256 | MATCH_PER_STREAM_OPT(top_field_first, i, ist->top_field_first, ic, st); |
770 | |||
771 | 5256 | ist->framerate_guessed = av_guess_frame_rate(ic, st, NULL); | |
772 | |||
773 | 5256 | break; | |
774 | 1549 | case AVMEDIA_TYPE_AUDIO: | |
775 | 1549 | ist->guess_layout_max = INT_MAX; | |
776 |
4/20✓ Branch 1 taken 4 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 6 taken 4 times.
✓ Branch 7 taken 1549 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 1549 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
1553 | MATCH_PER_STREAM_OPT(guess_layout_max, i, ist->guess_layout_max, ic, st); |
777 | 1549 | guess_input_channel_layout(ist); | |
778 | 1549 | break; | |
779 | 131 | case AVMEDIA_TYPE_DATA: | |
780 | case AVMEDIA_TYPE_SUBTITLE: { | ||
781 | 131 | char *canvas_size = NULL; | |
782 |
4/20✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 6 taken 1 times.
✓ Branch 7 taken 131 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 131 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
132 | MATCH_PER_STREAM_OPT(fix_sub_duration, i, ist->fix_sub_duration, ic, st); |
783 |
2/20✗ Branch 1 not taken.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 131 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 131 times.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 17 not taken.
✗ Branch 19 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
✗ Branch 22 not taken.
|
131 | MATCH_PER_STREAM_OPT(canvas_sizes, str, canvas_size, ic, st); |
784 |
1/4✗ Branch 0 not taken.
✓ Branch 1 taken 131 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
131 | if (canvas_size && |
785 | ✗ | av_parse_video_size(&ist->dec_ctx->width, &ist->dec_ctx->height, canvas_size) < 0) { | |
786 | ✗ | av_log(NULL, AV_LOG_FATAL, "Invalid canvas size: %s.\n", canvas_size); | |
787 | ✗ | exit_program(1); | |
788 | } | ||
789 | 131 | break; | |
790 | } | ||
791 | 1 | case AVMEDIA_TYPE_ATTACHMENT: | |
792 | case AVMEDIA_TYPE_UNKNOWN: | ||
793 | 1 | break; | |
794 | ✗ | default: | |
795 | ✗ | abort(); | |
796 | } | ||
797 | |||
798 | 6937 | ist->par = avcodec_parameters_alloc(); | |
799 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
|
6937 | if (!ist->par) |
800 | ✗ | report_and_exit(AVERROR(ENOMEM)); | |
801 | |||
802 | 6937 | ret = avcodec_parameters_from_context(ist->par, ist->dec_ctx); | |
803 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6937 times.
|
6937 | if (ret < 0) { |
804 | ✗ | av_log(NULL, AV_LOG_ERROR, "Error initializing the decoder context.\n"); | |
805 | ✗ | exit_program(1); | |
806 | } | ||
807 | } | ||
808 | 6494 | } | |
809 | |||
810 | ✗ | static void dump_attachment(AVStream *st, const char *filename) | |
811 | { | ||
812 | int ret; | ||
813 | ✗ | AVIOContext *out = NULL; | |
814 | const AVDictionaryEntry *e; | ||
815 | |||
816 | ✗ | if (!st->codecpar->extradata_size) { | |
817 | ✗ | av_log(NULL, AV_LOG_WARNING, "No extradata to dump in stream #%d:%d.\n", | |
818 | nb_input_files - 1, st->index); | ||
819 | ✗ | return; | |
820 | } | ||
821 | ✗ | if (!*filename && (e = av_dict_get(st->metadata, "filename", NULL, 0))) | |
822 | ✗ | filename = e->value; | |
823 | ✗ | if (!*filename) { | |
824 | ✗ | av_log(NULL, AV_LOG_FATAL, "No filename specified and no 'filename' tag" | |
825 | "in stream #%d:%d.\n", nb_input_files - 1, st->index); | ||
826 | ✗ | exit_program(1); | |
827 | } | ||
828 | |||
829 | ✗ | assert_file_overwrite(filename); | |
830 | |||
831 | ✗ | if ((ret = avio_open2(&out, filename, AVIO_FLAG_WRITE, &int_cb, NULL)) < 0) { | |
832 | ✗ | av_log(NULL, AV_LOG_FATAL, "Could not open file %s for writing.\n", | |
833 | filename); | ||
834 | ✗ | exit_program(1); | |
835 | } | ||
836 | |||
837 | ✗ | avio_write(out, st->codecpar->extradata, st->codecpar->extradata_size); | |
838 | ✗ | avio_flush(out); | |
839 | ✗ | avio_close(out); | |
840 | } | ||
841 | |||
842 | 6494 | int ifile_open(const OptionsContext *o, const char *filename) | |
843 | { | ||
844 | Demuxer *d; | ||
845 | InputFile *f; | ||
846 | AVFormatContext *ic; | ||
847 | 6494 | const AVInputFormat *file_iformat = NULL; | |
848 | int err, i, ret; | ||
849 | int64_t timestamp; | ||
850 | 6494 | AVDictionary *unused_opts = NULL; | |
851 | 6494 | const AVDictionaryEntry *e = NULL; | |
852 | 6494 | char * video_codec_name = NULL; | |
853 | 6494 | char * audio_codec_name = NULL; | |
854 | 6494 | char *subtitle_codec_name = NULL; | |
855 | 6494 | char * data_codec_name = NULL; | |
856 | 6494 | int scan_all_pmts_set = 0; | |
857 | |||
858 | 6494 | int64_t start_time = o->start_time; | |
859 | 6494 | int64_t start_time_eof = o->start_time_eof; | |
860 | 6494 | int64_t stop_time = o->stop_time; | |
861 | 6494 | int64_t recording_time = o->recording_time; | |
862 | |||
863 |
1/4✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
6494 | if (stop_time != INT64_MAX && recording_time != INT64_MAX) { |
864 | ✗ | stop_time = INT64_MAX; | |
865 | ✗ | av_log(NULL, AV_LOG_WARNING, "-t and -to cannot be used together; using -t.\n"); | |
866 | } | ||
867 | |||
868 |
1/4✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
6494 | if (stop_time != INT64_MAX && recording_time == INT64_MAX) { |
869 | ✗ | int64_t start = start_time == AV_NOPTS_VALUE ? 0 : start_time; | |
870 | ✗ | if (stop_time <= start) { | |
871 | ✗ | av_log(NULL, AV_LOG_ERROR, "-to value smaller than -ss; aborting.\n"); | |
872 | ✗ | exit_program(1); | |
873 | } else { | ||
874 | ✗ | recording_time = stop_time - start; | |
875 | } | ||
876 | } | ||
877 | |||
878 |
2/2✓ Branch 0 taken 3216 times.
✓ Branch 1 taken 3278 times.
|
6494 | if (o->format) { |
879 |
1/2✗ Branch 1 not taken.
✓ Branch 2 taken 3216 times.
|
3216 | if (!(file_iformat = av_find_input_format(o->format))) { |
880 | ✗ | av_log(NULL, AV_LOG_FATAL, "Unknown input format: '%s'\n", o->format); | |
881 | ✗ | exit_program(1); | |
882 | } | ||
883 | } | ||
884 | |||
885 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | if (!strcmp(filename, "-")) |
886 | ✗ | filename = "fd:"; | |
887 | |||
888 | 19482 | stdin_interaction &= strncmp(filename, "pipe:", 5) && | |
889 |
2/4✓ Branch 0 taken 6494 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 6494 times.
✗ Branch 3 not taken.
|
12988 | strcmp(filename, "fd:") && |
890 |
1/2✓ Branch 0 taken 6494 times.
✗ Branch 1 not taken.
|
6494 | strcmp(filename, "/dev/stdin"); |
891 | |||
892 | /* get default parameters from command line */ | ||
893 | 6494 | ic = avformat_alloc_context(); | |
894 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | if (!ic) |
895 | ✗ | report_and_exit(AVERROR(ENOMEM)); | |
896 |
2/2✓ Branch 0 taken 64 times.
✓ Branch 1 taken 6430 times.
|
6494 | if (o->nb_audio_sample_rate) { |
897 | 64 | av_dict_set_int(&o->g->format_opts, "sample_rate", o->audio_sample_rate[o->nb_audio_sample_rate - 1].u.i, 0); | |
898 | } | ||
899 |
2/2✓ Branch 0 taken 8 times.
✓ Branch 1 taken 6486 times.
|
6494 | if (o->nb_audio_channels) { |
900 | const AVClass *priv_class; | ||
901 |
3/6✓ Branch 0 taken 8 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 8 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 8 times.
✗ Branch 5 not taken.
|
16 | if (file_iformat && (priv_class = file_iformat->priv_class) && |
902 | 8 | av_opt_find(&priv_class, "ch_layout", NULL, 0, | |
903 | AV_OPT_SEARCH_FAKE_OBJ)) { | ||
904 | char buf[32]; | ||
905 | 8 | snprintf(buf, sizeof(buf), "%dC", o->audio_channels[o->nb_audio_channels - 1].u.i); | |
906 | 8 | av_dict_set(&o->g->format_opts, "ch_layout", buf, 0); | |
907 | } | ||
908 | } | ||
909 |
2/2✓ Branch 0 taken 1 times.
✓ Branch 1 taken 6493 times.
|
6494 | if (o->nb_audio_ch_layouts) { |
910 | const AVClass *priv_class; | ||
911 |
3/6✓ Branch 0 taken 1 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 1 times.
✗ Branch 5 not taken.
|
2 | if (file_iformat && (priv_class = file_iformat->priv_class) && |
912 | 1 | av_opt_find(&priv_class, "ch_layout", NULL, 0, | |
913 | AV_OPT_SEARCH_FAKE_OBJ)) { | ||
914 | 1 | av_dict_set(&o->g->format_opts, "ch_layout", o->audio_ch_layouts[o->nb_audio_ch_layouts - 1].u.str, 0); | |
915 | } | ||
916 | } | ||
917 |
2/2✓ Branch 0 taken 25 times.
✓ Branch 1 taken 6469 times.
|
6494 | if (o->nb_frame_rates) { |
918 | const AVClass *priv_class; | ||
919 | /* set the format-level framerate option; | ||
920 | * this is important for video grabbers, e.g. x11 */ | ||
921 |
3/6✓ Branch 0 taken 25 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 25 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 25 times.
✗ Branch 5 not taken.
|
50 | if (file_iformat && (priv_class = file_iformat->priv_class) && |
922 | 25 | av_opt_find(&priv_class, "framerate", NULL, 0, | |
923 | AV_OPT_SEARCH_FAKE_OBJ)) { | ||
924 | 25 | av_dict_set(&o->g->format_opts, "framerate", | |
925 | 25 | o->frame_rates[o->nb_frame_rates - 1].u.str, 0); | |
926 | } | ||
927 | } | ||
928 |
2/2✓ Branch 0 taken 514 times.
✓ Branch 1 taken 5980 times.
|
6494 | if (o->nb_frame_sizes) { |
929 | 514 | av_dict_set(&o->g->format_opts, "video_size", o->frame_sizes[o->nb_frame_sizes - 1].u.str, 0); | |
930 | } | ||
931 |
2/2✓ Branch 0 taken 523 times.
✓ Branch 1 taken 5971 times.
|
6494 | if (o->nb_frame_pix_fmts) |
932 | 523 | av_dict_set(&o->g->format_opts, "pixel_format", o->frame_pix_fmts[o->nb_frame_pix_fmts - 1].u.str, 0); | |
933 | |||
934 |
4/4✓ Branch 0 taken 2617 times.
✓ Branch 1 taken 34 times.
✓ Branch 2 taken 2651 times.
✓ Branch 3 taken 6494 times.
|
9145 | MATCH_PER_TYPE_OPT(codec_names, str, video_codec_name, ic, "v"); |
935 |
4/4✓ Branch 0 taken 17 times.
✓ Branch 1 taken 2634 times.
✓ Branch 2 taken 2651 times.
✓ Branch 3 taken 6494 times.
|
9145 | MATCH_PER_TYPE_OPT(codec_names, str, audio_codec_name, ic, "a"); |
936 |
3/4✗ Branch 0 not taken.
✓ Branch 1 taken 2651 times.
✓ Branch 2 taken 2651 times.
✓ Branch 3 taken 6494 times.
|
9145 | MATCH_PER_TYPE_OPT(codec_names, str, subtitle_codec_name, ic, "s"); |
937 |
3/4✗ Branch 0 not taken.
✓ Branch 1 taken 2651 times.
✓ Branch 2 taken 2651 times.
✓ Branch 3 taken 6494 times.
|
9145 | MATCH_PER_TYPE_OPT(codec_names, str, data_codec_name, ic, "d"); |
938 | |||
939 |
2/2✓ Branch 0 taken 2617 times.
✓ Branch 1 taken 3877 times.
|
6494 | if (video_codec_name) |
940 | 2617 | ic->video_codec = find_codec_or_die(video_codec_name , AVMEDIA_TYPE_VIDEO , 0); | |
941 |
2/2✓ Branch 0 taken 17 times.
✓ Branch 1 taken 6477 times.
|
6494 | if (audio_codec_name) |
942 | 17 | ic->audio_codec = find_codec_or_die(audio_codec_name , AVMEDIA_TYPE_AUDIO , 0); | |
943 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | if (subtitle_codec_name) |
944 | ✗ | ic->subtitle_codec = find_codec_or_die(subtitle_codec_name, AVMEDIA_TYPE_SUBTITLE, 0); | |
945 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | if (data_codec_name) |
946 | ✗ | ic->data_codec = find_codec_or_die(data_codec_name , AVMEDIA_TYPE_DATA , 0); | |
947 | |||
948 |
2/2✓ Branch 0 taken 2617 times.
✓ Branch 1 taken 3877 times.
|
6494 | ic->video_codec_id = video_codec_name ? ic->video_codec->id : AV_CODEC_ID_NONE; |
949 |
2/2✓ Branch 0 taken 17 times.
✓ Branch 1 taken 6477 times.
|
6494 | ic->audio_codec_id = audio_codec_name ? ic->audio_codec->id : AV_CODEC_ID_NONE; |
950 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | ic->subtitle_codec_id = subtitle_codec_name ? ic->subtitle_codec->id : AV_CODEC_ID_NONE; |
951 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | ic->data_codec_id = data_codec_name ? ic->data_codec->id : AV_CODEC_ID_NONE; |
952 | |||
953 | 6494 | ic->flags |= AVFMT_FLAG_NONBLOCK; | |
954 |
2/2✓ Branch 0 taken 81 times.
✓ Branch 1 taken 6413 times.
|
6494 | if (o->bitexact) |
955 | 81 | ic->flags |= AVFMT_FLAG_BITEXACT; | |
956 | 6494 | ic->interrupt_callback = int_cb; | |
957 | |||
958 |
1/2✓ Branch 1 taken 6494 times.
✗ Branch 2 not taken.
|
6494 | if (!av_dict_get(o->g->format_opts, "scan_all_pmts", NULL, AV_DICT_MATCH_CASE)) { |
959 | 6494 | av_dict_set(&o->g->format_opts, "scan_all_pmts", "1", AV_DICT_DONT_OVERWRITE); | |
960 | 6494 | scan_all_pmts_set = 1; | |
961 | } | ||
962 | /* open the input file with generic avformat function */ | ||
963 | 6494 | err = avformat_open_input(&ic, filename, file_iformat, &o->g->format_opts); | |
964 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | if (err < 0) { |
965 | ✗ | print_error(filename, err); | |
966 | ✗ | if (err == AVERROR_PROTOCOL_NOT_FOUND) | |
967 | ✗ | av_log(NULL, AV_LOG_ERROR, "Did you mean file:%s?\n", filename); | |
968 | ✗ | exit_program(1); | |
969 | } | ||
970 |
1/2✓ Branch 0 taken 6494 times.
✗ Branch 1 not taken.
|
6494 | if (scan_all_pmts_set) |
971 | 6494 | av_dict_set(&o->g->format_opts, "scan_all_pmts", NULL, AV_DICT_MATCH_CASE); | |
972 | 6494 | remove_avoptions(&o->g->format_opts, o->g->codec_opts); | |
973 | 6494 | assert_avoptions(o->g->format_opts); | |
974 | |||
975 | /* apply forced codec ids */ | ||
976 |
2/2✓ Branch 0 taken 6817 times.
✓ Branch 1 taken 6494 times.
|
13311 | for (i = 0; i < ic->nb_streams; i++) |
977 | 6817 | choose_decoder(o, ic, ic->streams[i], HWACCEL_NONE, AV_HWDEVICE_TYPE_NONE); | |
978 | |||
979 |
2/2✓ Branch 0 taken 6492 times.
✓ Branch 1 taken 2 times.
|
6494 | if (o->find_stream_info) { |
980 | 6492 | AVDictionary **opts = setup_find_stream_info_opts(ic, o->g->codec_opts); | |
981 | 6492 | int orig_nb_streams = ic->nb_streams; | |
982 | |||
983 | /* If not enough info to get the stream parameters, we decode the | ||
984 | first frames to get it. (used in mpeg case for example) */ | ||
985 | 6492 | ret = avformat_find_stream_info(ic, opts); | |
986 | |||
987 |
2/2✓ Branch 0 taken 6815 times.
✓ Branch 1 taken 6492 times.
|
13307 | for (i = 0; i < orig_nb_streams; i++) |
988 | 6815 | av_dict_free(&opts[i]); | |
989 | 6492 | av_freep(&opts); | |
990 | |||
991 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6492 times.
|
6492 | if (ret < 0) { |
992 | ✗ | av_log(NULL, AV_LOG_FATAL, "%s: could not find codec parameters\n", filename); | |
993 | ✗ | if (ic->nb_streams == 0) { | |
994 | ✗ | avformat_close_input(&ic); | |
995 | ✗ | exit_program(1); | |
996 | } | ||
997 | } | ||
998 | } | ||
999 | |||
1000 |
3/4✓ Branch 0 taken 21 times.
✓ Branch 1 taken 6473 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 21 times.
|
6494 | if (start_time != AV_NOPTS_VALUE && start_time_eof != AV_NOPTS_VALUE) { |
1001 | ✗ | av_log(NULL, AV_LOG_WARNING, "Cannot use -ss and -sseof both, using -ss for %s\n", filename); | |
1002 | ✗ | start_time_eof = AV_NOPTS_VALUE; | |
1003 | } | ||
1004 | |||
1005 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | if (start_time_eof != AV_NOPTS_VALUE) { |
1006 | ✗ | if (start_time_eof >= 0) { | |
1007 | ✗ | av_log(NULL, AV_LOG_ERROR, "-sseof value must be negative; aborting\n"); | |
1008 | ✗ | exit_program(1); | |
1009 | } | ||
1010 | ✗ | if (ic->duration > 0) { | |
1011 | ✗ | start_time = start_time_eof + ic->duration; | |
1012 | ✗ | if (start_time < 0) { | |
1013 | ✗ | av_log(NULL, AV_LOG_WARNING, "-sseof value seeks to before start of file %s; ignored\n", filename); | |
1014 | ✗ | start_time = AV_NOPTS_VALUE; | |
1015 | } | ||
1016 | } else | ||
1017 | ✗ | av_log(NULL, AV_LOG_WARNING, "Cannot use -sseof, duration of %s not known\n", filename); | |
1018 | } | ||
1019 |
2/2✓ Branch 0 taken 21 times.
✓ Branch 1 taken 6473 times.
|
6494 | timestamp = (start_time == AV_NOPTS_VALUE) ? 0 : start_time; |
1020 | /* add the stream start time */ | ||
1021 |
4/4✓ Branch 0 taken 6491 times.
✓ Branch 1 taken 3 times.
✓ Branch 2 taken 4930 times.
✓ Branch 3 taken 1561 times.
|
6494 | if (!o->seek_timestamp && ic->start_time != AV_NOPTS_VALUE) |
1022 | 4930 | timestamp += ic->start_time; | |
1023 | |||
1024 | /* if seeking requested, we execute it */ | ||
1025 |
2/2✓ Branch 0 taken 21 times.
✓ Branch 1 taken 6473 times.
|
6494 | if (start_time != AV_NOPTS_VALUE) { |
1026 | 21 | int64_t seek_timestamp = timestamp; | |
1027 | |||
1028 |
1/2✓ Branch 0 taken 21 times.
✗ Branch 1 not taken.
|
21 | if (!(ic->iformat->flags & AVFMT_SEEK_TO_PTS)) { |
1029 | 21 | int dts_heuristic = 0; | |
1030 |
2/2✓ Branch 0 taken 21 times.
✓ Branch 1 taken 21 times.
|
42 | for (i=0; i<ic->nb_streams; i++) { |
1031 | 21 | const AVCodecParameters *par = ic->streams[i]->codecpar; | |
1032 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 21 times.
|
21 | if (par->video_delay) { |
1033 | ✗ | dts_heuristic = 1; | |
1034 | ✗ | break; | |
1035 | } | ||
1036 | } | ||
1037 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 21 times.
|
21 | if (dts_heuristic) { |
1038 | ✗ | seek_timestamp -= 3*AV_TIME_BASE / 23; | |
1039 | } | ||
1040 | } | ||
1041 | 21 | ret = avformat_seek_file(ic, -1, INT64_MIN, seek_timestamp, seek_timestamp, 0); | |
1042 |
2/2✓ Branch 0 taken 1 times.
✓ Branch 1 taken 20 times.
|
21 | if (ret < 0) { |
1043 | 1 | av_log(NULL, AV_LOG_WARNING, "%s: could not seek to position %0.3f\n", | |
1044 | 1 | filename, (double)timestamp / AV_TIME_BASE); | |
1045 | } | ||
1046 | } | ||
1047 | |||
1048 | 6494 | d = allocate_array_elem(&input_files, sizeof(*d), &nb_input_files); | |
1049 | 6494 | f = &d->f; | |
1050 | |||
1051 | 6494 | f->ctx = ic; | |
1052 | 6494 | f->index = nb_input_files - 1; | |
1053 | 6494 | f->start_time = start_time; | |
1054 | 6494 | f->recording_time = recording_time; | |
1055 | 6494 | f->input_sync_ref = o->input_sync_ref; | |
1056 | 6494 | f->input_ts_offset = o->input_ts_offset; | |
1057 |
3/6✓ Branch 0 taken 12 times.
✓ Branch 1 taken 6482 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 12 times.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
|
6494 | f->ts_offset = o->input_ts_offset - (copy_ts ? (start_at_zero && ic->start_time != AV_NOPTS_VALUE ? ic->start_time : 0) : timestamp); |
1058 | 6494 | f->rate_emu = o->rate_emu; | |
1059 | 6494 | f->accurate_seek = o->accurate_seek; | |
1060 | 6494 | d->loop = o->loop; | |
1061 | 6494 | d->duration = 0; | |
1062 | 6494 | d->time_base = (AVRational){ 1, 1 }; | |
1063 | |||
1064 | 6494 | f->readrate = o->readrate ? o->readrate : 0.0; | |
1065 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | if (f->readrate < 0.0f) { |
1066 | ✗ | av_log(NULL, AV_LOG_ERROR, "Option -readrate for Input #%d is %0.3f; it must be non-negative.\n", f->index, f->readrate); | |
1067 | ✗ | exit_program(1); | |
1068 | } | ||
1069 |
1/4✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
|
6494 | if (f->readrate && f->rate_emu) { |
1070 | ✗ | av_log(NULL, AV_LOG_WARNING, "Both -readrate and -re set for Input #%d. Using -readrate %0.3f.\n", f->index, f->readrate); | |
1071 | ✗ | f->rate_emu = 0; | |
1072 | } | ||
1073 | |||
1074 | 6494 | d->thread_queue_size = o->thread_queue_size; | |
1075 | |||
1076 | /* update the current parameters so that they match the one of the input stream */ | ||
1077 | 6494 | add_input_streams(o, d); | |
1078 | |||
1079 | /* dump the file content */ | ||
1080 | 6494 | av_dump_format(ic, f->index, filename, 0); | |
1081 | |||
1082 | /* check if all codec options have been used */ | ||
1083 | 6494 | unused_opts = strip_specifiers(o->g->codec_opts); | |
1084 |
2/2✓ Branch 0 taken 6937 times.
✓ Branch 1 taken 6494 times.
|
13431 | for (i = 0; i < f->nb_streams; i++) { |
1085 | 6937 | e = NULL; | |
1086 |
2/2✓ Branch 1 taken 21484 times.
✓ Branch 2 taken 6937 times.
|
28421 | while ((e = av_dict_iterate(f->streams[i]->decoder_opts, e))) |
1087 | 21484 | av_dict_set(&unused_opts, e->key, NULL, 0); | |
1088 | } | ||
1089 | |||
1090 | 6494 | e = NULL; | |
1091 |
2/2✓ Branch 1 taken 395 times.
✓ Branch 2 taken 6494 times.
|
6889 | while ((e = av_dict_iterate(unused_opts, e))) { |
1092 | 395 | const AVClass *class = avcodec_get_class(); | |
1093 | 395 | const AVOption *option = av_opt_find(&class, e->key, NULL, 0, | |
1094 | AV_OPT_SEARCH_CHILDREN | AV_OPT_SEARCH_FAKE_OBJ); | ||
1095 | 395 | const AVClass *fclass = avformat_get_class(); | |
1096 | 395 | const AVOption *foption = av_opt_find(&fclass, e->key, NULL, 0, | |
1097 | AV_OPT_SEARCH_CHILDREN | AV_OPT_SEARCH_FAKE_OBJ); | ||
1098 |
2/4✓ Branch 0 taken 395 times.
✗ Branch 1 not taken.
✗ Branch 2 not taken.
✓ Branch 3 taken 395 times.
|
395 | if (!option || foption) |
1099 | ✗ | continue; | |
1100 | |||
1101 | |||
1102 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 395 times.
|
395 | if (!(option->flags & AV_OPT_FLAG_DECODING_PARAM)) { |
1103 | ✗ | av_log(NULL, AV_LOG_ERROR, "Codec AVOption %s (%s) specified for " | |
1104 | ✗ | "input file #%d (%s) is not a decoding option.\n", e->key, | |
1105 | ✗ | option->help ? option->help : "", f->index, | |
1106 | filename); | ||
1107 | ✗ | exit_program(1); | |
1108 | } | ||
1109 | |||
1110 | 395 | av_log(NULL, AV_LOG_WARNING, "Codec AVOption %s (%s) specified for " | |
1111 | "input file #%d (%s) has not been used for any stream. The most " | ||
1112 | "likely reason is either wrong type (e.g. a video option with " | ||
1113 | "no video streams) or that it is a private option of some decoder " | ||
1114 | 395 | "which was not actually used for any stream.\n", e->key, | |
1115 |
1/2✓ Branch 0 taken 395 times.
✗ Branch 1 not taken.
|
395 | option->help ? option->help : "", f->index, filename); |
1116 | } | ||
1117 | 6494 | av_dict_free(&unused_opts); | |
1118 | |||
1119 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 6494 times.
|
6494 | for (i = 0; i < o->nb_dump_attachment; i++) { |
1120 | int j; | ||
1121 | |||
1122 | ✗ | for (j = 0; j < ic->nb_streams; j++) { | |
1123 | ✗ | AVStream *st = ic->streams[j]; | |
1124 | |||
1125 | ✗ | if (check_stream_specifier(ic, st, o->dump_attachment[i].specifier) == 1) | |
1126 | ✗ | dump_attachment(st, o->dump_attachment[i].u.str); | |
1127 | } | ||
1128 | } | ||
1129 | |||
1130 | 6494 | return 0; | |
1131 | } | ||
1132 |