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) {
353 "%d:%d; previous: %"PRId64
", current: %"PRId64
"; ",
360 "in incorrect timestamps in the output file.\n",
445 picture2 = &picture_tmp;
460 if (picture != picture2)
461 *picture = *picture2;
472 int subtitle_out_max_size = 1024 * 1024;
473 int subtitle_out_size, nb, i;
487 subtitle_out =
av_malloc(subtitle_out_max_size);
498 for (i = 0; i < nb; i++) {
509 subtitle_out_max_size, sub);
510 if (subtitle_out_size < 0) {
516 pkt.
data = subtitle_out;
517 pkt.
size = subtitle_out_size;
536 int ret, format_video_sync;
588 big_picture = *in_picture;
620 *frame_size = pkt.
size;
640 return -10.0 * log(d) / log(10.0);
647 double ti1, bitrate, avg_bitrate;
672 avg_bitrate = (double)(
video_size * 8) / ti1 / 1000.0;
673 fprintf(
vstats_file,
"s_size= %8.0fkB time= %0.3f br= %7.1fkbits/s avg_br= %7.1fkbits/s ",
674 (
double)
video_size / 1024, ti1, bitrate, avg_bitrate);
769 int64_t min_pts = INT64_MAX;
773 int64_t pts = output_streams[i]->
sync_opts;
775 if (!output_streams[i]->
filter || output_streams[i]->finished)
778 pts =
av_rescale_q(pts, output_streams[i]->st->codec->time_base,
782 ost = output_streams[i];
794 }
else if (ret ==
AVERROR(EAGAIN))
808 int frame_number, vid, i;
809 double bitrate, ti1, pts;
810 static int64_t last_time = -1;
811 static int qp_histogram[52];
816 if (!is_last_report) {
820 if (last_time == -1) {
824 if ((cur_time - last_time) < 500000)
830 oc = output_files[0]->
ctx;
835 if (total_size < 0) {
839 "avio_tell() failed: %s\n", errbuf);
848 ost = output_streams[i];
853 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"q=%2.1f ", q);
856 float t = (
av_gettime() - timer_start) / 1000000.0;
859 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"frame=%5d fps=%3d q=%3.1f ",
860 frame_number, (t > 1) ? (
int)(frame_number / t + 0.5) : 0, q);
862 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"L");
868 for (j = 0; j < 32; j++)
869 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"%X", (
int)
lrintf(
log2(qp_histogram[j] + 1)));
873 double error, error_sum = 0;
874 double scale, scale_sum = 0;
875 char type[3] = {
'Y',
'U',
'V' };
876 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"PSNR=");
877 for (j = 0; j < 3; j++) {
878 if (is_last_report) {
879 error = enc->
error[j];
880 scale = enc->
width * enc->
height * 255.0 * 255.0 * frame_number;
889 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"%c:%2.2f ", type[j],
psnr(error / scale));
891 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
"*:%2.2f ",
psnr(error_sum / scale_sum));
897 if ((pts < ti1) && (pts > 0))
903 bitrate = (double)(total_size * 8) / ti1 / 1000.0;
905 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
906 "size=%8.0fkB time=%0.2f bitrate=%6.1fkbits/s",
907 (
double)total_size / 1024, ti1, bitrate);
910 snprintf(buf + strlen(buf),
sizeof(buf) - strlen(buf),
" dup=%d drop=%d",
917 if (is_last_report) {
920 av_log(
NULL,
AV_LOG_INFO,
"video:%1.0fkB audio:%1.0fkB global headers:%1.0fkB muxing overhead %f%%\n",
924 100.0 * (total_size - raw) / raw
937 int stop_encoding = 0;
974 ret = encode(enc, &pkt,
NULL, &got_packet);
1054 opkt.
dts -= ost_tb_start_time;
1091 char layout_name[256];
1108 int i, ret, resample_changed;
1115 if (!*got_output || ret < 0) {
1128 decoded_frame->
pts = pkt->
pts;
1138 if (resample_changed) {
1139 char layout1[64], layout2[64];
1143 "layout for Input Stream #%d.%d\n", ist->
file_index,
1155 "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",
1179 for (i = 0; i < ist->nb_filters; i++)
1188 void *buffer_to_free =
NULL;
1189 int i, ret = 0, resample_changed;
1196 decoded_frame, got_output, pkt);
1197 if (!*got_output || ret < 0) {
1218 if (resample_changed) {
1220 "Input stream #%d:%d frame changed from size:%dx%d fmt:%s to size:%dx%d fmt:%s\n",
1268 &subtitle, got_output, pkt);
1321 "Multiple frames in a packet from stream %d\n", pkt->
stream_index);
1401 avc[i] = output_files[i]->ctx;
1404 printf(
"SDP:\n%s\n", sdp);
1416 snprintf(error, error_len,
"Decoder (codec id %d) not found for input stream #%d:%d",
1442 snprintf(error, error_len,
"Error while opening decoder for input stream #%d:%d",
1481 for (p = kf; *p; p++)
1492 for (i = 0; i < n; i++) {
1493 char *next = strchr(p,
',');
1507 int ret = 0, i, j, k;
1525 oc = output_files[i]->
ctx;
1541 ost = output_streams[i];
1565 if (extra_size > INT_MAX) {
1637 snprintf(error,
sizeof(error),
"Automatic encoder selection "
1638 "failed for output stream #%d:%d. Default encoder for "
1639 "format %s is probably disabled. Please choose an "
1728 snprintf(logfilename,
sizeof(logfilename),
"%s-%d.log",
1732 if (!strcmp(ost->
enc->
name,
"libx264")) {
1736 f = fopen(logfilename,
"wb");
1739 logfilename, strerror(errno));
1745 size_t logbuffer_size;
1760 ost = output_streams[i];
1781 snprintf(error,
sizeof(error),
"Error while opening encoder for output stream #%d:%d - maybe incorrect parameters such as bit_rate, rate, width or height",
1788 "It takes bits/s as argument, not kbits/s\n");
1819 oc = output_files[i]->
ctx;
1823 const char *errbuf_ptr = errbuf;
1826 snprintf(error,
sizeof(error),
"Could not write header for output file #%d (incorrect codec parameters ?): %s", i, errbuf_ptr);
1840 av_dump_format(output_files[i]->ctx, i, output_files[i]->ctx->filename, 1);
1846 ist = input_streams[i];
1853 if (nb_filtergraphs > 1)
1861 ost = output_streams[i];
1873 if (nb_filtergraphs > 1)
1940 int64_t ipts_min = INT64_MAX;
1950 if (ipts < ipts_min) {
1961 static void *input_thread(
void *arg)
1966 while (!transcoding_finished && ret >= 0) {
1991 static void free_input_threads(
void)
1998 transcoding_finished = 1;
2004 if (!f->fifo || f->joined)
2026 static int init_input_threads(
void)
2030 if (nb_input_files == 1)
2073 if (nb_input_files > 1)
2074 return get_input_packet_mt(f, pkt);
2083 if (input_files[i]->eagain)
2092 input_files[i]->eagain = 0;
2144 ist = input_streams[ifile->
ist_index + i];
2170 goto discard_packet;
2174 goto discard_packet;
2194 "timestamp discontinuity %"PRId64
", new offset= %"PRId64
"\n",
2221 int ret, i, need_input = 1;
2225 int64_t timer_start;
2237 if ((ret = init_input_threads()) < 0)
2268 free_input_threads();
2273 ist = input_streams[i];
2285 os = output_files[i]->
ctx;
2294 ost = output_streams[i];
2303 ist = input_streams[i];
2314 free_input_threads();
2317 if (output_streams) {
2319 ost = output_streams[i];
2339 struct rusage rusage;
2341 getrusage(RUSAGE_SELF, &rusage);
2342 return (rusage.ru_utime.tv_sec * 1000000LL) + rusage.ru_utime.tv_usec;
2343 #elif HAVE_GETPROCESSTIMES
2345 FILETIME c, e, k, u;
2346 proc = GetCurrentProcess();
2347 GetProcessTimes(proc, &c, &e, &k, &u);
2348 return ((int64_t) u.dwHighDateTime << 32 | u.dwLowDateTime) / 10;
2356 #if HAVE_GETRUSAGE && HAVE_STRUCT_RUSAGE_RU_MAXRSS
2357 struct rusage rusage;
2358 getrusage(RUSAGE_SELF, &rusage);
2359 return (int64_t)rusage.ru_maxrss * 1024;
2360 #elif HAVE_GETPROCESSMEMORYINFO
2362 PROCESS_MEMORY_COUNTERS memcounters;
2363 proc = GetCurrentProcess();
2364 memcounters.cb =
sizeof(memcounters);
2365 GetProcessMemoryInfo(proc, &memcounters,
sizeof(memcounters));
2366 return memcounters.PeakPagefileUsage;
2405 fprintf(stderr,
"At least one output file must be specified\n");
2415 printf(
"bench: utime=%0.3fs maxrss=%ikB\n", ti / 1000000.0, maxrss);