FFmpeg  4.0
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 #include "libavutil/avassert.h"
27 
28 #include "avformat.h"
29 #include "url.h"
30 
31 /* Implementation of mock muxer to simulate real muxer failures */
32 
33 #define MAX_TST_PACKETS 128
34 #define SLEEPTIME_50_MS 50000
35 #define SLEEPTIME_10_MS 10000
36 
37 /* Implementation of mock muxer to simulate real muxer failures */
38 
39 /* This is structure of data sent in packets to
40  * failing muxer */
41 typedef struct FailingMuxerPacketData {
42  int ret; /* return value of write_packet call*/
43  int recover_after; /* set ret to zero after this number of recovery attempts */
44  unsigned sleep_time; /* sleep for this long in write_packet to simulate long I/O operation */
46 
47 
48 typedef struct FailingMuxerContext {
49  AVClass *class;
52  /* If non-zero, summary of processed packets will be printed in deinit */
54 
56  int pts_written[MAX_TST_PACKETS];
59 
61 {
63  return ctx->write_header_ret;
64 }
65 
67 {
69  int ret = 0;
70  if (!pkt) {
71  ctx->flush_count++;
72  } else {
74 
75  if (!data->recover_after) {
76  data->ret = 0;
77  } else {
78  data->recover_after--;
79  }
80 
81  ret = data->ret;
82 
83  if (data->sleep_time) {
84  int64_t slept = 0;
85  while (slept < data->sleep_time) {
87  return AVERROR_EXIT;
89  slept += SLEEPTIME_10_MS;
90  }
91  }
92 
93  if (!ret) {
94  ctx->pts_written[ctx->pts_written_nr++] = pkt->pts;
95  av_packet_unref(pkt);
96  }
97  }
98  return ret;
99 }
100 
102 {
104  return ctx->write_trailer_ret;
105 }
106 
108 {
109  int i;
111 
112  if (!ctx->print_deinit_summary)
113  return;
114 
115  printf("flush count: %d\n", ctx->flush_count);
116  printf("pts seen nr: %d\n", ctx->pts_written_nr);
117  printf("pts seen: ");
118  for (i = 0; i < ctx->pts_written_nr; ++i ) {
119  printf(i ? ",%d" : "%d", ctx->pts_written[i]);
120  }
121  printf("\n");
122 }
123 #define OFFSET(x) offsetof(FailingMuxerContext, x)
124 static const AVOption options[] = {
125  {"write_header_ret", "write_header() return value", OFFSET(write_header_ret),
126  AV_OPT_TYPE_INT, {.i64 = 0}, INT_MIN, INT_MAX, AV_OPT_FLAG_ENCODING_PARAM},
127  {"write_trailer_ret", "write_trailer() return value", OFFSET(write_trailer_ret),
128  AV_OPT_TYPE_INT, {.i64 = 0}, INT_MIN, INT_MAX, AV_OPT_FLAG_ENCODING_PARAM},
129  {"print_deinit_summary", "print summary when deinitializing muxer", OFFSET(print_deinit_summary),
130  AV_OPT_TYPE_BOOL, {.i64 = 1}, 0, 1, AV_OPT_FLAG_ENCODING_PARAM},
131  {NULL}
132  };
133 
134 static const AVClass failing_muxer_class = {
135  .class_name = "Fifo test muxer",
136  .item_name = av_default_item_name,
137  .option = options,
138  .version = LIBAVUTIL_VERSION_INT,
139 };
140 
142  .name = "fifo_test",
143  .long_name = NULL_IF_CONFIG_SMALL("Fifo test muxer"),
144  .priv_data_size = sizeof(FailingMuxerContext),
148  .deinit = failing_deinit,
149  .priv_class = &failing_muxer_class,
151 };
152 
static void write_packet(OutputFile *of, AVPacket *pkt, OutputStream *ost, int unqueue)
Definition: ffmpeg.c:679
#define NULL
Definition: coverity.c:32
#define MAX_TST_PACKETS
Definition: fifo_test.c:33
AVIOInterruptCB interrupt_callback
Custom interrupt callbacks for the I/O layer.
Definition: avformat.h:1618
AVOption.
Definition: opt.h:246
#define LIBAVUTIL_VERSION_INT
Definition: version.h:85
const char * av_default_item_name(void *ptr)
Return the context name.
Definition: log.c:191
int av_usleep(unsigned usec)
Sleep for a period of time.
Definition: time.c:84
static AVPacket pkt
#define AVFMT_ALLOW_FLUSH
Format allows flushing.
Definition: avformat.h:478
Format I/O context.
Definition: avformat.h:1342
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:72
int pts_written[MAX_TST_PACKETS]
Definition: fifo_test.c:56
static const AVOption options[]
Definition: fifo_test.c:124
AVOptions.
static const AVClass failing_muxer_class
Definition: fifo_test.c:134
const char data[16]
Definition: mxf.c:90
uint8_t * data
Definition: avcodec.h:1430
static int flags
Definition: log.c:55
#define SLEEPTIME_10_MS
Definition: fifo_test.c:35
#define AV_OPT_FLAG_ENCODING_PARAM
a generic parameter which can be set by the user for muxing or encoding
Definition: opt.h:276
static int failing_write_trailer(AVFormatContext *avf)
Definition: fifo_test.c:101
#define NULL_IF_CONFIG_SMALL(x)
Return NULL if CONFIG_SMALL is true, otherwise the argument without modification. ...
Definition: internal.h:186
simple assert() macros that are a bit more flexible than ISO C assert().
static int failing_write_header(AVFormatContext *avf)
Definition: fifo_test.c:60
static int write_trailer(AVFormatContext *s1)
Definition: v4l2enc.c:94
const char * name
Definition: avformat.h:507
AVFormatContext * ctx
Definition: movenc.c:48
#define AVERROR_EXIT
Immediate exit was requested; the called function should not be restarted.
Definition: error.h:56
if(ret< 0)
Definition: vf_mcdeint.c:279
int ff_check_interrupt(AVIOInterruptCB *cb)
Check if the user has requested to interrupt a blocking function associated with cb.
Definition: avio.c:664
void av_packet_unref(AVPacket *pkt)
Wipe the packet.
Definition: avpacket.c:592
static int failing_write_packet(AVFormatContext *avf, AVPacket *pkt)
Definition: fifo_test.c:66
Describe the class of an AVClass context structure.
Definition: log.h:67
static void failing_deinit(AVFormatContext *avf)
Definition: fifo_test.c:107
AVOutputFormat ff_fifo_test_muxer
Definition: fifo_test.c:141
Main libavformat public API header.
#define AVFMT_NOFILE
Demuxer will use avio_open, no opened file should be provided by the caller.
Definition: avformat.h:465
void * priv_data
Format private data.
Definition: avformat.h:1370
static void write_header(FFV1Context *f)
Definition: ffv1enc.c:337
unbuffered private I/O API
#define OFFSET(x)
Definition: fifo_test.c:123
This structure stores compressed data.
Definition: avcodec.h:1407
int64_t pts
Presentation timestamp in AVStream->time_base units; the time at which the decompressed packet will b...
Definition: avcodec.h:1423