FFmpeg
fifo_test.c
Go to the documentation of this file.
1 /*
2  * FIFO test pseudo-muxer
3  * Copyright (c) 2016 Jan Sebechlebsky
4  *
5  * This file is part of FFmpeg.
6  *
7  * FFmpeg is free software; you can redistribute it and/or
8  * modify it under the terms of the GNU Lesser General Public License
9  * as published by the Free Software Foundation; either
10  * version 2.1 of the License, or (at your option) any later version.
11  *
12  * FFmpeg is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15  * GNU Lesser General Public License for more details.
16  *
17  * You should have received a copy of the GNU Lesser General Public License
18  * along with FFmpeg; if not, write to the Free Software * Foundation, Inc.,
19  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
20  */
21 
22 #include <stdlib.h>
23 
24 #include "libavutil/opt.h"
25 #include "libavutil/time.h"
26 
27 #include "avformat.h"
28 #include "url.h"
29 
30 /* Implementation of mock muxer to simulate real muxer failures */
31 
32 #define MAX_TST_PACKETS 128
33 #define SLEEPTIME_50_MS 50000
34 #define SLEEPTIME_10_MS 10000
35 
36 /* Implementation of mock muxer to simulate real muxer failures */
37 
38 /* This is structure of data sent in packets to
39  * failing muxer */
40 typedef struct FailingMuxerPacketData {
41  int ret; /* return value of write_packet call*/
42  int recover_after; /* set ret to zero after this number of recovery attempts */
43  unsigned sleep_time; /* sleep for this long in write_packet to simulate long I/O operation */
45 
46 
47 typedef struct FailingMuxerContext {
48  AVClass *class;
51  /* If non-zero, summary of processed packets will be printed in deinit */
53 
58 
60 {
62  return ctx->write_header_ret;
63 }
64 
66 {
68  int ret = 0;
69  if (!pkt) {
70  ctx->flush_count++;
71  } else {
73 
74  if (!data->recover_after) {
75  data->ret = 0;
76  } else {
77  data->recover_after--;
78  }
79 
80  ret = data->ret;
81 
82  if (data->sleep_time) {
83  int64_t slept = 0;
84  while (slept < data->sleep_time) {
86  return AVERROR_EXIT;
88  slept += SLEEPTIME_10_MS;
89  }
90  }
91 
92  if (!ret) {
93  ctx->pts_written[ctx->pts_written_nr++] = pkt->pts;
95  }
96  }
97  return ret;
98 }
99 
101 {
103  return ctx->write_trailer_ret;
104 }
105 
107 {
108  int i;
110 
111  if (!ctx->print_deinit_summary)
112  return;
113 
114  printf("flush count: %d\n", ctx->flush_count);
115  printf("pts seen nr: %d\n", ctx->pts_written_nr);
116  printf("pts seen: ");
117  for (i = 0; i < ctx->pts_written_nr; ++i ) {
118  printf(i ? ",%d" : "%d", ctx->pts_written[i]);
119  }
120  printf("\n");
121 }
122 #define OFFSET(x) offsetof(FailingMuxerContext, x)
123 static const AVOption options[] = {
124  {"write_header_ret", "write_header() return value", OFFSET(write_header_ret),
125  AV_OPT_TYPE_INT, {.i64 = 0}, INT_MIN, INT_MAX, AV_OPT_FLAG_ENCODING_PARAM},
126  {"write_trailer_ret", "write_trailer() return value", OFFSET(write_trailer_ret),
127  AV_OPT_TYPE_INT, {.i64 = 0}, INT_MIN, INT_MAX, AV_OPT_FLAG_ENCODING_PARAM},
128  {"print_deinit_summary", "print summary when deinitializing muxer", OFFSET(print_deinit_summary),
129  AV_OPT_TYPE_BOOL, {.i64 = 1}, 0, 1, AV_OPT_FLAG_ENCODING_PARAM},
130  {NULL}
131  };
132 
133 static const AVClass failing_muxer_class = {
134  .class_name = "Fifo test muxer",
135  .item_name = av_default_item_name,
136  .option = options,
137  .version = LIBAVUTIL_VERSION_INT,
138 };
139 
141  .name = "fifo_test",
142  .long_name = NULL_IF_CONFIG_SMALL("Fifo test muxer"),
143  .priv_data_size = sizeof(FailingMuxerContext),
147  .deinit = failing_deinit,
148  .priv_class = &failing_muxer_class,
150 };
151 
FailingMuxerContext::print_deinit_summary
int print_deinit_summary
Definition: fifo_test.c:52
FailingMuxerContext::write_trailer_ret
int write_trailer_ret
Definition: fifo_test.c:50
av_packet_unref
void av_packet_unref(AVPacket *pkt)
Wipe the packet.
Definition: avpacket.c:417
AVOutputFormat::name
const char * name
Definition: avformat.h:496
opt.h
FailingMuxerContext::pts_written
int pts_written[MAX_TST_PACKETS]
Definition: fifo_test.c:55
AVPacket::data
uint8_t * data
Definition: packet.h:373
AVOption
AVOption.
Definition: opt.h:247
data
const char data[16]
Definition: mxf.c:143
FailingMuxerPacketData
Definition: fifo_test.c:40
options
static const AVOption options[]
Definition: fifo_test.c:123
AVFormatContext::interrupt_callback
AVIOInterruptCB interrupt_callback
Custom interrupt callbacks for the I/O layer.
Definition: avformat.h:1364
ff_fifo_test_muxer
const AVOutputFormat ff_fifo_test_muxer
Definition: fifo_test.c:140
ff_check_interrupt
int ff_check_interrupt(AVIOInterruptCB *cb)
Check if the user has requested to interrupt a blocking function associated with cb.
Definition: avio.c:658
pkt
AVPacket * pkt
Definition: movenc.c:59
AV_OPT_FLAG_ENCODING_PARAM
#define AV_OPT_FLAG_ENCODING_PARAM
a generic parameter which can be set by the user for muxing or encoding
Definition: opt.h:277
FailingMuxerContext
Definition: fifo_test.c:47
failing_write_trailer
static int failing_write_trailer(AVFormatContext *avf)
Definition: fifo_test.c:100
ctx
AVFormatContext * ctx
Definition: movenc.c:48
av_usleep
int av_usleep(unsigned usec)
Sleep for a period of time.
Definition: time.c:84
if
if(ret)
Definition: filter_design.txt:179
AVFormatContext
Format I/O context.
Definition: avformat.h:1097
LIBAVUTIL_VERSION_INT
#define LIBAVUTIL_VERSION_INT
Definition: version.h:85
AVClass
Describe the class of an AVClass context structure.
Definition: log.h:66
NULL
#define NULL
Definition: coverity.c:32
write_trailer
static int write_trailer(AVFormatContext *s1)
Definition: v4l2enc.c:98
av_default_item_name
const char * av_default_item_name(void *ptr)
Return the context name.
Definition: log.c:235
time.h
FailingMuxerPacketData::sleep_time
unsigned sleep_time
Definition: fifo_test.c:43
OFFSET
#define OFFSET(x)
Definition: fifo_test.c:122
NULL_IF_CONFIG_SMALL
#define NULL_IF_CONFIG_SMALL(x)
Return NULL if CONFIG_SMALL is true, otherwise the argument without modification.
Definition: internal.h:117
AVFMT_ALLOW_FLUSH
#define AVFMT_ALLOW_FLUSH
Format allows flushing.
Definition: avformat.h:476
AVFMT_NOFILE
#define AVFMT_NOFILE
Demuxer will use avio_open, no opened file should be provided by the caller.
Definition: avformat.h:463
printf
printf("static const uint8_t my_array[100] = {\n")
SLEEPTIME_10_MS
#define SLEEPTIME_10_MS
Definition: fifo_test.c:34
write_packet
static void write_packet(OutputFile *of, AVPacket *pkt, OutputStream *ost, int unqueue)
Definition: ffmpeg.c:731
i
int i
Definition: input.c:406
AVOutputFormat
Definition: avformat.h:495
AVPacket::pts
int64_t pts
Presentation timestamp in AVStream->time_base units; the time at which the decompressed packet will b...
Definition: packet.h:366
failing_muxer_class
static const AVClass failing_muxer_class
Definition: fifo_test.c:133
failing_write_packet
static int failing_write_packet(AVFormatContext *avf, AVPacket *pkt)
Definition: fifo_test.c:65
MAX_TST_PACKETS
#define MAX_TST_PACKETS
Definition: fifo_test.c:32
url.h
ret
ret
Definition: filter_design.txt:187
FailingMuxerPacketData::ret
int ret
Definition: fifo_test.c:41
AVClass::class_name
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
Definition: log.h:71
avformat.h
FailingMuxerContext::write_header_ret
int write_header_ret
Definition: fifo_test.c:49
FailingMuxerPacketData::recover_after
int recover_after
Definition: fifo_test.c:42
AV_OPT_TYPE_INT
@ AV_OPT_TYPE_INT
Definition: opt.h:224
AVPacket
This structure stores compressed data.
Definition: packet.h:350
AV_OPT_TYPE_BOOL
@ AV_OPT_TYPE_BOOL
Definition: opt.h:241
failing_write_header
static int failing_write_header(AVFormatContext *avf)
Definition: fifo_test.c:59
FailingMuxerContext::pts_written_nr
int pts_written_nr
Definition: fifo_test.c:56
flags
#define flags(name, subs,...)
Definition: cbs_av1.c:561
AVERROR_EXIT
#define AVERROR_EXIT
Immediate exit was requested; the called function should not be restarted.
Definition: error.h:58
FailingMuxerContext::flush_count
int flush_count
Definition: fifo_test.c:54
write_header
static void write_header(FFV1Context *f)
Definition: ffv1enc.c:347
failing_deinit
static void failing_deinit(AVFormatContext *avf)
Definition: fifo_test.c:106
AVFormatContext::priv_data
void * priv_data
Format private data.
Definition: avformat.h:1125