55 #if HAVE_SYS_RESOURCE_H
57 #include <sys/types.h>
58 #include <sys/resource.h>
59 #elif HAVE_GETPROCESSTIMES
62 #if HAVE_GETPROCESSMEMORYINFO
68 #include <sys/select.h>
97 static int transcoding_finished;
100 #define DEFAULT_PASS_LOGFILENAME_PREFIX "av2pass"
153 for (j = 0; j < filtergraphs[i]->
nb_inputs; j++) {
158 for (j = 0; j < filtergraphs[i]->
nb_outputs; j++) {
163 av_freep(&filtergraphs[i]->graph_desc);
189 av_freep(&output_streams[i]->forced_keyframes);
190 av_freep(&output_streams[i]->avfilter);
191 av_freep(&output_streams[i]->logfile_prefix);
202 av_freep(&input_streams[i]->filters);
203 av_freep(&input_streams[i]->hwaccel_device);
238 const char *codec_string = encoder ?
"encoder" :
"decoder";
241 "results.\nAdd '-strict experimental' if you want to use it.\n",
242 codec_string, c->
name);
246 codec_string, codec->
name);
271 int min_dec = INT_MAX, min_inc = INT_MAX;
283 int fmt_diff = 32 * abs(dfmt - efmt);
290 }
else if (dfmt > efmt) {
291 if (fmt_diff < min_inc) {
296 if (fmt_diff < min_dec) {
359 "%d:%d; previous: %"PRId64
", current: %"PRId64
"; ",
366 "in incorrect timestamps in the output file.\n",
436 int subtitle_out_max_size = 1024 * 1024;
437 int subtitle_out_size, nb, i;
451 subtitle_out =
av_malloc(subtitle_out_max_size);
462 for (i = 0; i < nb; i++) {
473 subtitle_out_max_size, sub);
474 if (subtitle_out_size < 0) {
480 pkt.
data = subtitle_out;
481 pkt.
size = subtitle_out_size;
500 int ret, format_video_sync;
575 *frame_size = pkt.
size;
595 return -10.0 * log(d) / log(10.0);
602 double ti1, bitrate, avg_bitrate;
627 avg_bitrate = (double)(
video_size * 8) / ti1 / 1000.0;
628 fprintf(
vstats_file,
"s_size= %8.0fkB time= %0.3f br= %7.1fkbits/s avg_br= %7.1fkbits/s ",
629 (
double)
video_size / 1024, ti1, bitrate, avg_bitrate);
717 int64_t min_pts = INT64_MAX;
721 int64_t pts = output_streams[i]->
sync_opts;
723 if (!output_streams[i]->
filter || output_streams[i]->finished)
726 pts =
av_rescale_q(pts, output_streams[i]->st->codec->time_base,
730 ost = output_streams[i];
742 }
else if (ret ==
AVERROR(EAGAIN))
756 int frame_number, vid, i;
757 double bitrate, ti1, pts;
758 static int64_t last_time = -1;
759 static int qp_histogram[52];
764 if (!is_last_report) {
768 if (last_time == -1) {
772 if ((cur_time - last_time) < 500000)
778 oc = output_files[0]->
ctx;
783 if (total_size < 0) {
787 "avio_tell() failed: %s\n", errbuf);
796 ost = output_streams[i];
801 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"q=%2.1f ", q);
804 float t = (
av_gettime() - timer_start) / 1000000.0;
807 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"frame=%5d fps=%3d q=%3.1f ",
808 frame_number, (t > 1) ? (
int)(frame_number / t + 0.5) : 0, q);
810 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"L");
816 for (j = 0; j < 32; j++)
817 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"%X", (
int)
lrintf(
log2(qp_histogram[j] + 1)));
821 double error, error_sum = 0;
822 double scale, scale_sum = 0;
823 char type[3] = {
'Y',
'U',
'V' };
824 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"PSNR=");
825 for (j = 0; j < 3; j++) {
826 if (is_last_report) {
827 error = enc->
error[j];
828 scale = enc->
width * enc->
height * 255.0 * 255.0 * frame_number;
837 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"%c:%2.2f ", type[j],
psnr(error / scale));
839 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"*:%2.2f ",
psnr(error_sum / scale_sum));
845 if ((pts < ti1) && (pts > 0))
851 bitrate = (double)(total_size * 8) / ti1 / 1000.0;
853 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
854 "size=%8.0fkB time=%0.2f bitrate=%6.1fkbits/s",
855 (
double)total_size / 1024, ti1, bitrate);
858 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
" dup=%d drop=%d",
865 if (is_last_report) {
870 percent = 100.0 * (total_size - raw) / raw;
873 av_log(
NULL,
AV_LOG_INFO,
"video:%1.0fkB audio:%1.0fkB global headers:%1.0fkB muxing overhead %f%%\n",
889 int stop_encoding = 0;
926 ret = encode(enc, &pkt,
NULL, &got_packet);
1018 opkt.
dts -= ost_tb_start_time;
1051 char layout_name[256];
1068 int i, ret, err = 0, resample_changed;
1077 if (!*got_output || ret < 0) {
1090 decoded_frame->
pts = pkt->
pts;
1098 if (resample_changed) {
1099 char layout1[64], layout2[64];
1103 "layout for Input Stream #%d.%d\n", ist->
file_index,
1115 "Input stream #%d:%d frame changed from rate:%d fmt:%s ch:%d chl:%s to rate:%d fmt:%s ch:%d chl:%s\n",
1139 for (i = 0; i < ist->nb_filters; i++) {
1140 if (i < ist->nb_filters - 1) {
1141 f = ist->filter_frame;
1155 return err < 0 ? err : ret;
1161 int i, ret = 0, err = 0, resample_changed;
1170 decoded_frame, got_output, pkt);
1171 if (!*got_output || ret < 0) {
1196 if (resample_changed) {
1198 "Input stream #%d:%d frame changed from size:%dx%d fmt:%s to size:%dx%d fmt:%s\n",
1220 if (i < ist->nb_filters - 1) {
1236 return err < 0 ? err : ret;
1243 &subtitle, got_output, pkt);
1294 "Multiple frames in a packet from stream %d\n", pkt->
stream_index);
1373 avc[i] = output_files[i]->ctx;
1376 printf(
"SDP:\n%s\n", sdp);
1385 if (
hwaccels[i].pix_fmt == pix_fmt)
1396 for (p = pix_fmts; *p != -1; p++) {
1409 ret = hwaccel->
init(s);
1413 "%s hwaccel requested for input stream #%d:%d, "
1414 "but cannot be initialized.\n", hwaccel->
name,
1445 snprintf(error, error_len,
"Decoder (codec id %d) not found for input stream #%d:%d",
1476 snprintf(error, error_len,
1477 "Error while opening decoder for input stream "
1517 for (p = kf; *p; p++)
1528 for (i = 0; i < n; i++) {
1529 char *next = strchr(p,
',');
1543 int ret = 0, i, j, k;
1561 oc = output_files[i]->
ctx;
1577 ost = output_streams[i];
1602 if (extra_size > INT_MAX) {
1676 snprintf(error,
sizeof(error),
"Automatic encoder selection "
1677 "failed for output stream #%d:%d. Default encoder for "
1678 "format %s is probably disabled. Please choose an "
1709 "for the output stream #%d:%d, but no information "
1710 "about the input framerate is available. Falling "
1711 "back to a default value of 25fps. Use the -r option "
1712 "if you want a different framerate.\n",
1776 snprintf(logfilename,
sizeof(logfilename),
"%s-%d.log",
1780 if (!strcmp(ost->
enc->
name,
"libx264")) {
1784 f = fopen(logfilename,
"wb");
1787 logfilename, strerror(errno));
1793 size_t logbuffer_size;
1808 ost = output_streams[i];
1829 snprintf(error,
sizeof(error),
"Error while opening encoder for output stream #%d:%d - maybe incorrect parameters such as bit_rate, rate, width or height",
1836 "It takes bits/s as argument, not kbits/s\n");
1866 oc = output_files[i]->
ctx;
1871 snprintf(error,
sizeof(error),
1872 "Could not write header for output file #%d "
1873 "(incorrect codec parameters ?): %s",
1888 av_dump_format(output_files[i]->ctx, i, output_files[i]->ctx->filename, 1);
1894 ist = input_streams[i];
1901 if (nb_filtergraphs > 1)
1909 ost = output_streams[i];
1921 if (nb_filtergraphs > 1)
1988 int64_t ipts_min = INT64_MAX;
1998 if (ipts < ipts_min) {
2009 static void *input_thread(
void *arg)
2014 while (!transcoding_finished && ret >= 0) {
2039 static void free_input_threads(
void)
2046 transcoding_finished = 1;
2052 if (!f->fifo || f->joined)
2074 static int init_input_threads(
void)
2078 if (nb_input_files == 1)
2132 if (nb_input_files > 1)
2133 return get_input_packet_mt(f, pkt);
2142 if (input_files[i]->eagain)
2151 input_files[i]->eagain = 0;
2203 ist = input_streams[ifile->
ist_index + i];
2229 goto discard_packet;
2233 goto discard_packet;
2253 "timestamp discontinuity %"PRId64
", new offset= %"PRId64
"\n",
2280 int ret, i, need_input = 1;
2284 int64_t timer_start;
2296 if ((ret = init_input_threads()) < 0)
2327 free_input_threads();
2332 ist = input_streams[i];
2344 os = output_files[i]->
ctx;
2353 ost = output_streams[i];
2362 ist = input_streams[i];
2375 free_input_threads();
2378 if (output_streams) {
2380 ost = output_streams[i];
2401 struct rusage rusage;
2403 getrusage(RUSAGE_SELF, &rusage);
2404 return (rusage.ru_utime.tv_sec * 1000000LL) + rusage.ru_utime.tv_usec;
2405 #elif HAVE_GETPROCESSTIMES
2407 FILETIME c, e, k, u;
2408 proc = GetCurrentProcess();
2409 GetProcessTimes(proc, &c, &e, &k, &u);
2410 return ((int64_t) u.dwHighDateTime << 32 | u.dwLowDateTime) / 10;
2418 #if HAVE_GETRUSAGE && HAVE_STRUCT_RUSAGE_RU_MAXRSS
2419 struct rusage rusage;
2420 getrusage(RUSAGE_SELF, &rusage);
2421 return (int64_t)rusage.ru_maxrss * 1024;
2422 #elif HAVE_GETPROCESSMEMORYINFO
2424 PROCESS_MEMORY_COUNTERS memcounters;
2425 proc = GetCurrentProcess();
2426 memcounters.cb =
sizeof(memcounters);
2427 GetProcessMemoryInfo(proc, &memcounters,
sizeof(memcounters));
2428 return memcounters.PeakPagefileUsage;
2467 fprintf(stderr,
"At least one output file must be specified\n");
2477 printf(
"bench: utime=%0.3fs maxrss=%ikB\n", ti / 1000000.0, maxrss);