40 #define VALIDATE_INDEX_TS_THRESH 2500 42 #define RESYNC_BUFFER_SIZE (1<<20) 96 d[3] < 5 && d[5] == 0 &&
99 int is_live = !memcmp(d + offset + 40,
"NGINX RTMP", 10);
204 switch (flv_codecid) {
207 codec_id = bits_per_coded_sample == 8
216 codec_id = bits_per_coded_sample == 8
246 switch (flv_codecid) {
310 switch (flv_codecid) {
329 int flv_codecid,
int read)
334 switch (flv_codecid) {
389 if (length >= buffsize) {
408 unsigned int timeslen = 0, fileposlen = 0,
i;
410 int64_t *times =
NULL;
427 int64_t **current_array;
428 unsigned int arraylen;
439 current_array = ×
444 fileposlen = arraylen;
450 if (!(*current_array =
av_mallocz(
sizeof(**current_array) * arraylen))) {
455 for (
i = 0;
i < arraylen &&
avio_tell(ioc) < max_pos - 1;
i++) {
460 if (times && filepositions) {
468 if (timeslen == fileposlen && fileposlen>1 && max_pos <= filepositions[0]) {
469 for (
i = 0;
i <
FFMIN(2,fileposlen);
i++) {
478 filepositions =
NULL;
560 av_log(s,
AV_LOG_ERROR,
"Missing AMF_END_OF_OBJECT in AMF_DATA_TYPE_MIXEDARRAY, found %d\n", v);
567 unsigned int arraylen,
i;
570 for (i = 0; i < arraylen &&
avio_tell(ioc) < max_pos - 1; i++)
594 if (!strcmp(key,
"duration"))
596 else if (!strcmp(key,
"videodatarate") &&
597 0 <= (
int)(num_val * 1024.0))
599 else if (!strcmp(key,
"audiodatarate") &&
600 0 <= (
int)(num_val * 1024.0))
602 else if (!strcmp(key,
"datastream")) {
607 }
else if (!strcmp(key,
"framerate")) {
612 if (!strcmp(key,
"videocodecid") && vpar) {
616 }
else if (!strcmp(key,
"audiocodecid") && apar) {
619 }
else if (!strcmp(key,
"audiosamplerate") && apar) {
621 }
else if (!strcmp(key,
"audiosamplesize") && apar) {
623 }
else if (!strcmp(key,
"stereo") && apar) {
628 }
else if (!strcmp(key,
"width") && vpar) {
629 vpar->
width = num_val;
630 }
else if (!strcmp(key,
"height") && vpar) {
636 if (!strcmp(key,
"encoder")) {
638 if (1 == sscanf(str_val,
"Open Broadcaster Software v0.%d", &version)) {
639 if (version > 0 && version <= 655)
642 }
else if (!strcmp(key,
"metadatacreator")) {
643 if ( !strcmp (str_val,
"MEGA")
644 || !strncmp(str_val,
"FlixEngine", 10))
651 ((!apar && !strcmp(key,
"audiocodecid")) ||
652 (!vpar && !strcmp(key,
"videocodecid"))))
655 if ((!strcmp(key,
"duration") ||
656 !strcmp(key,
"filesize") ||
657 !strcmp(key,
"width") ||
658 !strcmp(key,
"height") ||
659 !strcmp(key,
"videodatarate") ||
660 !strcmp(key,
"framerate") ||
661 !strcmp(key,
"videocodecid") ||
662 !strcmp(key,
"audiodatarate") ||
663 !strcmp(key,
"audiosamplerate") ||
664 !strcmp(key,
"audiosamplesize") ||
665 !strcmp(key,
"stereo") ||
666 !strcmp(key,
"audiocodecid") ||
672 av_strlcpy(str_val, num_val > 0 ?
"true" :
"false",
676 snprintf(str_val,
sizeof(str_val),
"%.f", num_val);
686 strftime(datestr,
sizeof(datestr),
"%a, %d %b %Y %H:%M:%S %z", &t);
695 #define TYPE_ONTEXTDATA 1 696 #define TYPE_ONCAPTION 2 697 #define TYPE_ONCAPTIONINFO 3 698 #define TYPE_UNKNOWN 9 704 AVStream *stream, *astream, *vstream;
721 if (!strcmp(buffer,
"onTextData"))
724 if (!strcmp(buffer,
"onCaption"))
727 if (!strcmp(buffer,
"onCaptionInfo"))
730 if (strcmp(buffer,
"onMetaData") && strcmp(buffer,
"onCuePoint") && strcmp(buffer,
"|RtmpSampleAccess")) {
762 int pre_tag_size = 0;
785 av_log(s,
AV_LOG_WARNING,
"Read FLV header error, input file is not a standard flv format, first PreviousTagSize0 always is 0\n");
838 "Found invalid index entries, clearing the index.\n");
852 int nb = -1,
ret, parse_name = 1;
898 int64_t
dts, int64_t next)
918 while (array || (ret =
amf_get_string(pb, buf,
sizeof(buf))) > 0) {
981 d[3] < 5 && d[5] == 0) {
990 if (lsize2 >= 11 && lsize2 + 8LL <
FFMIN(i, RESYNC_BUFFER_SIZE)) {
993 if (lsize1 >= 11 && lsize1 + 8LL + lsize2 <
FFMIN(i, RESYNC_BUFFER_SIZE)) {
995 if (size1 == lsize1 - 11 && size2 == lsize2 - 11) {
996 avio_seek(s->
pb, pos + i - lsize1 - lsize2 - 8, SEEK_SET);
1012 int64_t next,
pos, meta_pos;
1029 av_log(s,
AV_LOG_TRACE,
"type:%d, size:%d, last:%d, dts:%"PRId64
" pos:%"PRId64
"\n", type, size, last, dts,
avio_tell(s->
pb));
1037 if (pos == validate_pos) {
1045 }
else if (pos > validate_pos) {
1070 if (size > 13 + 1 + 4) {
1074 if (type == 0 && dts == 0 || type < 0) {
1094 "Skipping flv packet: type %d, size %d, flags %d.\n",
1171 if (size > 0 && size < fsize) {
1180 else if (fsize >= 8 && fsize - 8 >= size) {
1182 goto retry_duration;
1192 int bits_per_coded_sample;
1254 "Negative cts, previous timestamps might be wrong.\n");
1256 }
else if (
FFABS(dts - pts) > 1000*60*15) {
1258 "invalid timestamps %"PRId64
" %"PRId64
"\n", dts, pts);
1324 if (last != orig_size + 11 && last != orig_size + 10 &&
1345 int64_t ts,
int flags)
1352 #define OFFSET(x) offsetof(FLVContext, x) 1353 #define VD AV_OPT_FLAG_VIDEO_PARAM | AV_OPT_FLAG_DECODING_PARAM 1378 .extensions =
"flv",
1379 .priv_class = &flv_class,
1398 .extensions =
"flv",
1399 .priv_class = &live_flv_class,
1419 .extensions =
"kux",
1420 .priv_class = &kux_class,
discard all frames except keyframes
#define AVERROR_INVALIDDATA
Invalid data found when processing input.
int64_t avio_size(AVIOContext *s)
Get the filesize.
#define AV_OPT_FLAG_EXPORT
The option is intended for exporting values to the caller.
int av_add_index_entry(AVStream *st, int64_t pos, int64_t timestamp, int size, int distance, int flags)
Add an index entry into a sorted list.
#define AV_LOG_WARNING
Something somehow does not look correct.
#define LIBAVUTIL_VERSION_INT
int64_t pos
byte position in stream, -1 if unknown
#define avpriv_request_sample(...)
static int read_seek(AVFormatContext *ctx, int stream_index, int64_t timestamp, int flags)
enum AVCodecID codec_id
Specific type of the encoded data (the codec used).
int index
stream index in AVFormatContext
static const int32_t max_pos[4]
Size of the MP-MLQ fixed excitation codebooks.
int64_t avio_seek(AVIOContext *s, int64_t offset, int whence)
fseek() equivalent for AVIOContext.
const char * av_default_item_name(void *ptr)
Return the context name.
int trust_datasize
trust data size of FLVTag
enum AVMediaType codec_type
int event_flags
Flags indicating events happening on the file, a combination of AVFMT_EVENT_FLAG_*.
int64_t avio_skip(AVIOContext *s, int64_t offset)
Skip given number of bytes forward.
void * av_mallocz(size_t size)
Allocate a memory block with alignment suitable for all memory accesses (including vectors if availab...
#define AV_CH_LAYOUT_STEREO
unsigned int avio_rb16(AVIOContext *s)
int ctx_flags
Flags signalling stream properties.
This struct describes the properties of an encoded stream.
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
#define av_assert0(cond)
assert() equivalent, that is always enabled.
static av_always_inline double av_int2double(uint64_t i)
Reinterpret a 64-bit integer as a double.
Opaque data information usually continuous.
#define AV_LOG_TRACE
Extremely verbose debugging, useful for libav* development.
unsigned int avio_rb32(AVIOContext *s)
it s the only field you need to keep assuming you have a context There is some magic you don t need to care about around this just let it vf offset
int wrong_dts
wrong dts due to negative cts
enum AVStreamParseType need_parsing
AVStream * avformat_new_stream(AVFormatContext *s, const AVCodec *c)
Add a new stream to a media file.
uint64_t_TMPL AV_WL64 unsigned int_TMPL AV_WL32 unsigned int_TMPL AV_WL24 unsigned int_TMPL AV_WL16 uint64_t_TMPL AV_WB64 unsigned int_TMPL AV_RB32
AVStream ** streams
A list of all streams in the file.
AVDictionaryEntry * av_dict_get(const AVDictionary *m, const char *key, const AVDictionaryEntry *prev, int flags)
Get a dictionary entry with matching key.
int flags
Flags modifying the (de)muxer behaviour.
#define AVERROR_EOF
End of file.
static av_cold int read_close(AVFormatContext *ctx)
uint64_t avio_rb64(AVIOContext *s)
static av_always_inline int64_t avio_tell(AVIOContext *s)
ftell() equivalent for AVIOContext.
int trust_metadata
configure streams according onMetaData
enum AVCodecID video_codec_id
Forced video codec_id.
uint64_t channel_layout
Audio only.
int avio_read(AVIOContext *s, unsigned char *buf, int size)
Read size bytes from AVIOContext into buf.
int64_t bit_rate
The average bitrate of the encoded data (in bits per second).
#define AV_PKT_FLAG_KEY
The packet contains a keyframe.
void avcodec_parameters_free(AVCodecParameters **par)
Free an AVCodecParameters instance and everything associated with it and write NULL to the supplied p...
AVCodecID
Identify the syntax and semantics of the bitstream.
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
AVDictionary * metadata
Metadata that applies to the whole file.
discard all bidirectional frames
#define NULL_IF_CONFIG_SMALL(x)
Return NULL if CONFIG_SMALL is true, otherwise the argument without modification. ...
ff_const59 struct AVInputFormat * iformat
The input container format.
#define AV_LOG_DEBUG
Stuff which is only useful for libav* developers.
preferred ID for decoding MPEG audio layer 1, 2 or 3
enum AVMediaType codec_type
General type of the encoded data.
int64_t * keyframe_filepositions
AVRational avg_frame_rate
Average framerate.
FLVFileposition * filepositions
uint8_t * new_extradata[FLV_STREAM_TYPE_NB]
size_t av_strlcpy(char *dst, const char *src, size_t size)
Copy the string src to dst, but no more than size - 1 bytes, and null-terminate dst.
uint8_t resync_buffer[2 *RESYNC_BUFFER_SIZE]
int flags
A combination of AV_PKT_FLAG values.
int extradata_size
Size of the extradata content in bytes.
int avio_r8(AVIOContext *s)
int buf_size
Size of buf except extra allocated bytes.
unsigned char * buf
Buffer must have AVPROBE_PADDING_SIZE of extra allocated bytes filled with zero.
int last_keyframe_stream_index
AVIndexEntry * index_entries
Only used if the format does not support seeking natively.
unsigned int nb_streams
Number of elements in AVFormatContext.streams.
int seekable
A combination of AVIO_SEEKABLE_ flags or 0 when the stream is not seekable.
audio channel layout utility functions
unsigned int avio_rb24(AVIOContext *s)
#define AV_TIME_BASE
Internal time base represented as integer.
int dump_full_metadata
Dump full metadata of the onMetadata.
enum AVCodecID audio_codec_id
Forced audio codec_id.
int new_extradata_size[FLV_STREAM_TYPE_NB]
#define FFABS(a)
Absolute value, Note, INT_MIN / INT64_MIN result in undefined behavior as they are not representable ...
static int read_header(FFV1Context *f)
#define AVERROR_PATCHWELCOME
Not yet implemented in FFmpeg, patches welcome.
static int read_packet(void *opaque, uint8_t *buf, int buf_size)
#define AVIO_SEEKABLE_NORMAL
Seeking works like for a local file.
The AV_PKT_DATA_NEW_EXTRADATA is used to notify the codec or the format that the extradata buffer was...
AVStreamInternal * internal
An opaque field for libavformat internal usage.
uint64_t_TMPL AV_WL64 unsigned int_TMPL AV_WL32 unsigned int_TMPL AV_WL24 unsigned int_TMPL AV_WL16 uint64_t_TMPL AV_WB64 unsigned int_TMPL AV_WB32 unsigned int_TMPL AV_RB24
AVIOContext * pb
I/O context.
void av_packet_unref(AVPacket *pkt)
Wipe the packet.
int av_dict_set(AVDictionary **pm, const char *key, const char *value, int flags)
Set the given entry in *pm, overwriting an existing entry.
Describe the class of an AVClass context structure.
Rational number (pair of numerator and denominator).
FF_ENABLE_DEPRECATION_WARNINGS int av_packet_add_side_data(AVPacket *pkt, enum AVPacketSideDataType type, uint8_t *data, size_t size)
Wrap an existing array as a packet side data.
int need_context_update
Whether the internal avctx needs to be updated from codecpar (after a late change to codecpar) ...
This structure contains the data a format has to probe a file.
int64_t start_time
Position of the first frame of the component, in AV_TIME_BASE fractional seconds. ...
AVRational av_d2q(double d, int max)
Convert a double precision floating point number to a rational.
int sample_rate
Audio only.
struct FLVContext::@255 validate_index[2]
AVCodecParameters * avcodec_parameters_alloc(void)
Allocate a new AVCodecParameters and set its fields to default values (unknown/invalid/0).
#define AV_INPUT_BUFFER_PADDING_SIZE
Required number of additionally allocated bytes at the end of the input bitstream for decoding...
int64_t avio_seek_time(AVIOContext *h, int stream_index, int64_t timestamp, int flags)
Seek to a given timestamp relative to some component stream.
int eof_reached
true if was unable to read due to error or eof
void * priv_data
Format private data.
#define AV_OPT_FLAG_READONLY
The option may not be set through the AVOptions API, only read.
int bits_per_coded_sample
The number of bits per sample in the codedwords.
uint8_t * extradata
Extra binary data needed for initializing the decoder, codec-dependent.
int64_t dts
Decompression timestamp in AVStream->time_base units; the time at which the packet is decompressed...
int64_t duration
Duration of the stream, in AV_TIME_BASE fractional seconds.
static int array[MAX_W *MAX_W]
AVCodecParameters * codecpar
Codec parameters associated with this stream.
int avio_feof(AVIOContext *s)
Similar to feof() but also returns nonzero on read errors.
uint32_t codec_tag
Additional information about the codec (corresponds to the AVI FOURCC).
static int64_t fsize(FILE *f)
Filter the word “frame” indicates either a video frame or a group of audio as stored in an AVFrame structure Format for each input and each output the list of supported formats For video that means pixel format For audio that means channel sample they are references to shared objects When the negotiation mechanism computes the intersection of the formats supported at each end of a all references to both lists are replaced with a reference to the intersection And when a single format is eventually chosen for a link amongst the remaining all references to the list are updated That means that if a filter requires that its input and output have the same format amongst a supported all it has to do is use a reference to the same list of formats query_formats can leave some formats unset and return AVERROR(EAGAIN) to cause the negotiation mechanism toagain later.That can be used by filters with complex requirements to use the format negotiated on one link to set the formats supported on another.Frame references ownership and permissions
#define AV_CH_LAYOUT_MONO
enum AVDiscard discard
Selects which packets can be discarded at will and do not need to be demuxed.
This structure stores compressed data.
int64_t pts
Presentation timestamp in AVStream->time_base units; the time at which the decompressed packet will b...
#define AV_NOPTS_VALUE
Undefined timestamp value.