transcoding.c 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623
  1. /*
  2. * Copyright (c) 2010 Nicolas George
  3. * Copyright (c) 2011 Stefano Sabatini
  4. * Copyright (c) 2014 Andrey Utkin
  5. *
  6. * Permission is hereby granted, free of charge, to any person obtaining a copy
  7. * of this software and associated documentation files (the "Software"), to deal
  8. * in the Software without restriction, including without limitation the rights
  9. * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  10. * copies of the Software, and to permit persons to whom the Software is
  11. * furnished to do so, subject to the following conditions:
  12. *
  13. * The above copyright notice and this permission notice shall be included in
  14. * all copies or substantial portions of the Software.
  15. *
  16. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  17. * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  18. * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
  19. * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  20. * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  21. * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
  22. * THE SOFTWARE.
  23. */
  24. /**
  25. * @file
  26. * API example for demuxing, decoding, filtering, encoding and muxing
  27. * @example transcoding.c
  28. */
  29. #include <libavcodec/avcodec.h>
  30. #include <libavformat/avformat.h>
  31. #include <libavfilter/avfiltergraph.h>
  32. #include <libavfilter/buffersink.h>
  33. #include <libavfilter/buffersrc.h>
  34. #include <libavutil/opt.h>
  35. #include <libavutil/pixdesc.h>
  36. static AVFormatContext *ifmt_ctx;
  37. static AVFormatContext *ofmt_ctx;
  38. typedef struct FilteringContext {
  39. AVFilterContext *buffersink_ctx;
  40. AVFilterContext *buffersrc_ctx;
  41. AVFilterGraph *filter_graph;
  42. } FilteringContext;
  43. static FilteringContext *filter_ctx;
  44. typedef struct StreamContext {
  45. AVCodecContext *dec_ctx;
  46. AVCodecContext *enc_ctx;
  47. } StreamContext;
  48. static StreamContext *stream_ctx;
  49. static int open_input_file(const char *filename)
  50. {
  51. int ret;
  52. unsigned int i;
  53. ifmt_ctx = NULL;
  54. if ((ret = avformat_open_input(&ifmt_ctx, filename, NULL, NULL)) < 0) {
  55. av_log(NULL, AV_LOG_ERROR, "Cannot open input file\n");
  56. return ret;
  57. }
  58. if ((ret = avformat_find_stream_info(ifmt_ctx, NULL)) < 0) {
  59. av_log(NULL, AV_LOG_ERROR, "Cannot find stream information\n");
  60. return ret;
  61. }
  62. stream_ctx = av_mallocz_array(ifmt_ctx->nb_streams, sizeof(*stream_ctx));
  63. if (!stream_ctx)
  64. return AVERROR(ENOMEM);
  65. for (i = 0; i < ifmt_ctx->nb_streams; i++) {
  66. AVStream *stream = ifmt_ctx->streams[i];
  67. AVCodec *dec = avcodec_find_decoder(stream->codecpar->codec_id);
  68. AVCodecContext *codec_ctx;
  69. if (!dec) {
  70. av_log(NULL, AV_LOG_ERROR, "Failed to find decoder for stream #%u\n", i);
  71. return AVERROR_DECODER_NOT_FOUND;
  72. }
  73. codec_ctx = avcodec_alloc_context3(dec);
  74. if (!codec_ctx) {
  75. av_log(NULL, AV_LOG_ERROR, "Failed to allocate the decoder context for stream #%u\n", i);
  76. return AVERROR(ENOMEM);
  77. }
  78. ret = avcodec_parameters_to_context(codec_ctx, stream->codecpar);
  79. if (ret < 0) {
  80. av_log(NULL, AV_LOG_ERROR, "Failed to copy decoder parameters to input decoder context "
  81. "for stream #%u\n", i);
  82. return ret;
  83. }
  84. /* Reencode video & audio and remux subtitles etc. */
  85. if (codec_ctx->codec_type == AVMEDIA_TYPE_VIDEO
  86. || codec_ctx->codec_type == AVMEDIA_TYPE_AUDIO) {
  87. if (codec_ctx->codec_type == AVMEDIA_TYPE_VIDEO)
  88. codec_ctx->framerate = av_guess_frame_rate(ifmt_ctx, stream, NULL);
  89. /* Open decoder */
  90. ret = avcodec_open2(codec_ctx, dec, NULL);
  91. if (ret < 0) {
  92. av_log(NULL, AV_LOG_ERROR, "Failed to open decoder for stream #%u\n", i);
  93. return ret;
  94. }
  95. }
  96. stream_ctx[i].dec_ctx = codec_ctx;
  97. }
  98. av_dump_format(ifmt_ctx, 0, filename, 0);
  99. return 0;
  100. }
  101. static int open_output_file(const char *filename)
  102. {
  103. AVStream *out_stream;
  104. AVStream *in_stream;
  105. AVCodecContext *dec_ctx, *enc_ctx;
  106. AVCodec *encoder;
  107. int ret;
  108. unsigned int i;
  109. ofmt_ctx = NULL;
  110. avformat_alloc_output_context2(&ofmt_ctx, NULL, NULL, filename);
  111. if (!ofmt_ctx) {
  112. av_log(NULL, AV_LOG_ERROR, "Could not create output context\n");
  113. return AVERROR_UNKNOWN;
  114. }
  115. for (i = 0; i < ifmt_ctx->nb_streams; i++) {
  116. out_stream = avformat_new_stream(ofmt_ctx, NULL);
  117. if (!out_stream) {
  118. av_log(NULL, AV_LOG_ERROR, "Failed allocating output stream\n");
  119. return AVERROR_UNKNOWN;
  120. }
  121. in_stream = ifmt_ctx->streams[i];
  122. dec_ctx = stream_ctx[i].dec_ctx;
  123. if (dec_ctx->codec_type == AVMEDIA_TYPE_VIDEO
  124. || dec_ctx->codec_type == AVMEDIA_TYPE_AUDIO) {
  125. /* in this example, we choose transcoding to same codec */
  126. encoder = avcodec_find_encoder(dec_ctx->codec_id);
  127. if (!encoder) {
  128. av_log(NULL, AV_LOG_FATAL, "Necessary encoder not found\n");
  129. return AVERROR_INVALIDDATA;
  130. }
  131. enc_ctx = avcodec_alloc_context3(encoder);
  132. if (!enc_ctx) {
  133. av_log(NULL, AV_LOG_FATAL, "Failed to allocate the encoder context\n");
  134. return AVERROR(ENOMEM);
  135. }
  136. /* In this example, we transcode to same properties (picture size,
  137. * sample rate etc.). These properties can be changed for output
  138. * streams easily using filters */
  139. if (dec_ctx->codec_type == AVMEDIA_TYPE_VIDEO) {
  140. enc_ctx->height = dec_ctx->height;
  141. enc_ctx->width = dec_ctx->width;
  142. enc_ctx->sample_aspect_ratio = dec_ctx->sample_aspect_ratio;
  143. /* take first format from list of supported formats */
  144. if (encoder->pix_fmts)
  145. enc_ctx->pix_fmt = encoder->pix_fmts[0];
  146. else
  147. enc_ctx->pix_fmt = dec_ctx->pix_fmt;
  148. /* video time_base can be set to whatever is handy and supported by encoder */
  149. enc_ctx->time_base = av_inv_q(dec_ctx->framerate);
  150. } else {
  151. enc_ctx->sample_rate = dec_ctx->sample_rate;
  152. enc_ctx->channel_layout = dec_ctx->channel_layout;
  153. enc_ctx->channels = av_get_channel_layout_nb_channels(enc_ctx->channel_layout);
  154. /* take first format from list of supported formats */
  155. enc_ctx->sample_fmt = encoder->sample_fmts[0];
  156. enc_ctx->time_base = (AVRational){1, enc_ctx->sample_rate};
  157. }
  158. /* Third parameter can be used to pass settings to encoder */
  159. ret = avcodec_open2(enc_ctx, encoder, NULL);
  160. if (ret < 0) {
  161. av_log(NULL, AV_LOG_ERROR, "Cannot open video encoder for stream #%u\n", i);
  162. return ret;
  163. }
  164. ret = avcodec_parameters_from_context(out_stream->codecpar, enc_ctx);
  165. if (ret < 0) {
  166. av_log(NULL, AV_LOG_ERROR, "Failed to copy encoder parameters to output stream #%u\n", i);
  167. return ret;
  168. }
  169. if (ofmt_ctx->oformat->flags & AVFMT_GLOBALHEADER)
  170. enc_ctx->flags |= AV_CODEC_FLAG_GLOBAL_HEADER;
  171. out_stream->time_base = enc_ctx->time_base;
  172. stream_ctx[i].enc_ctx = enc_ctx;
  173. } else if (dec_ctx->codec_type == AVMEDIA_TYPE_UNKNOWN) {
  174. av_log(NULL, AV_LOG_FATAL, "Elementary stream #%d is of unknown type, cannot proceed\n", i);
  175. return AVERROR_INVALIDDATA;
  176. } else {
  177. /* if this stream must be remuxed */
  178. ret = avcodec_parameters_copy(out_stream->codecpar, in_stream->codecpar);
  179. if (ret < 0) {
  180. av_log(NULL, AV_LOG_ERROR, "Copying parameters for stream #%u failed\n", i);
  181. return ret;
  182. }
  183. out_stream->time_base = in_stream->time_base;
  184. }
  185. }
  186. av_dump_format(ofmt_ctx, 0, filename, 1);
  187. if (!(ofmt_ctx->oformat->flags & AVFMT_NOFILE)) {
  188. ret = avio_open(&ofmt_ctx->pb, filename, AVIO_FLAG_WRITE);
  189. if (ret < 0) {
  190. av_log(NULL, AV_LOG_ERROR, "Could not open output file '%s'", filename);
  191. return ret;
  192. }
  193. }
  194. /* init muxer, write output file header */
  195. ret = avformat_write_header(ofmt_ctx, NULL);
  196. if (ret < 0) {
  197. av_log(NULL, AV_LOG_ERROR, "Error occurred when opening output file\n");
  198. return ret;
  199. }
  200. return 0;
  201. }
  202. static int init_filter(FilteringContext* fctx, AVCodecContext *dec_ctx,
  203. AVCodecContext *enc_ctx, const char *filter_spec)
  204. {
  205. char args[512];
  206. int ret = 0;
  207. AVFilter *buffersrc = NULL;
  208. AVFilter *buffersink = NULL;
  209. AVFilterContext *buffersrc_ctx = NULL;
  210. AVFilterContext *buffersink_ctx = NULL;
  211. AVFilterInOut *outputs = avfilter_inout_alloc();
  212. AVFilterInOut *inputs = avfilter_inout_alloc();
  213. AVFilterGraph *filter_graph = avfilter_graph_alloc();
  214. if (!outputs || !inputs || !filter_graph) {
  215. ret = AVERROR(ENOMEM);
  216. goto end;
  217. }
  218. if (dec_ctx->codec_type == AVMEDIA_TYPE_VIDEO) {
  219. buffersrc = avfilter_get_by_name("buffer");
  220. buffersink = avfilter_get_by_name("buffersink");
  221. if (!buffersrc || !buffersink) {
  222. av_log(NULL, AV_LOG_ERROR, "filtering source or sink element not found\n");
  223. ret = AVERROR_UNKNOWN;
  224. goto end;
  225. }
  226. snprintf(args, sizeof(args),
  227. "video_size=%dx%d:pix_fmt=%d:time_base=%d/%d:pixel_aspect=%d/%d",
  228. dec_ctx->width, dec_ctx->height, dec_ctx->pix_fmt,
  229. dec_ctx->time_base.num, dec_ctx->time_base.den,
  230. dec_ctx->sample_aspect_ratio.num,
  231. dec_ctx->sample_aspect_ratio.den);
  232. ret = avfilter_graph_create_filter(&buffersrc_ctx, buffersrc, "in",
  233. args, NULL, filter_graph);
  234. if (ret < 0) {
  235. av_log(NULL, AV_LOG_ERROR, "Cannot create buffer source\n");
  236. goto end;
  237. }
  238. ret = avfilter_graph_create_filter(&buffersink_ctx, buffersink, "out",
  239. NULL, NULL, filter_graph);
  240. if (ret < 0) {
  241. av_log(NULL, AV_LOG_ERROR, "Cannot create buffer sink\n");
  242. goto end;
  243. }
  244. ret = av_opt_set_bin(buffersink_ctx, "pix_fmts",
  245. (uint8_t*)&enc_ctx->pix_fmt, sizeof(enc_ctx->pix_fmt),
  246. AV_OPT_SEARCH_CHILDREN);
  247. if (ret < 0) {
  248. av_log(NULL, AV_LOG_ERROR, "Cannot set output pixel format\n");
  249. goto end;
  250. }
  251. } else if (dec_ctx->codec_type == AVMEDIA_TYPE_AUDIO) {
  252. buffersrc = avfilter_get_by_name("abuffer");
  253. buffersink = avfilter_get_by_name("abuffersink");
  254. if (!buffersrc || !buffersink) {
  255. av_log(NULL, AV_LOG_ERROR, "filtering source or sink element not found\n");
  256. ret = AVERROR_UNKNOWN;
  257. goto end;
  258. }
  259. if (!dec_ctx->channel_layout)
  260. dec_ctx->channel_layout =
  261. av_get_default_channel_layout(dec_ctx->channels);
  262. snprintf(args, sizeof(args),
  263. "time_base=%d/%d:sample_rate=%d:sample_fmt=%s:channel_layout=0x%"PRIx64,
  264. dec_ctx->time_base.num, dec_ctx->time_base.den, dec_ctx->sample_rate,
  265. av_get_sample_fmt_name(dec_ctx->sample_fmt),
  266. dec_ctx->channel_layout);
  267. ret = avfilter_graph_create_filter(&buffersrc_ctx, buffersrc, "in",
  268. args, NULL, filter_graph);
  269. if (ret < 0) {
  270. av_log(NULL, AV_LOG_ERROR, "Cannot create audio buffer source\n");
  271. goto end;
  272. }
  273. ret = avfilter_graph_create_filter(&buffersink_ctx, buffersink, "out",
  274. NULL, NULL, filter_graph);
  275. if (ret < 0) {
  276. av_log(NULL, AV_LOG_ERROR, "Cannot create audio buffer sink\n");
  277. goto end;
  278. }
  279. ret = av_opt_set_bin(buffersink_ctx, "sample_fmts",
  280. (uint8_t*)&enc_ctx->sample_fmt, sizeof(enc_ctx->sample_fmt),
  281. AV_OPT_SEARCH_CHILDREN);
  282. if (ret < 0) {
  283. av_log(NULL, AV_LOG_ERROR, "Cannot set output sample format\n");
  284. goto end;
  285. }
  286. ret = av_opt_set_bin(buffersink_ctx, "channel_layouts",
  287. (uint8_t*)&enc_ctx->channel_layout,
  288. sizeof(enc_ctx->channel_layout), AV_OPT_SEARCH_CHILDREN);
  289. if (ret < 0) {
  290. av_log(NULL, AV_LOG_ERROR, "Cannot set output channel layout\n");
  291. goto end;
  292. }
  293. ret = av_opt_set_bin(buffersink_ctx, "sample_rates",
  294. (uint8_t*)&enc_ctx->sample_rate, sizeof(enc_ctx->sample_rate),
  295. AV_OPT_SEARCH_CHILDREN);
  296. if (ret < 0) {
  297. av_log(NULL, AV_LOG_ERROR, "Cannot set output sample rate\n");
  298. goto end;
  299. }
  300. } else {
  301. ret = AVERROR_UNKNOWN;
  302. goto end;
  303. }
  304. /* Endpoints for the filter graph. */
  305. outputs->name = av_strdup("in");
  306. outputs->filter_ctx = buffersrc_ctx;
  307. outputs->pad_idx = 0;
  308. outputs->next = NULL;
  309. inputs->name = av_strdup("out");
  310. inputs->filter_ctx = buffersink_ctx;
  311. inputs->pad_idx = 0;
  312. inputs->next = NULL;
  313. if (!outputs->name || !inputs->name) {
  314. ret = AVERROR(ENOMEM);
  315. goto end;
  316. }
  317. if ((ret = avfilter_graph_parse_ptr(filter_graph, filter_spec,
  318. &inputs, &outputs, NULL)) < 0)
  319. goto end;
  320. if ((ret = avfilter_graph_config(filter_graph, NULL)) < 0)
  321. goto end;
  322. /* Fill FilteringContext */
  323. fctx->buffersrc_ctx = buffersrc_ctx;
  324. fctx->buffersink_ctx = buffersink_ctx;
  325. fctx->filter_graph = filter_graph;
  326. end:
  327. avfilter_inout_free(&inputs);
  328. avfilter_inout_free(&outputs);
  329. return ret;
  330. }
  331. static int init_filters(void)
  332. {
  333. const char *filter_spec;
  334. unsigned int i;
  335. int ret;
  336. filter_ctx = av_malloc_array(ifmt_ctx->nb_streams, sizeof(*filter_ctx));
  337. if (!filter_ctx)
  338. return AVERROR(ENOMEM);
  339. for (i = 0; i < ifmt_ctx->nb_streams; i++) {
  340. filter_ctx[i].buffersrc_ctx = NULL;
  341. filter_ctx[i].buffersink_ctx = NULL;
  342. filter_ctx[i].filter_graph = NULL;
  343. if (!(ifmt_ctx->streams[i]->codecpar->codec_type == AVMEDIA_TYPE_AUDIO
  344. || ifmt_ctx->streams[i]->codecpar->codec_type == AVMEDIA_TYPE_VIDEO))
  345. continue;
  346. if (ifmt_ctx->streams[i]->codecpar->codec_type == AVMEDIA_TYPE_VIDEO)
  347. filter_spec = "null"; /* passthrough (dummy) filter for video */
  348. else
  349. filter_spec = "anull"; /* passthrough (dummy) filter for audio */
  350. ret = init_filter(&filter_ctx[i], stream_ctx[i].dec_ctx,
  351. stream_ctx[i].enc_ctx, filter_spec);
  352. if (ret)
  353. return ret;
  354. }
  355. return 0;
  356. }
  357. static int encode_write_frame(AVFrame *filt_frame, unsigned int stream_index, int *got_frame) {
  358. int ret;
  359. int got_frame_local;
  360. AVPacket enc_pkt;
  361. int (*enc_func)(AVCodecContext *, AVPacket *, const AVFrame *, int *) =
  362. (ifmt_ctx->streams[stream_index]->codecpar->codec_type ==
  363. AVMEDIA_TYPE_VIDEO) ? avcodec_encode_video2 : avcodec_encode_audio2;
  364. if (!got_frame)
  365. got_frame = &got_frame_local;
  366. av_log(NULL, AV_LOG_INFO, "Encoding frame\n");
  367. /* encode filtered frame */
  368. enc_pkt.data = NULL;
  369. enc_pkt.size = 0;
  370. av_init_packet(&enc_pkt);
  371. ret = enc_func(stream_ctx[stream_index].enc_ctx, &enc_pkt,
  372. filt_frame, got_frame);
  373. av_frame_free(&filt_frame);
  374. if (ret < 0)
  375. return ret;
  376. if (!(*got_frame))
  377. return 0;
  378. /* prepare packet for muxing */
  379. enc_pkt.stream_index = stream_index;
  380. av_packet_rescale_ts(&enc_pkt,
  381. stream_ctx[stream_index].enc_ctx->time_base,
  382. ofmt_ctx->streams[stream_index]->time_base);
  383. av_log(NULL, AV_LOG_DEBUG, "Muxing frame\n");
  384. /* mux encoded frame */
  385. ret = av_interleaved_write_frame(ofmt_ctx, &enc_pkt);
  386. return ret;
  387. }
  388. static int filter_encode_write_frame(AVFrame *frame, unsigned int stream_index)
  389. {
  390. int ret;
  391. AVFrame *filt_frame;
  392. av_log(NULL, AV_LOG_INFO, "Pushing decoded frame to filters\n");
  393. /* push the decoded frame into the filtergraph */
  394. ret = av_buffersrc_add_frame_flags(filter_ctx[stream_index].buffersrc_ctx,
  395. frame, 0);
  396. if (ret < 0) {
  397. av_log(NULL, AV_LOG_ERROR, "Error while feeding the filtergraph\n");
  398. return ret;
  399. }
  400. /* pull filtered frames from the filtergraph */
  401. while (1) {
  402. filt_frame = av_frame_alloc();
  403. if (!filt_frame) {
  404. ret = AVERROR(ENOMEM);
  405. break;
  406. }
  407. av_log(NULL, AV_LOG_INFO, "Pulling filtered frame from filters\n");
  408. ret = av_buffersink_get_frame(filter_ctx[stream_index].buffersink_ctx,
  409. filt_frame);
  410. if (ret < 0) {
  411. /* if no more frames for output - returns AVERROR(EAGAIN)
  412. * if flushed and no more frames for output - returns AVERROR_EOF
  413. * rewrite retcode to 0 to show it as normal procedure completion
  414. */
  415. if (ret == AVERROR(EAGAIN) || ret == AVERROR_EOF)
  416. ret = 0;
  417. av_frame_free(&filt_frame);
  418. break;
  419. }
  420. filt_frame->pict_type = AV_PICTURE_TYPE_NONE;
  421. ret = encode_write_frame(filt_frame, stream_index, NULL);
  422. if (ret < 0)
  423. break;
  424. }
  425. return ret;
  426. }
  427. static int flush_encoder(unsigned int stream_index)
  428. {
  429. int ret;
  430. int got_frame;
  431. if (!(stream_ctx[stream_index].enc_ctx->codec->capabilities &
  432. AV_CODEC_CAP_DELAY))
  433. return 0;
  434. while (1) {
  435. av_log(NULL, AV_LOG_INFO, "Flushing stream #%u encoder\n", stream_index);
  436. ret = encode_write_frame(NULL, stream_index, &got_frame);
  437. if (ret < 0)
  438. break;
  439. if (!got_frame)
  440. return 0;
  441. }
  442. return ret;
  443. }
  444. int main(int argc, char **argv)
  445. {
  446. int ret;
  447. AVPacket packet = { .data = NULL, .size = 0 };
  448. AVFrame *frame = NULL;
  449. enum AVMediaType type;
  450. unsigned int stream_index;
  451. unsigned int i;
  452. int got_frame;
  453. int (*dec_func)(AVCodecContext *, AVFrame *, int *, const AVPacket *);
  454. if (argc != 3) {
  455. av_log(NULL, AV_LOG_ERROR, "Usage: %s <input file> <output file>\n", argv[0]);
  456. return 1;
  457. }
  458. av_register_all();
  459. avfilter_register_all();
  460. if ((ret = open_input_file(argv[1])) < 0)
  461. goto end;
  462. if ((ret = open_output_file(argv[2])) < 0)
  463. goto end;
  464. if ((ret = init_filters()) < 0)
  465. goto end;
  466. /* read all packets */
  467. while (1) {
  468. if ((ret = av_read_frame(ifmt_ctx, &packet)) < 0)
  469. break;
  470. stream_index = packet.stream_index;
  471. type = ifmt_ctx->streams[packet.stream_index]->codecpar->codec_type;
  472. av_log(NULL, AV_LOG_DEBUG, "Demuxer gave frame of stream_index %u\n",
  473. stream_index);
  474. if (filter_ctx[stream_index].filter_graph) {
  475. av_log(NULL, AV_LOG_DEBUG, "Going to reencode&filter the frame\n");
  476. frame = av_frame_alloc();
  477. if (!frame) {
  478. ret = AVERROR(ENOMEM);
  479. break;
  480. }
  481. av_packet_rescale_ts(&packet,
  482. ifmt_ctx->streams[stream_index]->time_base,
  483. stream_ctx[stream_index].dec_ctx->time_base);
  484. dec_func = (type == AVMEDIA_TYPE_VIDEO) ? avcodec_decode_video2 :
  485. avcodec_decode_audio4;
  486. ret = dec_func(stream_ctx[stream_index].dec_ctx, frame,
  487. &got_frame, &packet);
  488. if (ret < 0) {
  489. av_frame_free(&frame);
  490. av_log(NULL, AV_LOG_ERROR, "Decoding failed\n");
  491. break;
  492. }
  493. if (got_frame) {
  494. frame->pts = frame->best_effort_timestamp;
  495. ret = filter_encode_write_frame(frame, stream_index);
  496. av_frame_free(&frame);
  497. if (ret < 0)
  498. goto end;
  499. } else {
  500. av_frame_free(&frame);
  501. }
  502. } else {
  503. /* remux this frame without reencoding */
  504. av_packet_rescale_ts(&packet,
  505. ifmt_ctx->streams[stream_index]->time_base,
  506. ofmt_ctx->streams[stream_index]->time_base);
  507. ret = av_interleaved_write_frame(ofmt_ctx, &packet);
  508. if (ret < 0)
  509. goto end;
  510. }
  511. av_packet_unref(&packet);
  512. }
  513. /* flush filters and encoders */
  514. for (i = 0; i < ifmt_ctx->nb_streams; i++) {
  515. /* flush filter */
  516. if (!filter_ctx[i].filter_graph)
  517. continue;
  518. ret = filter_encode_write_frame(NULL, i);
  519. if (ret < 0) {
  520. av_log(NULL, AV_LOG_ERROR, "Flushing filter failed\n");
  521. goto end;
  522. }
  523. /* flush encoder */
  524. ret = flush_encoder(i);
  525. if (ret < 0) {
  526. av_log(NULL, AV_LOG_ERROR, "Flushing encoder failed\n");
  527. goto end;
  528. }
  529. }
  530. av_write_trailer(ofmt_ctx);
  531. end:
  532. av_packet_unref(&packet);
  533. av_frame_free(&frame);
  534. for (i = 0; i < ifmt_ctx->nb_streams; i++) {
  535. avcodec_free_context(&stream_ctx[i].dec_ctx);
  536. if (ofmt_ctx && ofmt_ctx->nb_streams > i && ofmt_ctx->streams[i] && stream_ctx[i].enc_ctx)
  537. avcodec_free_context(&stream_ctx[i].enc_ctx);
  538. if (filter_ctx && filter_ctx[i].filter_graph)
  539. avfilter_graph_free(&filter_ctx[i].filter_graph);
  540. }
  541. av_free(filter_ctx);
  542. av_free(stream_ctx);
  543. avformat_close_input(&ifmt_ctx);
  544. if (ofmt_ctx && !(ofmt_ctx->oformat->flags & AVFMT_NOFILE))
  545. avio_closep(&ofmt_ctx->pb);
  546. avformat_free_context(ofmt_ctx);
  547. if (ret < 0)
  548. av_log(NULL, AV_LOG_ERROR, "Error occurred: %s\n", av_err2str(ret));
  549. return ret ? 1 : 0;
  550. }