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++) {
186 av_freep(&output_streams[i]->forced_keyframes);
187 av_freep(&output_streams[i]->avfilter);
188 av_freep(&output_streams[i]->logfile_prefix);
199 av_freep(&input_streams[i]->filters);
235 const char *codec_string = encoder ?
"encoder" :
"decoder";
238 "results.\nAdd '-strict experimental' if you want to use it.\n",
239 codec_string, c->
name);
243 codec_string, codec->
name);
268 int min_dec = INT_MAX, min_inc = INT_MAX;
280 int fmt_diff = 32 * abs(dfmt - efmt);
287 }
else if (dfmt > efmt) {
288 if (fmt_diff < min_inc) {
293 if (fmt_diff < min_dec) {
426 picture2 = &picture_tmp;
441 if (picture != picture2)
442 *picture = *picture2;
453 int subtitle_out_max_size = 1024 * 1024;
454 int subtitle_out_size, nb, i;
468 subtitle_out =
av_malloc(subtitle_out_max_size);
479 for (i = 0; i < nb; i++) {
490 subtitle_out_max_size, sub);
491 if (subtitle_out_size < 0) {
497 pkt.
data = subtitle_out;
498 pkt.
size = subtitle_out_size;
517 int ret, format_video_sync;
569 big_picture = *in_picture;
601 *frame_size = pkt.
size;
621 return -10.0 * log(d) / log(10.0);
628 double ti1, bitrate, avg_bitrate;
653 avg_bitrate = (double)(
video_size * 8) / ti1 / 1000.0;
654 fprintf(
vstats_file,
"s_size= %8.0fkB time= %0.3f br= %7.1fkbits/s avg_br= %7.1fkbits/s ",
655 (
double)
video_size / 1024, ti1, bitrate, avg_bitrate);
737 int64_t min_pts = INT64_MAX;
741 int64_t pts = output_streams[i]->
sync_opts;
743 if (!output_streams[i]->
filter || output_streams[i]->finished)
746 pts =
av_rescale_q(pts, output_streams[i]->st->codec->time_base,
750 ost = output_streams[i];
770 }
else if (ret ==
AVERROR(EAGAIN))
784 int frame_number, vid, i;
785 double bitrate, ti1, pts;
786 static int64_t last_time = -1;
787 static int qp_histogram[52];
792 if (!is_last_report) {
796 if (last_time == -1) {
800 if ((cur_time - last_time) < 500000)
806 oc = output_files[0]->
ctx;
811 if (total_size < 0) {
815 "avio_tell() failed: %s\n", errbuf);
824 ost = output_streams[i];
829 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"q=%2.1f ", q);
832 float t = (
av_gettime() - timer_start) / 1000000.0;
835 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"frame=%5d fps=%3d q=%3.1f ",
836 frame_number, (t > 1) ? (
int)(frame_number / t + 0.5) : 0, q);
838 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"L");
844 for (j = 0; j < 32; j++)
845 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"%X", (
int)
lrintf(
log2(qp_histogram[j] + 1)));
849 double error, error_sum = 0;
850 double scale, scale_sum = 0;
851 char type[3] = {
'Y',
'U',
'V' };
852 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"PSNR=");
853 for (j = 0; j < 3; j++) {
854 if (is_last_report) {
855 error = enc->
error[j];
856 scale = enc->
width * enc->
height * 255.0 * 255.0 * frame_number;
865 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"%c:%2.2f ", type[j],
psnr(error / scale));
867 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"*:%2.2f ",
psnr(error_sum / scale_sum));
873 if ((pts < ti1) && (pts > 0))
879 bitrate = (double)(total_size * 8) / ti1 / 1000.0;
881 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
882 "size=%8.0fkB time=%0.2f bitrate=%6.1fkbits/s",
883 (
double)total_size / 1024, ti1, bitrate);
886 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
" dup=%d drop=%d",
893 if (is_last_report) {
896 av_log(
NULL,
AV_LOG_INFO,
"video:%1.0fkB audio:%1.0fkB global headers:%1.0fkB muxing overhead %f%%\n",
900 100.0 * (total_size - raw) / raw
913 int stop_encoding = 0;
950 ret = encode(enc, &pkt,
NULL, &got_packet);
1030 opkt.
dts -= ost_tb_start_time;
1067 char layout_name[256];
1084 int i, ret, resample_changed;
1091 if (!*got_output || ret < 0) {
1104 decoded_frame->
pts = pkt->
pts;
1114 if (resample_changed) {
1115 char layout1[64], layout2[64];
1119 "layout for Input Stream #%d.%d\n", ist->
file_index,
1131 "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",
1155 for (i = 0; i < ist->nb_filters; i++)
1164 void *buffer_to_free =
NULL;
1165 int i, ret = 0, resample_changed;
1172 decoded_frame, got_output, pkt);
1173 if (!*got_output || ret < 0) {
1194 if (resample_changed) {
1196 "Input stream #%d:%d frame changed from size:%dx%d fmt:%s to size:%dx%d fmt:%s\n",
1244 &subtitle, got_output, pkt);
1297 "Multiple frames in a packet from stream %d\n", pkt->
stream_index);
1377 avc[i] = output_files[i]->ctx;
1380 printf(
"SDP:\n%s\n", sdp);
1392 snprintf(error, error_len,
"Decoder (codec id %d) not found for input stream #%d:%d",
1418 snprintf(error, error_len,
"Error while opening decoder for input stream #%d:%d",
1457 for (p = kf; *p; p++)
1468 for (i = 0; i < n; i++) {
1469 char *next = strchr(p,
',');
1483 int ret = 0, i, j, k;
1501 oc = output_files[i]->
ctx;
1517 ost = output_streams[i];
1541 if (extra_size > INT_MAX) {
1613 snprintf(error,
sizeof(error),
"Automatic encoder selection "
1614 "failed for output stream #%d:%d. Default encoder for "
1615 "format %s is probably disabled. Please choose an "
1704 snprintf(logfilename,
sizeof(logfilename),
"%s-%d.log",
1708 if (!strcmp(ost->
enc->
name,
"libx264")) {
1712 f = fopen(logfilename,
"wb");
1715 logfilename, strerror(errno));
1721 size_t logbuffer_size;
1736 ost = output_streams[i];
1757 snprintf(error,
sizeof(error),
"Error while opening encoder for output stream #%d:%d - maybe incorrect parameters such as bit_rate, rate, width or height",
1764 "It takes bits/s as argument, not kbits/s\n");
1795 oc = output_files[i]->
ctx;
1799 const char *errbuf_ptr = errbuf;
1802 snprintf(error,
sizeof(error),
"Could not write header for output file #%d (incorrect codec parameters ?): %s", i, errbuf_ptr);
1816 av_dump_format(output_files[i]->ctx, i, output_files[i]->ctx->filename, 1);
1822 ist = input_streams[i];
1829 if (nb_filtergraphs > 1)
1837 ost = output_streams[i];
1849 if (nb_filtergraphs > 1)
1916 int64_t ipts_min = INT64_MAX;
1926 if (ipts < ipts_min) {
1937 static void *input_thread(
void *arg)
1942 while (!transcoding_finished && ret >= 0) {
1967 static void free_input_threads(
void)
1974 transcoding_finished = 1;
1980 if (!f->fifo || f->joined)
2002 static int init_input_threads(
void)
2006 if (nb_input_files == 1)
2049 if (nb_input_files > 1)
2050 return get_input_packet_mt(f, pkt);
2059 if (input_files[i]->eagain)
2068 input_files[i]->eagain = 0;
2120 ist = input_streams[ifile->
ist_index + i];
2146 goto discard_packet;
2150 goto discard_packet;
2170 "timestamp discontinuity %"PRId64
", new offset= %"PRId64
"\n",
2197 int ret, i, need_input = 1;
2201 int64_t timer_start;
2213 if ((ret = init_input_threads()) < 0)
2244 free_input_threads();
2249 ist = input_streams[i];
2261 os = output_files[i]->
ctx;
2270 ost = output_streams[i];
2279 ist = input_streams[i];
2290 free_input_threads();
2293 if (output_streams) {
2295 ost = output_streams[i];
2315 struct rusage rusage;
2317 getrusage(RUSAGE_SELF, &rusage);
2318 return (rusage.ru_utime.tv_sec * 1000000LL) + rusage.ru_utime.tv_usec;
2319 #elif HAVE_GETPROCESSTIMES
2321 FILETIME c, e, k, u;
2322 proc = GetCurrentProcess();
2323 GetProcessTimes(proc, &c, &e, &k, &u);
2324 return ((int64_t) u.dwHighDateTime << 32 | u.dwLowDateTime) / 10;
2332 #if HAVE_GETRUSAGE && HAVE_STRUCT_RUSAGE_RU_MAXRSS
2333 struct rusage rusage;
2334 getrusage(RUSAGE_SELF, &rusage);
2335 return (int64_t)rusage.ru_maxrss * 1024;
2336 #elif HAVE_GETPROCESSMEMORYINFO
2338 PROCESS_MEMORY_COUNTERS memcounters;
2339 proc = GetCurrentProcess();
2340 memcounters.cb =
sizeof(memcounters);
2341 GetProcessMemoryInfo(proc, &memcounters,
sizeof(memcounters));
2342 return memcounters.PeakPagefileUsage;
2381 fprintf(stderr,
"At least one output file must be specified\n");
2391 printf(
"bench: utime=%0.3fs maxrss=%ikB\n", ti / 1000000.0, maxrss);