stream 1407 applications/mp42ts/main.c GF_ESIStream *stream; stream 1417 applications/mp42ts/main.c GF_SAFEALLOC(stream, GF_ESIStream); stream 1418 applications/mp42ts/main.c if (!stream) { stream 1423 applications/mp42ts/main.c stream->rap = 1; stream 1426 applications/mp42ts/main.c ifce->input_udta = stream; stream 2603 applications/mp42ts/main.c GF_M2TS_Mux_Stream *stream; stream 2610 applications/mp42ts/main.c stream = gf_m2ts_program_stream_add(program, &sources[i].streams[j], cur_pid+j+1, (sources[i].pcr_idx==j) ? 1 : 0, force_pes_mode); stream 2611 applications/mp42ts/main.c if (split_rap && (sources[i].streams[j].stream_type==GF_STREAM_VISUAL)) stream->start_pes_at_rap = 1; stream 3088 applications/mp4box/filedump.c if (gf_list_count(ts->programs)>1 && pck->stream->program->number != dumper->prog_number) stream 3094 applications/mp4box/filedump.c if (gf_list_count(ts->programs)>1 && pck->stream->program->number != dumper->prog_number) stream 3099 applications/mp4box/filedump.c GF_M2TS_PES *pes = pck->stream; stream 3118 applications/mp4box/filedump.c fprintf(dumper->timestamps_info_file, "%u\t%d\t", pck->stream->pes_start_packet_number, pck->stream->pid); stream 3134 applications/mp4box/filedump.c if (dumper->has_seen_pat && dumper->pes_out && (dumper->dump_pid == pck->stream->pid)) { stream 3140 applications/mp4box/filedump.c if (gf_list_count(ts->programs)>1 && pck->stream->program->number != dumper->prog_number) stream 3143 applications/mp4box/filedump.c fprintf(dumper->timestamps_info_file, "%u\t%d\t%f\t\t\t\t%d\n", pck->stream->program->last_pcr_value_pck_number, pck->stream->pid, pck->PTS / (300*90000.0), (pck->flags & GF_M2TS_PES_PCK_DISCONTINUITY ? 1 : 0)); stream 3150 applications/mp4box/filedump.c if (dumper->pes_out && (dumper->dump_pid == sl_pck->stream->pid)) { stream 3153 applications/mp4box/filedump.c if (sl_pck->stream->mpeg4_es_id) { stream 3154 applications/mp4box/filedump.c GF_ESD *esd = ((GF_M2TS_PES*)sl_pck->stream)->esd; stream 161 applications/osmozilla/osmo_npapi.cpp NPError NPOsmozilla_NewStream(NPP instance, NPMIMEType type, NPStream* stream, NPBool seekable, uint16_t *stype) stream 171 applications/osmozilla/osmo_npapi.cpp Osmozilla_ConnectTo(osmozilla, stream->url); stream 176 applications/osmozilla/osmo_npapi.cpp NPINT32 NPOsmozilla_WriteReady (NPP instance, NPStream *stream) stream 181 applications/osmozilla/osmo_npapi.cpp NPINT32 NPOsmozilla_Write (NPP instance, NPStream *stream, NPINT32 offset, NPINT32 len, void *buffer) stream 186 applications/osmozilla/osmo_npapi.cpp NPError NPOsmozilla_DestroyStream (NPP instance, NPStream *stream, NPError reason) stream 191 applications/osmozilla/osmo_npapi.cpp void NPOsmozilla_StreamAsFile (NPP instance, NPStream* stream, const char* fname) stream 89 applications/osmozilla/osmo_npapi.h NPError NPOsmozilla_NewStream(NPP instance, NPMIMEType type, NPStream* stream, NPBool seekable, uint16_t* stype); stream 90 applications/osmozilla/osmo_npapi.h NPError NPOsmozilla_DestroyStream(NPP instance, NPStream* stream, NPError reason); stream 91 applications/osmozilla/osmo_npapi.h NPINT32 NPOsmozilla_WriteReady(NPP instance, NPStream* stream); stream 92 applications/osmozilla/osmo_npapi.h NPINT32 NPOsmozilla_Write(NPP instance, NPStream* stream, NPINT32 offset, NPINT32 len, void* buffer); stream 93 applications/osmozilla/osmo_npapi.h void NPOsmozilla_StreamAsFile(NPP instance, NPStream* stream, const char* fname); stream 34 applications/testapps/mpeg2ts/main.c if (dest && (dump_pid == pck->stream->pid)) { stream 51 applications/testapps/ts2udp/main.c sender->first_pcr = pck->stream->program->last_pcr_value; stream 53 applications/testapps/ts2udp/main.c sender->pcr = pck->stream->program->last_pcr_value; stream 521 extra_lib/include/ffmpeg_android/libavformat/avformat.h void (*get_output_timestamp)(struct AVFormatContext *s, int stream, stream 1852 extra_lib/include/ffmpeg_android/libavformat/avformat.h uint8_t *av_stream_get_side_data(AVStream *stream, stream 2397 extra_lib/include/ffmpeg_android/libavformat/avformat.h int av_get_output_timestamp(struct AVFormatContext *s, int stream, stream 2678 extra_lib/include/ffmpeg_android/libavformat/avformat.h AVRational av_guess_sample_aspect_ratio(AVFormatContext *format, AVStream *stream, AVFrame *frame); stream 2688 extra_lib/include/ffmpeg_android/libavformat/avformat.h AVRational av_guess_frame_rate(AVFormatContext *ctx, AVStream *stream, AVFrame *frame); stream 924 extra_lib/include/freetype/freetype/freetype.h FT_Stream stream; stream 1696 extra_lib/include/freetype/freetype/freetype.h FT_Stream stream; stream 89 extra_lib/include/freetype/freetype/ftgzip.h FT_Stream_OpenGzip( FT_Stream stream, stream 84 extra_lib/include/freetype/freetype/ftsysio.h typedef FT_ULong (*FT_Stream_ReadFunc)( FT_Stream stream, stream 103 extra_lib/include/freetype/freetype/ftsysio.h typedef FT_Error (*FT_Stream_SeekFunc)( FT_Stream stream, stream 223 extra_lib/include/freetype/freetype/ftsystem.h (*FT_Stream_IoFunc)( FT_Stream stream, stream 241 extra_lib/include/freetype/freetype/ftsystem.h (*FT_Stream_CloseFunc)( FT_Stream stream ); stream 55 extra_lib/include/freetype/freetype/internal/cfftypes.h FT_Stream stream; stream 208 extra_lib/include/freetype/freetype/internal/cfftypes.h FT_Stream stream; stream 31 extra_lib/include/freetype/freetype/internal/ftdriver.h (*FT_Face_InitFunc)( FT_Stream stream, stream 91 extra_lib/include/freetype/freetype/internal/ftdriver.h FT_Stream stream ); stream 498 extra_lib/include/freetype/freetype/internal/ftobjs.h #define FT_FACE_STREAM( x ) FT_FACE( x )->stream stream 272 extra_lib/include/freetype/freetype/internal/ftstream.h #define FT_GET_MACRO( func, type ) ( (type)func( stream ) ) stream 290 extra_lib/include/freetype/freetype/internal/ftstream.h ( var = (type)func( stream, &error ), \ stream 312 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_Open( FT_Stream stream, stream 320 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_OpenMemory( FT_Stream stream, stream 326 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_Close( FT_Stream stream ); stream 331 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_Seek( FT_Stream stream, stream 336 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_Skip( FT_Stream stream, stream 341 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_Pos( FT_Stream stream ); stream 346 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_Read( FT_Stream stream, stream 352 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ReadAt( FT_Stream stream, stream 366 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_EnterFrame( FT_Stream stream, stream 371 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ExitFrame( FT_Stream stream ); stream 383 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ExtractFrame( FT_Stream stream, stream 389 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ReleaseFrame( FT_Stream stream, stream 394 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_GetChar( FT_Stream stream ); stream 398 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_GetShort( FT_Stream stream ); stream 402 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_GetOffset( FT_Stream stream ); stream 406 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_GetLong( FT_Stream stream ); stream 410 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_GetShortLE( FT_Stream stream ); stream 414 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_GetLongLE( FT_Stream stream ); stream 419 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ReadChar( FT_Stream stream, stream 424 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ReadShort( FT_Stream stream, stream 429 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ReadOffset( FT_Stream stream, stream 434 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ReadLong( FT_Stream stream, stream 439 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ReadShortLE( FT_Stream stream, stream 444 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ReadLongLE( FT_Stream stream, stream 450 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ReadFields( FT_Stream stream, stream 456 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_Pos( stream ) stream 459 extra_lib/include/freetype/freetype/internal/ftstream.h FT_SET_ERROR( FT_Stream_Seek( stream, position ) ) stream 462 extra_lib/include/freetype/freetype/internal/ftstream.h FT_SET_ERROR( FT_Stream_Skip( stream, distance ) ) stream 465 extra_lib/include/freetype/freetype/internal/ftstream.h FT_SET_ERROR( FT_Stream_Read( stream, \ stream 470 extra_lib/include/freetype/freetype/internal/ftstream.h FT_SET_ERROR( FT_Stream_ReadAt( stream, \ stream 476 extra_lib/include/freetype/freetype/internal/ftstream.h FT_SET_ERROR( FT_Stream_ReadFields( stream, fields, object ) ) stream 480 extra_lib/include/freetype/freetype/internal/ftstream.h FT_SET_ERROR( FT_Stream_EnterFrame( stream, size ) ) stream 483 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ExitFrame( stream ) stream 486 extra_lib/include/freetype/freetype/internal/ftstream.h FT_SET_ERROR( FT_Stream_ExtractFrame( stream, size, \ stream 490 extra_lib/include/freetype/freetype/internal/ftstream.h FT_Stream_ReleaseFrame( stream, (FT_Byte**)&(bytes) ) stream 27 extra_lib/include/freetype/freetype/internal/fttrace.h FT_TRACE_DEF( stream ) /* stream manager (ftstream.c) */ stream 67 extra_lib/include/freetype/freetype/internal/sfnt.h (*TT_Init_Face_Func)( FT_Stream stream, stream 103 extra_lib/include/freetype/freetype/internal/sfnt.h (*TT_Load_Face_Func)( FT_Stream stream, stream 161 extra_lib/include/freetype/freetype/internal/sfnt.h FT_Stream stream, stream 191 extra_lib/include/freetype/freetype/internal/sfnt.h FT_Stream stream, stream 280 extra_lib/include/freetype/freetype/internal/sfnt.h FT_Stream stream, stream 360 extra_lib/include/freetype/freetype/internal/sfnt.h FT_Stream stream, stream 437 extra_lib/include/freetype/freetype/internal/sfnt.h FT_Stream stream ); stream 330 extra_lib/include/freetype/freetype/internal/tttypes.h FT_Stream stream; stream 1195 extra_lib/include/freetype/freetype/internal/tttypes.h FT_Stream stream, stream 1644 extra_lib/include/freetype/freetype/internal/tttypes.h FT_Stream stream; stream 511 extra_lib/include/libavformat/avformat.h void (*get_output_timestamp)(struct AVFormatContext *s, int stream, stream 2229 extra_lib/include/libavformat/avformat.h int av_get_output_timestamp(struct AVFormatContext *s, int stream, stream 2499 extra_lib/include/libavformat/avformat.h AVRational av_guess_sample_aspect_ratio(AVFormatContext *format, AVStream *stream, AVFrame *frame); stream 2509 extra_lib/include/libavformat/avformat.h AVRational av_guess_frame_rate(AVFormatContext *ctx, AVStream *stream, AVFrame *frame); stream 721 extra_lib/include/mad.h # define mad_stream_options(stream, opts) \ stream 722 extra_lib/include/mad.h ((void) ((stream)->options = (opts))) stream 910 extra_lib/include/mad.h struct mad_stream stream; stream 570 extra_lib/include/openssl/bio.h BIO *BIO_new_fp(FILE *stream, int close_flag); stream 56 extra_lib/include/platinum/NptBufferedStreams.h NPT_BufferedInputStream(NPT_InputStreamReference& stream, stream 146 extra_lib/include/platinum/NptFile.h virtual NPT_Result GetInputStream(NPT_InputStreamReference& stream) = 0; stream 147 extra_lib/include/platinum/NptFile.h virtual NPT_Result GetOutputStream(NPT_OutputStreamReference& stream) = 0; stream 195 extra_lib/include/platinum/NptFile.h NPT_Result GetInputStream(NPT_InputStreamReference& stream) { stream 196 extra_lib/include/platinum/NptFile.h return m_Delegate->GetInputStream(stream); stream 198 extra_lib/include/platinum/NptFile.h NPT_Result GetOutputStream(NPT_OutputStreamReference& stream) { stream 199 extra_lib/include/platinum/NptFile.h return m_Delegate->GetOutputStream(stream); stream 161 extra_lib/include/platinum/NptHttp.h NPT_Result Emit(NPT_OutputStream& stream) const; stream 183 extra_lib/include/platinum/NptHttp.h NPT_Result Parse(NPT_BufferedInputStream& stream); stream 184 extra_lib/include/platinum/NptHttp.h NPT_Result Emit(NPT_OutputStream& stream) const; stream 208 extra_lib/include/platinum/NptHttp.h NPT_Result SetInputStream(const NPT_InputStreamReference& stream, stream 213 extra_lib/include/platinum/NptHttp.h NPT_Result GetInputStream(NPT_InputStreamReference& stream); stream 267 extra_lib/include/platinum/NptHttp.h virtual NPT_Result ParseHeaders(NPT_BufferedInputStream& stream); stream 285 extra_lib/include/platinum/NptHttp.h static NPT_Result Parse(NPT_BufferedInputStream& stream, stream 304 extra_lib/include/platinum/NptHttp.h virtual NPT_Result Emit(NPT_OutputStream& stream, bool use_proxy=false) const; stream 318 extra_lib/include/platinum/NptHttp.h static NPT_Result Parse(NPT_BufferedInputStream& stream, stream 334 extra_lib/include/platinum/NptHttp.h virtual NPT_Result Emit(NPT_OutputStream& stream) const; stream 679 extra_lib/include/platinum/NptHttp.h NPT_InputStreamReference& stream, stream 818 extra_lib/include/platinum/NptHttp.h NPT_HttpChunkedInputStream(NPT_BufferedInputStreamReference& stream); stream 844 extra_lib/include/platinum/NptHttp.h NPT_HttpChunkedOutputStream(NPT_OutputStream& stream); stream 133 extra_lib/include/platinum/NptLogging.h NPT_OutputStream& stream, stream 83 extra_lib/include/platinum/NptSerialPort.h virtual NPT_Result GetInputStream(NPT_InputStreamReference& stream) = 0; stream 84 extra_lib/include/platinum/NptSerialPort.h virtual NPT_Result GetOutputStream(NPT_OutputStreamReference& stream) = 0; stream 107 extra_lib/include/platinum/NptSerialPort.h NPT_Result GetInputStream(NPT_InputStreamReference& stream) { stream 108 extra_lib/include/platinum/NptSerialPort.h return m_Delegate->GetInputStream(stream); stream 110 extra_lib/include/platinum/NptSerialPort.h NPT_Result GetOutputStream(NPT_OutputStreamReference& stream) { stream 111 extra_lib/include/platinum/NptSerialPort.h return m_Delegate->GetOutputStream(stream); stream 130 extra_lib/include/platinum/NptSockets.h virtual NPT_Result GetInputStream(NPT_InputStreamReference& stream) = 0; stream 131 extra_lib/include/platinum/NptSockets.h virtual NPT_Result GetOutputStream(NPT_OutputStreamReference& stream) = 0; stream 206 extra_lib/include/platinum/NptSockets.h NPT_Result GetInputStream(NPT_InputStreamReference& stream) { stream 207 extra_lib/include/platinum/NptSockets.h return m_SocketDelegate->GetInputStream(stream); stream 209 extra_lib/include/platinum/NptSockets.h NPT_Result GetOutputStream(NPT_OutputStreamReference& stream) { stream 210 extra_lib/include/platinum/NptSockets.h return m_SocketDelegate->GetOutputStream(stream); stream 208 extra_lib/include/platinum/NptTls.h virtual NPT_Result GetInputStream(NPT_InputStreamReference& stream); stream 209 extra_lib/include/platinum/NptTls.h virtual NPT_Result GetOutputStream(NPT_OutputStreamReference& stream); stream 291 extra_lib/include/platinum/NptXml.h virtual NPT_Result Parse(NPT_InputStream& stream, stream 294 extra_lib/include/platinum/NptXml.h virtual NPT_Result Parse(NPT_InputStream& stream, stream 370 extra_lib/include/platinum/NptXml.h NPT_OutputStream& stream, stream 386 extra_lib/include/platinum/NptXml.h NPT_OutputStream& stream, stream 238 extra_lib/include/platinum/PltAction.h NPT_Result FormatSoapRequest(NPT_OutputStream& stream); stream 244 extra_lib/include/platinum/PltAction.h NPT_Result FormatSoapResponse(NPT_OutputStream& stream); stream 254 extra_lib/include/platinum/PltAction.h NPT_OutputStream& stream); stream 100 extra_lib/include/platinum/PltHttp.h static NPT_Result SetBody(NPT_HttpMessage& message, NPT_InputStreamReference stream, NPT_HttpEntity** entity = NULL); stream 74 extra_lib/include/platinum/PltHttpServer.h NPT_InputStreamReference& stream, stream 76 extra_lib/include/platinum/PltHttpServerTask.h virtual NPT_Result GetInputStream(NPT_InputStreamReference& stream); stream 53 extra_lib/include/platinum/PltMetadataHandler.h virtual NPT_Result Load(NPT_InputStream& stream, stream 56 extra_lib/include/platinum/PltMetadataHandler.h virtual NPT_Result Save(NPT_OutputStream& stream, stream 332 extra_lib/include/platinum/PltSsdp.h NPT_Result GetInputStream(NPT_InputStreamReference& stream); stream 54 extra_lib/include/platinum/PltStreamPump.h virtual NPT_Result Receive(NPT_InputStream& stream, NPT_Size max_bytes_to_read, NPT_Size* bytes_read = 0) = 0; stream 69 extra_lib/include/platinum/PltStreamPump.h virtual NPT_Result Transmit(NPT_OutputStream& stream) = 0; stream 312 extra_lib/include/platinum/PltUtilities.h NPT_StringOutputStreamReference stream(new NPT_StringOutputStream(&xml)); stream 313 extra_lib/include/platinum/PltUtilities.h NPT_CHECK(writer.Serialize(node, *stream, add_header)); stream 320 extra_lib/include/platinum/PltUtilities.h NPT_StringOutputStreamReference stream(new NPT_StringOutputStream(&xml)); stream 321 extra_lib/include/platinum/PltUtilities.h if (NPT_FAILED(writer.Serialize(node, *stream, add_header))) { stream 270 extra_lib/include/platinum/PltXmlHelper.h NPT_StringOutputStreamReference stream(new NPT_StringOutputStream(&xml)); stream 271 extra_lib/include/platinum/PltXmlHelper.h NPT_CHECK(writer.Serialize(node, *stream, add_header)); stream 278 extra_lib/include/platinum/PltXmlHelper.h NPT_StringOutputStreamReference stream(new NPT_StringOutputStream(&xml)); stream 279 extra_lib/include/platinum/PltXmlHelper.h if (NPT_FAILED(writer.Serialize(node, *stream, add_header))) { stream 528 include/gpac/bitstream.h void gf_bs_reassign(GF_BitStream *bs, FILE *stream); stream 644 include/gpac/internal/compositor_dev.h GF_MediaObject *stream; stream 1181 include/gpac/internal/compositor_dev.h GF_MediaObject *stream; stream 3061 include/gpac/internal/isomedia_dev.h FILE *stream; stream 872 include/gpac/mpegts.h GF_M2TS_PES *stream; stream 882 include/gpac/mpegts.h GF_M2TS_ES *stream; stream 1157 include/gpac/mpegts.h u32 (*process)(struct __m2ts_mux *muxer, struct __m2ts_mux_stream *stream); stream 157 include/gpac/scene_manager.h GF_AUContext *gf_sm_stream_au_new(GF_StreamContext *stream, u64 timing, Double time_ms, Bool isRap); stream 115 include/gpac/tools.h size_t gf_fread(void *ptr, size_t size, size_t nmemb, FILE *stream); stream 125 include/gpac/tools.h size_t gf_fwrite(const void *ptr, size_t size, size_t nmemb, FILE *stream); stream 48 modules/aac_in/aac_in.c FILE *stream; stream 251 modules/aac_in/aac_in.c if (!read || !read->stream) return GF_FALSE; stream 252 modules/aac_in/aac_in.c bs = gf_bs_from_file(read->stream, GF_BITSTREAM_READ); stream 276 modules/aac_in/aac_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 429 modules/aac_in/aac_in.c if (read->stream) { stream 492 modules/aac_in/aac_in.c if (read->stream) return; stream 498 modules/aac_in/aac_in.c read->stream = gf_fopen((char *) szCache, "rb"); stream 499 modules/aac_in/aac_in.c if (!read->stream) e = GF_SERVICE_ERROR; stream 511 modules/aac_in/aac_in.c gf_fclose(read->stream); stream 512 modules/aac_in/aac_in.c read->stream = NULL; stream 581 modules/aac_in/aac_in.c if (read->stream) stream 582 modules/aac_in/aac_in.c gf_fclose(read->stream); stream 586 modules/aac_in/aac_in.c read->stream = NULL; stream 636 modules/aac_in/aac_in.c read->stream = gf_fopen(szURL, "rb"); stream 637 modules/aac_in/aac_in.c if (!read->stream) { stream 640 modules/aac_in/aac_in.c gf_fclose(read->stream); stream 641 modules/aac_in/aac_in.c read->stream = NULL; stream 772 modules/aac_in/aac_in.c if (read->stream) gf_fseek(read->stream, 0, SEEK_SET); stream 824 modules/aac_in/aac_in.c if (!read->stream) { stream 829 modules/aac_in/aac_in.c bs = gf_bs_from_file(read->stream, GF_BITSTREAM_READ); stream 833 modules/aac_in/aac_in.c pos = gf_ftell(read->stream); stream 844 modules/aac_in/aac_in.c gf_fclose(read->stream); stream 845 modules/aac_in/aac_in.c read->stream = gf_fopen(param.url_query.next_url, "rb"); stream 854 modules/aac_in/aac_in.c gf_fseek(read->stream, pos, SEEK_SET); stream 39 modules/ac3_in/ac3_in.c FILE *stream; stream 130 modules/ac3_in/ac3_in.c if (!read->stream) return GF_FALSE; stream 131 modules/ac3_in/ac3_in.c bs = gf_bs_from_file(read->stream, GF_BITSTREAM_READ); stream 152 modules/ac3_in/ac3_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 239 modules/ac3_in/ac3_in.c if (read->stream) { stream 292 modules/ac3_in/ac3_in.c if (read->stream) return; stream 298 modules/ac3_in/ac3_in.c read->stream = gf_fopen((char *) szCache, "rb"); stream 299 modules/ac3_in/ac3_in.c if (!read->stream) e = GF_SERVICE_ERROR; stream 311 modules/ac3_in/ac3_in.c gf_fclose(read->stream); stream 312 modules/ac3_in/ac3_in.c read->stream = NULL; stream 368 modules/ac3_in/ac3_in.c read->stream = gf_fopen(szURL, "rb"); stream 369 modules/ac3_in/ac3_in.c if (!read->stream) { stream 372 modules/ac3_in/ac3_in.c gf_fclose(read->stream); stream 373 modules/ac3_in/ac3_in.c read->stream = NULL; stream 384 modules/ac3_in/ac3_in.c if (read->stream) gf_fclose(read->stream); stream 385 modules/ac3_in/ac3_in.c read->stream = NULL; stream 498 modules/ac3_in/ac3_in.c if (read->stream) gf_fseek(read->stream, 0, SEEK_SET); stream 550 modules/ac3_in/ac3_in.c if (!read->stream) { stream 555 modules/ac3_in/ac3_in.c bs = gf_bs_from_file(read->stream, GF_BITSTREAM_READ); stream 559 modules/ac3_in/ac3_in.c pos = gf_ftell(read->stream); stream 567 modules/ac3_in/ac3_in.c gf_fseek(read->stream, pos, SEEK_SET); stream 48 modules/amr_dec/amr_in.c FILE *stream; stream 142 modules/amr_dec/amr_in.c if (!read->stream) return GF_FALSE; stream 147 modules/amr_dec/amr_in.c i = (u32) fread(magic, 1, 20, read->stream); stream 151 modules/amr_dec/amr_in.c fseek(read->stream, 6, SEEK_SET); stream 155 modules/amr_dec/amr_in.c fseek(read->stream, 7, SEEK_SET); stream 160 modules/amr_dec/amr_in.c fseek(read->stream, 6, SEEK_SET); stream 168 modules/amr_dec/amr_in.c fseek(read->stream, 9, SEEK_SET); stream 179 modules/amr_dec/amr_in.c while (!feof(read->stream)) { stream 180 modules/amr_dec/amr_in.c u8 ft = fgetc(read->stream); stream 198 modules/amr_dec/amr_in.c if (size) fseek(read->stream, size, SEEK_CUR); stream 202 modules/amr_dec/amr_in.c fseek(read->stream, read->start_offset, SEEK_SET); stream 216 modules/amr_dec/amr_in.c if (read->stream) { stream 230 modules/amr_dec/amr_in.c if (read->stream) return; stream 236 modules/amr_dec/amr_in.c read->stream = gf_fopen((char *) szCache, "rb"); stream 237 modules/amr_dec/amr_in.c if (!read->stream) e = GF_SERVICE_ERROR; stream 249 modules/amr_dec/amr_in.c gf_fclose(read->stream); stream 250 modules/amr_dec/amr_in.c read->stream = NULL; stream 306 modules/amr_dec/amr_in.c read->stream = gf_fopen(szURL, "rb"); stream 307 modules/amr_dec/amr_in.c if (!read->stream) { stream 310 modules/amr_dec/amr_in.c gf_fclose(read->stream); stream 311 modules/amr_dec/amr_in.c read->stream = NULL; stream 322 modules/amr_dec/amr_in.c if (read->stream) gf_fclose(read->stream); stream 323 modules/amr_dec/amr_in.c read->stream = NULL; stream 419 modules/amr_dec/amr_in.c if (read->stream) fseek(read->stream, read->start_offset, SEEK_SET); stream 467 modules/amr_dec/amr_in.c if (!read->stream) { stream 476 modules/amr_dec/amr_in.c if (feof(read->stream)) { stream 482 modules/amr_dec/amr_in.c toc = fgetc(read->stream); stream 483 modules/amr_dec/amr_in.c if (feof(read->stream)) { stream 513 modules/amr_dec/amr_in.c fseek(read->stream, read->data_size, SEEK_CUR); stream 525 modules/amr_dec/amr_in.c u32 bytes_read = (u32) fread(read->data + 1, read->data_size-1, 1, read->stream); stream 45 modules/img_in/img_in.c FILE *stream; stream 74 modules/img_in/img_in.c GF_BitStream *bs = gf_bs_from_file(read->stream, GF_BITSTREAM_READ); stream 183 modules/img_in/img_in.c if (read->stream) gf_fclose(read->stream); stream 184 modules/img_in/img_in.c read->stream = gf_fopen((char *) szCache, "rb"); stream 185 modules/img_in/img_in.c if (!read->stream) e = GF_SERVICE_ERROR; stream 188 modules/img_in/img_in.c gf_fseek(read->stream, 0, SEEK_END); stream 189 modules/img_in/img_in.c read->data_size = (u32) gf_ftell(read->stream); stream 190 modules/img_in/img_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 243 modules/img_in/img_in.c read->stream = gf_fopen(url, "rb"); stream 244 modules/img_in/img_in.c if (read->stream) { stream 245 modules/img_in/img_in.c gf_fseek(read->stream, 0, SEEK_END); stream 246 modules/img_in/img_in.c read->data_size = (u32) gf_ftell(read->stream); stream 247 modules/img_in/img_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 250 modules/img_in/img_in.c gf_service_connect_ack(serv, NULL, read->stream ? GF_OK : GF_URL_ERROR); stream 251 modules/img_in/img_in.c if (read->stream && read->is_inline) IMG_SetupObject(read); stream 263 modules/img_in/img_in.c if (read->stream) gf_fclose(read->stream); stream 264 modules/img_in/img_in.c read->stream = NULL; stream 384 modules/img_in/img_in.c if (!read->stream) { stream 390 modules/img_in/img_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 392 modules/img_in/img_in.c read->data_size = (u32) fread(read->data, sizeof(char), read->data_size, read->stream); stream 394 modules/img_in/img_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 65 modules/mp3_in/mad_dec.c struct mad_stream stream; stream 79 modules/mp3_in/mad_dec.c mad_stream_finish(&ctx->stream); stream 83 modules/mp3_in/mad_dec.c mad_stream_init(&ctx->stream); stream 113 modules/mp3_in/mad_dec.c mad_stream_finish(&ctx->stream); stream 178 modules/mp3_in/mad_dec.c mad_stream_finish(&ctx->stream); stream 182 modules/mp3_in/mad_dec.c mad_stream_finish(&ctx->stream); stream 244 modules/mp3_in/mad_dec.c mad_stream_buffer(&ctx->stream, ctx->buffer, ctx->len); stream 246 modules/mp3_in/mad_dec.c if (mad_frame_decode(&ctx->frame, &ctx->stream) == -1) { stream 267 modules/mp3_in/mad_dec.c if (ctx->stream.next_frame) { stream 268 modules/mp3_in/mad_dec.c ctx->len = (u32) (&ctx->buffer[ctx->len] - ctx->stream.next_frame); stream 269 modules/mp3_in/mad_dec.c memmove(ctx->buffer, ctx->stream.next_frame, ctx->len); stream 364 modules/mp3_in/mad_dec.c mad_stream_finish(&ctx->stream); stream 40 modules/mp3_in/mp3_in.c FILE *stream; stream 144 modules/mp3_in/mp3_in.c if (!read->stream) return GF_FALSE; stream 152 modules/mp3_in/mp3_in.c pos = fread(id3v2, sizeof(unsigned char), 10, read->stream); stream 162 modules/mp3_in/mp3_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 163 modules/mp3_in/mp3_in.c hdr = gf_mp3_get_next_header(read->stream); stream 167 modules/mp3_in/mp3_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 175 modules/mp3_in/mp3_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 178 modules/mp3_in/mp3_in.c hdr = gf_mp3_get_next_header(read->stream); stream 182 modules/mp3_in/mp3_in.c pos = gf_ftell(read->stream); stream 183 modules/mp3_in/mp3_in.c gf_fseek(read->stream, pos + size - 4, SEEK_SET); stream 185 modules/mp3_in/mp3_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 270 modules/mp3_in/mp3_in.c if (read->stream) { stream 334 modules/mp3_in/mp3_in.c if (read->stream) return; stream 340 modules/mp3_in/mp3_in.c read->stream = gf_fopen((char *) szCache, "rb"); stream 341 modules/mp3_in/mp3_in.c if (!read->stream) e = GF_SERVICE_ERROR; stream 354 modules/mp3_in/mp3_in.c gf_fclose(read->stream); stream 355 modules/mp3_in/mp3_in.c read->stream = NULL; stream 413 modules/mp3_in/mp3_in.c read->stream = gf_fopen(szURL, "rb"); stream 414 modules/mp3_in/mp3_in.c if (!read->stream) { stream 417 modules/mp3_in/mp3_in.c gf_fclose(read->stream); stream 418 modules/mp3_in/mp3_in.c read->stream = NULL; stream 429 modules/mp3_in/mp3_in.c if (read->stream) gf_fclose(read->stream); stream 430 modules/mp3_in/mp3_in.c read->stream = NULL; stream 553 modules/mp3_in/mp3_in.c if (read->stream) gf_fseek(read->stream, 0, SEEK_SET); stream 603 modules/mp3_in/mp3_in.c if (!read->stream) { stream 610 modules/mp3_in/mp3_in.c pos = gf_ftell(read->stream); stream 611 modules/mp3_in/mp3_in.c hdr = gf_mp3_get_next_header(read->stream); stream 617 modules/mp3_in/mp3_in.c gf_fseek(read->stream, pos, SEEK_SET); stream 634 modules/mp3_in/mp3_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 636 modules/mp3_in/mp3_in.c hdr = gf_mp3_get_next_header(read->stream); stream 644 modules/mp3_in/mp3_in.c gf_fseek(read->stream, read->data_size-4, SEEK_CUR); stream 647 modules/mp3_in/mp3_in.c GF_LOG(GF_LOG_DEBUG, GF_LOG_NETWORK, ("[MP3Demux] Seeking to frame size %d - TS %d - file pos %d\n", read->data_size, read->current_time, gf_ftell(read->stream))); stream 651 modules/mp3_in/mp3_in.c GF_LOG(GF_LOG_DEBUG, GF_LOG_NETWORK, ("[MP3Demux] Found new frame size %d - TS %d - file pos %d\n", read->data_size, read->current_time, gf_ftell(read->stream))); stream 661 modules/mp3_in/mp3_in.c if (fread(&read->data[4], 1, read->data_size - 4, read->stream) != read->data_size-4) { stream 665 modules/mp3_in/mp3_in.c gf_fseek(read->stream, pos, SEEK_SET); stream 185 modules/mpegts_in/mpegts_in.c static GF_ESD *MP2TS_GetESD(M2TSIn *m2ts, GF_M2TS_PES *stream, char *dsi, u32 dsi_size) stream 190 modules/mpegts_in/mpegts_in.c esd->ESID = stream->mpeg4_es_id ? stream->mpeg4_es_id : stream->pid; stream 192 modules/mpegts_in/mpegts_in.c switch (stream->stream_type) { stream 247 modules/mpegts_in/mpegts_in.c gf_m2ts_set_pes_framing(stream, GF_M2TS_PES_FRAMING_DEFAULT); stream 277 modules/mpegts_in/mpegts_in.c esd->OCRESID = stream->program->pcr_pid; stream 278 modules/mpegts_in/mpegts_in.c if (stream->pid == stream->program->pcr_pid) { stream 291 modules/mpegts_in/mpegts_in.c static GF_ObjectDescriptor *MP2TS_GetOD(M2TSIn *m2ts, GF_M2TS_PES *stream, char *dsi, u32 dsi_size, u32 *streamType) stream 298 modules/mpegts_in/mpegts_in.c esd = MP2TS_GetESD(m2ts, stream, dsi, dsi_size); stream 301 modules/mpegts_in/mpegts_in.c if (stream->program->is_scalable) stream 310 modules/mpegts_in/mpegts_in.c od->ServiceID = stream->program->number; stream 315 modules/mpegts_in/mpegts_in.c count = gf_list_count(stream->program->streams); stream 317 modules/mpegts_in/mpegts_in.c GF_M2TS_ES *es = (GF_M2TS_ES *)gf_list_get(stream->program->streams, i); stream 337 modules/mpegts_in/mpegts_in.c static void MP2TS_DeclareStream(M2TSIn *m2ts, GF_M2TS_PES *stream, char *dsi, u32 dsi_size) stream 339 modules/mpegts_in/mpegts_in.c GF_ObjectDescriptor *od = MP2TS_GetOD(m2ts, stream, dsi, dsi_size, NULL); stream 412 modules/mpegts_in/mpegts_in.c if (! pck->stream->program->first_dts) return; stream 413 modules/mpegts_in/mpegts_in.c if (!pck->stream->user) return; stream 426 modules/mpegts_in/mpegts_in.c gf_service_send_packet(m2ts->service, pck->stream->user, pck->data, pck->data_len, &slh, GF_OK); stream 436 modules/mpegts_in/mpegts_in.c if (((GF_M2TS_ES*)pck->stream)->slcfg) { stream 437 modules/mpegts_in/mpegts_in.c gf_sl_depacketize(((GF_M2TS_ES*)pck->stream)->slcfg, &SLHeader, pck->data, pck->data_len, &SLHdrLen); stream 441 modules/mpegts_in/mpegts_in.c gf_service_send_packet(m2ts->service, pck->stream->user, pck->data+SLHdrLen, pck->data_len-SLHdrLen, slh, GF_OK); stream 654 modules/mpegts_in/mpegts_in.c if (!pck->stream->first_dts) { stream 655 modules/mpegts_in/mpegts_in.c gf_m2ts_set_pes_framing(pck->stream, GF_M2TS_PES_FRAMING_SKIP_NO_RESET); stream 656 modules/mpegts_in/mpegts_in.c MP2TS_DeclareStream(m2ts, pck->stream, pck->data, pck->data_len); stream 662 modules/mpegts_in/mpegts_in.c pck->stream->first_dts=1; stream 673 modules/mpegts_in/mpegts_in.c if (((GF_M2TS_PES_PCK *) param)->stream && ((GF_M2TS_PES_PCK *) param)->stream->user) { stream 697 modules/mpegts_in/mpegts_in.c gf_service_send_packet(m2ts->service, ((GF_M2TS_PES_PCK *) param)->stream->user, NULL, 0, &slh, GF_OK); stream 699 modules/mpegts_in/mpegts_in.c if ( m2ts->map_media_time_on_prog_id && !ts->start_range && (m2ts->map_media_time_on_prog_id==((GF_M2TS_PES_PCK *) param)->stream->program->number)) { stream 705 modules/mpegts_in/mpegts_in.c com.base.on_channel = ((GF_M2TS_PES_PCK *) param)->stream->user; stream 712 modules/mpegts_in/mpegts_in.c if (pck->stream && pck->stream->program) pck->stream->program->first_dts = 1; stream 729 modules/mpegts_in/mpegts_in.c if (pck->stream) { stream 733 modules/mpegts_in/mpegts_in.c m2ts->regulation_pcr_pid = pck->stream->pid; stream 734 modules/mpegts_in/mpegts_in.c } else if (m2ts->regulation_pcr_pid != pck->stream->pid) { stream 822 modules/mpegts_in/mpegts_in.c GF_M2TS_ES * stream = gf_list_get(prog->streams, j); stream 823 modules/mpegts_in/mpegts_in.c if (stream->user) { stream 824 modules/mpegts_in/mpegts_in.c com.base.on_channel = stream->user; stream 850 modules/mpegts_in/mpegts_in.c GF_M2TS_ES * stream = gf_list_get(prog->streams, j); stream 851 modules/mpegts_in/mpegts_in.c if (stream->user) { stream 852 modules/mpegts_in/mpegts_in.c com.base.on_channel = stream->user; stream 526 modules/platinum/GPACFileMediaServer.cpp NPT_InputStreamReference stream(memory_stream); stream 528 modules/platinum/GPACFileMediaServer.cpp if (NPT_FAILED(result = stream->GetSize(total_len)) ) { stream 567 modules/platinum/GPACFileMediaServer.cpp start_offset > end_offset || NPT_FAILED(stream->Seek(start_offset))) { stream 572 modules/platinum/GPACFileMediaServer.cpp entity->SetInputStream(stream); stream 576 modules/platinum/GPACFileMediaServer.cpp entity->SetInputStream(stream); stream 293 modules/rtp_in/rtp_in.h void RP_FetchSDP(RTPClient *rtp, char *url, RTPStream *stream, char *original_url); stream 298 modules/rtp_in/rtp_in.h GF_Err RP_AddStream(RTPClient *rtp, RTPStream *stream, char *session_control); stream 321 modules/rtp_in/rtp_in.h void RP_LoadSDP(RTPClient *rtp, char *sdp, u32 sdp_len, RTPStream *stream); stream 283 modules/rtp_in/rtp_session.c GF_Err RP_AddStream(RTPClient *rtp, RTPStream *stream, char *session_control) stream 298 modules/rtp_in/rtp_session.c stream->rtsp = in_session; stream 299 modules/rtp_in/rtp_session.c gf_list_add(rtp->channels, stream); stream 304 modules/rtp_in/rtp_session.c if (stream->control) { stream 306 modules/rtp_in/rtp_session.c if (strnicmp(stream->control, "rtsp://", 7) && strnicmp(stream->control, "rtspu://", 8) && strnicmp(stream->control, "satip://", 8)) { stream 317 modules/rtp_in/rtp_session.c in_session = RP_CheckSession(rtp, stream->control); stream 320 modules/rtp_in/rtp_session.c if (session_control && strstr(stream->control, session_control)) stream 323 modules/rtp_in/rtp_session.c in_session = RP_NewSession(rtp, stream->control); stream 328 modules/rtp_in/rtp_session.c ctrl = strstr(stream->control, service_name); stream 332 modules/rtp_in/rtp_session.c gf_free(stream->control); stream 333 modules/rtp_in/rtp_session.c stream->control = service_name; stream 345 modules/rtp_in/rtp_session.c } else if (stream->control) { stream 346 modules/rtp_in/rtp_session.c gf_free(stream->control); stream 347 modules/rtp_in/rtp_session.c stream->control = NULL; stream 349 modules/rtp_in/rtp_session.c stream->rtsp = in_session; stream 350 modules/rtp_in/rtp_session.c gf_list_add(rtp->channels, stream); stream 31 modules/rtp_in/sdp_fetch.c void RP_SDPFromData(RTPClient *rtp, char *s_url, RTPStream *stream) stream 49 modules/rtp_in/sdp_fetch.c RP_LoadSDP(rtp, url, (u32) strlen(url), stream); stream 52 modules/rtp_in/sdp_fetch.c void RP_SDPFromFile(RTPClient *rtp, char *file_name, RTPStream *stream) stream 73 modules/rtp_in/sdp_fetch.c RP_LoadSDP(rtp, sdp_buf, sdp_size, stream); stream 149 modules/rtp_in/sdp_fetch.c void RP_FetchSDP(RTPClient *rtp, char *url, RTPStream *stream, char *original_url) stream 154 modules/rtp_in/sdp_fetch.c RP_SDPFromData(rtp, url, stream); stream 158 modules/rtp_in/sdp_fetch.c RP_SDPFromFile(rtp, url, stream); stream 166 modules/rtp_in/sdp_fetch.c sdp->chan = stream; stream 31 modules/rtp_in/sdp_load.c GF_Err RP_SetupSDP(RTPClient *rtp, GF_SDPInfo *sdp, RTPStream *stream) stream 79 modules/rtp_in/sdp_load.c ch = RP_NewStream(rtp, media, sdp, stream); stream 306 modules/rtp_in/sdp_load.c void RP_LoadSDP(RTPClient *rtp, char *sdp_text, u32 sdp_len, RTPStream *stream) stream 320 modules/rtp_in/sdp_load.c if (e == GF_OK) e = RP_SetupSDP(rtp, sdp, stream); stream 323 modules/rtp_in/sdp_load.c if (!stream) { stream 377 modules/rtp_in/sdp_load.c gf_service_connect_ack(rtp->service, stream->channel, e); stream 378 modules/rtp_in/sdp_load.c stream->status = RTP_Unavailable; stream 381 modules/rtp_in/sdp_load.c RP_SetupChannel(stream, NULL); stream 62 modules/saf_in/saf_in.c FILE *stream; stream 142 modules/saf_in/saf_in.c if (read->stream && (read->saf_type==SAF_FILE_REMOTE)) read->saf_type = SAF_FILE_LOCAL; stream 327 modules/saf_in/saf_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 330 modules/saf_in/saf_in.c while (read->run_state && !feof(read->stream) ) { stream 331 modules/saf_in/saf_in.c par.size = (u32) fread(data, 1, 1024, read->stream); stream 365 modules/saf_in/saf_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 366 modules/saf_in/saf_in.c bs = gf_bs_from_file(read->stream, GF_BITSTREAM_READ); stream 399 modules/saf_in/saf_in.c gf_fseek(read->stream, 0, SEEK_SET); stream 427 modules/saf_in/saf_in.c read->stream = gf_fopen(szURL, "rb"); stream 428 modules/saf_in/saf_in.c if (!read->stream) { stream 452 modules/saf_in/saf_in.c if (read->stream) gf_fclose(read->stream); stream 453 modules/saf_in/saf_in.c read->stream = NULL; stream 35 modules/sdl_out/audio.c void sdl_fill_audio(void *udata, Uint8 *stream, int len) stream 45 modules/sdl_out/audio.c memset(stream, 0, len); stream 48 modules/sdl_out/audio.c SDL_MixAudio(stream, ctx->audioBuff, len, ctx->volume); stream 50 modules/sdl_out/audio.c dr->FillBuffer(dr->audio_renderer, (char *) stream, (u32) len); stream 57 modules/widgetman/unzip.c voidpf stream, stream 63 modules/widgetman/unzip.c voidpf stream, stream 69 modules/widgetman/unzip.c voidpf stream)); stream 73 modules/widgetman/unzip.c voidpf stream, stream 79 modules/widgetman/unzip.c voidpf stream)); stream 83 modules/widgetman/unzip.c voidpf stream)); stream 106 modules/widgetman/unzip.c uLong ZCALLBACK fread_file_func (opaque, stream, buf, size) stream 108 modules/widgetman/unzip.c voidpf stream; stream 113 modules/widgetman/unzip.c ret = (uLong)fread(buf, 1, (size_t)size, (FILE *)stream); stream 118 modules/widgetman/unzip.c uLong ZCALLBACK fwrite_file_func (opaque, stream, buf, size) stream 120 modules/widgetman/unzip.c voidpf stream; stream 125 modules/widgetman/unzip.c ret = (uLong)gf_fwrite(buf, 1, (size_t)size, (FILE *)stream); stream 129 modules/widgetman/unzip.c long ZCALLBACK ftell_file_func (opaque, stream) stream 131 modules/widgetman/unzip.c voidpf stream; stream 134 modules/widgetman/unzip.c ret = ftell((FILE *)stream); stream 138 modules/widgetman/unzip.c long ZCALLBACK fseek_file_func (opaque, stream, offset, origin) stream 140 modules/widgetman/unzip.c voidpf stream; stream 161 modules/widgetman/unzip.c fseek((FILE *)stream, offset, fseek_origin); stream 165 modules/widgetman/unzip.c int ZCALLBACK fclose_file_func (opaque, stream) stream 167 modules/widgetman/unzip.c voidpf stream; stream 170 modules/widgetman/unzip.c ret = gf_fclose((FILE *)stream); stream 174 modules/widgetman/unzip.c int ZCALLBACK ferror_file_func (opaque, stream) stream 176 modules/widgetman/unzip.c voidpf stream; stream 179 modules/widgetman/unzip.c ret = ferror((FILE *)stream); stream 617 modules/widgetman/unzip.c inflateEnd(&pfile_in_zip_read_info->stream); stream 770 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.next_out = (Bytef*)buf; stream 772 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_out = (uInt)len; stream 776 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_out = stream 780 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_in) && stream 782 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_out = stream 784 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_in; stream 786 modules/widgetman/unzip.c while (pfile_in_zip_read_info->stream.avail_out>0) stream 788 modules/widgetman/unzip.c if ((pfile_in_zip_read_info->stream.avail_in==0) && stream 812 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.next_in = stream 814 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_in = (uInt)uReadThis; stream 821 modules/widgetman/unzip.c if ((pfile_in_zip_read_info->stream.avail_in == 0) && stream 825 modules/widgetman/unzip.c if (pfile_in_zip_read_info->stream.avail_out < stream 826 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_in) stream 827 modules/widgetman/unzip.c uDoCopy = pfile_in_zip_read_info->stream.avail_out ; stream 829 modules/widgetman/unzip.c uDoCopy = pfile_in_zip_read_info->stream.avail_in ; stream 832 modules/widgetman/unzip.c *(pfile_in_zip_read_info->stream.next_out+i) = stream 833 modules/widgetman/unzip.c *(pfile_in_zip_read_info->stream.next_in+i); stream 836 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.next_out, stream 839 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_in -= uDoCopy; stream 840 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_out -= uDoCopy; stream 841 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.next_out += uDoCopy; stream 842 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.next_in += uDoCopy; stream 843 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.total_out += uDoCopy; stream 853 modules/widgetman/unzip.c uTotalOutBefore = pfile_in_zip_read_info->stream.total_out; stream 854 modules/widgetman/unzip.c bufBefore = pfile_in_zip_read_info->stream.next_out; stream 862 modules/widgetman/unzip.c err=inflate(&pfile_in_zip_read_info->stream,flush); stream 864 modules/widgetman/unzip.c if ((err>=0) && (pfile_in_zip_read_info->stream.msg!=NULL)) stream 867 modules/widgetman/unzip.c uTotalOutAfter = pfile_in_zip_read_info->stream.total_out; stream 1071 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.total_out = 0; stream 1076 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.zalloc = (alloc_func)0; stream 1077 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.zfree = (free_func)0; stream 1078 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.opaque = (voidpf)0; stream 1079 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.next_in = (voidpf)0; stream 1080 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_in = 0; stream 1082 modules/widgetman/unzip.c err=inflateInit2(&pfile_in_zip_read_info->stream, -MAX_WBITS); stream 1108 modules/widgetman/unzip.c pfile_in_zip_read_info->stream.avail_in = (uInt)0; stream 72 modules/widgetman/unzip.h typedef uLong (ZCALLBACK *read_file_func) OF((voidpf opaque, voidpf stream, void* buf, uLong size)); stream 73 modules/widgetman/unzip.h typedef uLong (ZCALLBACK *write_file_func) OF((voidpf opaque, voidpf stream, const void* buf, uLong size)); stream 74 modules/widgetman/unzip.h typedef long (ZCALLBACK *tell_file_func) OF((voidpf opaque, voidpf stream)); stream 75 modules/widgetman/unzip.h typedef long (ZCALLBACK *seek_file_func) OF((voidpf opaque, voidpf stream, uLong offset, int origin)); stream 76 modules/widgetman/unzip.h typedef int (ZCALLBACK *close_file_func) OF((voidpf opaque, voidpf stream)); stream 77 modules/widgetman/unzip.h typedef int (ZCALLBACK *testerror_file_func) OF((voidpf opaque, voidpf stream)); stream 207 modules/widgetman/unzip.h z_stream stream; /* zLib stream structure for inflate */ stream 64 src/compositor/audio_input.c if (!ai->stream) return NULL; stream 67 src/compositor/audio_input.c frame = gf_mo_fetch_data(ai->stream, ai->compositor->audio_renderer->step_mode ? GF_MO_FETCH_PAUSED : GF_MO_FETCH, 0, &ai->stream_finished, &ts, size, NULL, NULL, NULL); stream 78 src/compositor/audio_input.c gf_mo_adjust_clock(ai->stream, 0); stream 90 src/compositor/audio_input.c speed = gf_mo_get_current_speed(ai->stream); stream 92 src/compositor/audio_input.c gf_mo_get_object_time(ai->stream, &obj_time); stream 106 src/compositor/audio_input.c gf_mo_release_data(ai->stream, 0, -1); stream 117 src/compositor/audio_input.c gf_mo_release_data(ai->stream, *size, 2); stream 121 src/compositor/audio_input.c resync_delay = gf_mo_get_clock_drift(ai->stream) - drift; stream 126 src/compositor/audio_input.c gf_mo_adjust_clock(ai->stream, drift); stream 135 src/compositor/audio_input.c if (!ai->stream) return; stream 136 src/compositor/audio_input.c gf_mo_release_data(ai->stream, nb_bytes, 1); stream 143 src/compositor/audio_input.c return gf_mo_get_current_speed(ai->stream); stream 160 src/compositor/audio_input.c if (!ai->stream) return GF_TRUE; stream 163 src/compositor/audio_input.c return gf_mo_is_muted(ai->stream); stream 169 src/compositor/audio_input.c if (!ai->stream) return GF_FALSE; stream 171 src/compositor/audio_input.c if (aifc->samplerate && (gf_mo_get_flags(ai->stream) & GF_MO_IS_INIT)) return GF_TRUE; stream 173 src/compositor/audio_input.c gf_mo_get_audio_info(ai->stream, &aifc->samplerate, &aifc->bps , &aifc->chan, &aifc->ch_cfg); stream 179 src/compositor/audio_input.c gf_mo_set_flag(ai->stream, GF_MO_IS_INIT, GF_TRUE); stream 182 src/compositor/audio_input.c gf_mo_set_flag(ai->stream, GF_MO_IS_INIT, GF_FALSE); stream 192 src/compositor/audio_input.c ai->stream = NULL; stream 222 src/compositor/audio_input.c ai->stream = gf_mo_register(ai->owner, url, lock_timeline, GF_FALSE); stream 224 src/compositor/audio_input.c if (!ai->stream) return GF_NOT_SUPPORTED; stream 227 src/compositor/audio_input.c gf_mo_play(ai->stream, clipBegin, clipEnd, GF_FALSE); stream 231 src/compositor/audio_input.c gf_mo_set_flag(ai->stream, GF_MO_IS_INIT, GF_FALSE); stream 256 src/compositor/audio_input.c gf_mo_stop(ai->stream); stream 258 src/compositor/audio_input.c gf_mo_unregister(ai->owner, ai->stream); stream 259 src/compositor/audio_input.c ai->stream = NULL; stream 272 src/compositor/audio_input.c if (ai->need_release) gf_mo_release_data(ai->stream, 0xFFFFFFFF, 2); stream 276 src/compositor/audio_input.c gf_mo_restart(ai->stream); stream 282 src/compositor/audio_input.c if (!ai->stream) return url->count; stream 283 src/compositor/audio_input.c return gf_mo_url_changed(ai->stream, url); stream 2451 src/compositor/compositor.c if (! txh->stream) continue; stream 2458 src/compositor/compositor.c u32 d = gf_mo_get_min_frame_dur(txh->stream); stream 2588 src/compositor/compositor.c if (txh->stream) continue; stream 651 src/compositor/compositor_2d.c gf_mo_get_object_time(txh->stream, &ck); stream 1308 src/compositor/hardcoded_protos.c if (!txh->stream) return; stream 1311 src/compositor/hardcoded_protos.c if (! gf_mo_get_srd_info(txh->stream, &vrinfo)) stream 1392 src/compositor/hardcoded_protos.c GF_LOG(GF_LOG_DEBUG, GF_LOG_COMPOSE, ("[Compositor] Texure %d Partial sphere is %s - Angle center-cam is %.02f h %.02f v\n", txh->stream->OD_ID, visible ? "visible" : "hidden", theta_angle, phi_angle)); stream 1395 src/compositor/hardcoded_protos.c gf_mo_hint_quality_degradation(asp.fill_texture->stream, 0); stream 1397 src/compositor/hardcoded_protos.c gf_mo_hint_quality_degradation(asp.fill_texture->stream, 100); stream 37 src/compositor/mpeg4_animstream.c GF_MediaObject *stream; stream 50 src/compositor/mpeg4_animstream.c if (st->stream && as->isActive) { stream 51 src/compositor/mpeg4_animstream.c gf_mo_set_flag(st->stream, GF_MO_DISPLAY_REMOVE, 1); stream 52 src/compositor/mpeg4_animstream.c gf_mo_stop(st->stream); stream 62 src/compositor/mpeg4_animstream.c if (!stack->stream) { stream 65 src/compositor/mpeg4_animstream.c stack->stream = gf_mo_register((GF_Node *)as, &as->url, 0, 0); stream 70 src/compositor/mpeg4_animstream.c gf_mo_play(stack->stream, 0, -1, 0); stream 71 src/compositor/mpeg4_animstream.c gf_mo_set_speed(stack->stream, as->speed); stream 76 src/compositor/mpeg4_animstream.c if (gf_mo_url_changed(stack->stream, &as->url)) { stream 81 src/compositor/mpeg4_animstream.c gf_mo_set_flag(stack->stream, GF_MO_DISPLAY_REMOVE, 1); stream 82 src/compositor/mpeg4_animstream.c gf_mo_stop(stack->stream); stream 84 src/compositor/mpeg4_animstream.c gf_mo_unregister((GF_Node *)as, stack->stream); stream 86 src/compositor/mpeg4_animstream.c stack->stream = gf_mo_register((GF_Node *)as, &as->url, 0, 0); stream 89 src/compositor/mpeg4_animstream.c gf_mo_play(stack->stream, 0, -1, 0); stream 90 src/compositor/mpeg4_animstream.c gf_mo_set_speed(stack->stream, as->speed); stream 98 src/compositor/mpeg4_animstream.c return gf_mo_get_speed(stack->stream, as->speed); stream 102 src/compositor/mpeg4_animstream.c return gf_mo_get_loop(stack->stream, as->loop); stream 111 src/compositor/mpeg4_animstream.c gf_mo_play(stack->stream, 0, -1, 0); stream 112 src/compositor/mpeg4_animstream.c gf_mo_set_speed(stack->stream, as->speed); stream 121 src/compositor/mpeg4_animstream.c if (stack->stream) { stream 122 src/compositor/mpeg4_animstream.c if (gf_mo_url_changed(stack->stream, &as->url)) stream 123 src/compositor/mpeg4_animstream.c gf_mo_set_flag(stack->stream, GF_MO_DISPLAY_REMOVE, 1); stream 124 src/compositor/mpeg4_animstream.c gf_mo_stop(stack->stream); stream 150 src/compositor/mpeg4_animstream.c if (gf_mo_is_done(stack->stream)) { stream 152 src/compositor/mpeg4_animstream.c gf_mo_restart(stack->stream); stream 153 src/compositor/mpeg4_animstream.c } else if (gf_mo_should_deactivate(stack->stream)) { stream 49 src/compositor/mpeg4_audio.c gf_mo_set_speed(st->input.stream, st->input.speed); stream 80 src/compositor/mpeg4_audio.c if (st->input.stream && st->input.stream_finished) { stream 81 src/compositor/mpeg4_audio.c if (gf_mo_get_loop(st->input.stream, ac->loop)) { stream 83 src/compositor/mpeg4_audio.c } else if (ac->isActive && gf_mo_should_deactivate(st->input.stream)) { stream 91 src/compositor/mpeg4_audio.c if (st->set_duration && st->input.stream) { stream 92 src/compositor/mpeg4_audio.c ac->duration_changed = gf_mo_get_duration(st->input.stream); stream 192 src/compositor/mpeg4_audio.c gf_mo_set_speed(st->input.stream, st->input.speed); stream 222 src/compositor/mpeg4_audio.c if (st->input.stream && st->input.stream_finished) { stream 223 src/compositor/mpeg4_audio.c if (gf_mo_get_loop(st->input.stream, GF_FALSE)) { stream 225 src/compositor/mpeg4_audio.c } else if (st->is_active && gf_mo_should_deactivate(st->input.stream)) { stream 568 src/compositor/mpeg4_audio.c ai->stream = NULL; stream 54 src/compositor/mpeg4_background.c if (txh->stream_finished && gf_mo_get_loop(txh->stream, 0)) gf_sc_texture_restart(txh); stream 448 src/compositor/mpeg4_background2d.c if (txh->stream_finished && gf_mo_get_loop(txh->stream, 0)) stream 204 src/compositor/mpeg4_geometry_3d.c if (!txh || !txh->stream) return; stream 206 src/compositor/mpeg4_geometry_3d.c if (!gf_mo_get_srd_info(txh->stream, &vrinfo) || !vrinfo.is_tiled_srd) stream 214 src/compositor/mpeg4_geometry_3d.c gf_mo_hint_visible_rect(txh->stream, min_x, max_x, min_y, max_y); stream 63 src/compositor/mpeg4_textures.c return gf_mo_get_speed(stack->txh.stream, mt->speed); stream 67 src/compositor/mpeg4_textures.c return gf_mo_get_loop(stack->txh.stream, mt->loop); stream 75 src/compositor/mpeg4_textures.c gf_sc_texture_play_from_to(&stack->txh, &mt->url, scene_time, -1, gf_mo_get_loop(stack->txh.stream, mt->loop), 0); stream 77 src/compositor/mpeg4_textures.c gf_mo_resume(stack->txh.stream); stream 79 src/compositor/mpeg4_textures.c gf_mo_set_speed(stack->txh.stream, mt->speed); stream 108 src/compositor/mpeg4_textures.c else if (txnode->isActive && gf_mo_should_deactivate(st->txh.stream) ) { stream 115 src/compositor/mpeg4_textures.c txnode->duration_changed = gf_mo_get_duration(txh->stream); stream 119 src/compositor/mpeg4_textures.c gf_mo_pause(txh->stream); stream 154 src/compositor/mpeg4_textures.c gf_mo_resume(stack->txh.stream); stream 291 src/compositor/svg_media.c if (!stack->txh.stream || gf_mo_url_changed(stack->txh.stream, &stack->txurl)) { stream 415 src/compositor/svg_media.c if (txh->stream && !txh->stream_finished && (!txh->tx_io || txh->needs_refresh) ) { stream 458 src/compositor/svg_media.c if (!txh->stream) { stream 497 src/compositor/svg_media.c u32 res = gf_mo_has_audio(stack->txh.stream); stream 538 src/compositor/svg_media.c Double dur = gf_mo_get_duration(stack->txh.stream); stream 591 src/compositor/svg_media.c if (pause) gf_mo_pause(st->txh.stream); stream 592 src/compositor/svg_media.c else gf_mo_resume(st->txh.stream); stream 654 src/compositor/svg_media.c gf_mo_set_speed(stack->input.stream, FIX_ONE); stream 662 src/compositor/svg_media.c Double dur = gf_mo_get_duration(stack->input.stream); stream 664 src/compositor/svg_media.c dur = gf_mo_get_last_frame_time(stack->input.stream); stream 745 src/compositor/svg_media.c gf_mo_set_speed(stack->input.stream, FIX_ONE); stream 795 src/compositor/svg_media.c if (pause) gf_mo_pause(st->input.stream); stream 796 src/compositor/svg_media.c else gf_mo_resume(st->input.stream); stream 67 src/compositor/texturing.c if (!txh->stream) return url->count; stream 68 src/compositor/texturing.c return gf_mo_url_changed(txh->stream, url); stream 80 src/compositor/texturing.c txh->stream = gf_mo_register(txh->owner, url, lock_scene_timeline, 0); stream 82 src/compositor/texturing.c if (!txh->stream) return GF_NOT_SUPPORTED; stream 90 src/compositor/texturing.c if (!txh->stream) { stream 97 src/compositor/texturing.c gf_mo_play(txh->stream, start_offset, end_offset, can_loop); stream 104 src/compositor/texturing.c txh->raw_memory = gf_mo_is_raw_memory(txh->stream); stream 127 src/compositor/texturing.c gf_mo_release_data(txh->stream, 0xFFFFFFFF, -1); stream 132 src/compositor/texturing.c if (gf_mo_stop(txh->stream)) { stream 138 src/compositor/texturing.c gf_mo_unregister(txh->owner, txh->stream); stream 139 src/compositor/texturing.c txh->stream = NULL; stream 148 src/compositor/texturing.c gf_mo_restart(txh->stream); stream 158 src/compositor/texturing.c gf_mo_get_visual_info(txh->stream, &txh->width, &txh->height, &txh->stride, &txh->pixel_ar, &txh->pixelformat, &txh->is_flipped); stream 177 src/compositor/texturing.c gf_mo_set_flag(txh->stream, GF_MO_IS_INIT, GF_TRUE); stream 192 src/compositor/texturing.c if (!txh->stream) { stream 199 src/compositor/texturing.c gf_mo_release_data(txh->stream, 0xFFFFFFFF, 0); stream 204 src/compositor/texturing.c if (!(gf_mo_get_flags(txh->stream) & GF_MO_IS_INIT)) { stream 214 src/compositor/texturing.c txh->data = gf_mo_fetch_data(txh->stream, disable_resync ? GF_MO_FETCH : GF_MO_FETCH_RESYNC, push_time, &txh->stream_finished, &ts, &size, &ms_until_pres, &ms_until_next, &txh->frame); stream 216 src/compositor/texturing.c if (!(gf_mo_get_flags(txh->stream) & GF_MO_IS_INIT)) { stream 229 src/compositor/texturing.c if (gf_mo_is_private_media(txh->stream)) { stream 253 src/compositor/texturing.c gf_mo_release_data(txh->stream, 0xFFFFFFFF, 0); stream 267 src/compositor/texturing.c gf_mo_get_raw_image_planes(txh->stream, (u8 **) &txh->data, (u8 **) &txh->pU, (u8 **) &txh->pV, &txh->stride, &txh->stride_chroma); stream 269 src/compositor/texturing.c if (gf_mo_is_muted(txh->stream)) return; stream 298 src/compositor/texturing.c assert(txh->stream); stream 299 src/compositor/texturing.c gf_mo_release_data(txh->stream, 0xFFFFFFFF, 0); stream 1039 src/compositor/texturing_gl.c if (txh->stream) { stream 1040 src/compositor/texturing_gl.c gf_mo_get_nb_views(txh->stream, &nb_views); stream 1041 src/compositor/texturing_gl.c gf_mo_get_nb_layers(txh->stream, &nb_layers); stream 1329 src/compositor/texturing_gl.c gf_mo_get_object_time(txh->stream, &ck); stream 1483 src/compositor/texturing_gl.c gf_mo_get_nb_views(txh->stream, &nb_views); stream 1486 src/compositor/texturing_gl.c if(txh->stream && txh->tx_io->gl_type == GL_TEXTURE_EXTERNAL_OES) { stream 1499 src/compositor/texturing_gl.c if (txh->stream && (txh->compositor->frame_packing==GF_3D_STEREO_TOP)) { stream 2084 src/compositor/texturing_gl.c if (txh->stream && txh->tx_io) { stream 330 src/compositor/visual_manager_2d.c if (ctx->aspect.fill_texture &&ctx->aspect.fill_texture->stream) { stream 753 src/compositor/visual_manager_2d.c if (bck_ctx->aspect.fill_texture && bck_ctx->aspect.fill_texture->stream) { stream 517 src/compositor/visual_manager_2d_draw.c gf_mo_get_visual_info(txh->stream, &txh->width, &txh->height, &txh->stride, &txh->pixel_ar, &txh->pixelformat, &txh->is_flipped); stream 523 src/compositor/visual_manager_2d_draw.c if (txh->stream && gf_mo_set_position(txh->stream, &src, &dst)) { stream 524 src/compositor/visual_manager_2d_draw.c gf_mo_get_visual_info(txh->stream, &txh->width, &txh->height, &txh->stride, &txh->pixel_ar, &txh->pixelformat, &txh->is_flipped); stream 143 src/ietf/rtp_streamer.c GF_RTPStreamer *stream; stream 153 src/ietf/rtp_streamer.c GF_SAFEALLOC(stream, GF_RTPStreamer); stream 154 src/ietf/rtp_streamer.c if (!stream) return NULL; stream 456 src/ietf/rtp_streamer.c stream->packetizer = gf_rtp_builder_new(rtp_type, &slc, flags, stream 457 src/ietf/rtp_streamer.c stream, stream 461 src/ietf/rtp_streamer.c if (!stream->packetizer) { stream 463 src/ietf/rtp_streamer.c gf_free(stream); stream 467 src/ietf/rtp_streamer.c gf_rtp_builder_init(stream->packetizer, PayloadType, MTU, max_ptime, stream 471 src/ietf/rtp_streamer.c if (force_dts_delta) stream->packetizer->slMap.DTSDeltaLength = force_dts_delta; stream 473 src/ietf/rtp_streamer.c e = rtp_stream_init_channel(stream, MTU + 12, ip_dest, port, TTL, ifce_addr); stream 476 src/ietf/rtp_streamer.c gf_free(stream); stream 479 src/ietf/rtp_streamer.c stream->ts_scale = slc.timestampResolution; stream 480 src/ietf/rtp_streamer.c stream->ts_scale /= timeScale; stream 482 src/ietf/rtp_streamer.c stream->buffer_alloc = MTU+12; stream 483 src/ietf/rtp_streamer.c stream->buffer = (char*)gf_malloc(sizeof(char) * stream->buffer_alloc); stream 485 src/ietf/rtp_streamer.c return stream; stream 100 src/isomedia/data_map.c FILE *stream; stream 102 src/isomedia/data_map.c stream = gf_fopen(path, "rb"); stream 103 src/isomedia/data_map.c if (!stream) return 0; stream 104 src/isomedia/data_map.c gf_fseek(stream, 0, SEEK_END); stream 105 src/isomedia/data_map.c size = gf_ftell(stream); stream 106 src/isomedia/data_map.c gf_fclose(stream); stream 335 src/isomedia/data_map.c tmp->stream = gf_temp_file_new(&tmp->temp_file); stream 343 src/isomedia/data_map.c tmp->stream = gf_fopen(szPath, "w+b"); stream 346 src/isomedia/data_map.c if (!tmp->stream) { stream 351 src/isomedia/data_map.c tmp->bs = gf_bs_from_file(tmp->stream, GF_BITSTREAM_WRITE); stream 353 src/isomedia/data_map.c gf_fclose(tmp->stream); stream 383 src/isomedia/data_map.c tmp->stream = gf_temp_file_new(&tmp->temp_file); stream 402 src/isomedia/data_map.c if (!tmp->stream) tmp->stream = gf_fopen(sPath, "rb"); stream 408 src/isomedia/data_map.c tmp->stream = stdout; stream 412 src/isomedia/data_map.c if (!tmp->stream) tmp->stream = gf_fopen(sPath, "w+b"); stream 413 src/isomedia/data_map.c if (!tmp->stream) tmp->stream = gf_fopen(sPath, "wb"); stream 419 src/isomedia/data_map.c tmp->stream = stdout; stream 423 src/isomedia/data_map.c if (!tmp->stream) tmp->stream = gf_fopen(sPath, "a+b"); stream 424 src/isomedia/data_map.c if (tmp->stream) gf_fseek(tmp->stream, 0, SEEK_END); stream 431 src/isomedia/data_map.c if (!tmp->stream) { stream 435 src/isomedia/data_map.c tmp->bs = gf_bs_from_file(tmp->stream, bs_mode); stream 437 src/isomedia/data_map.c gf_fclose(tmp->stream); stream 451 src/isomedia/data_map.c if (ptr->stream && !ptr->is_stdout) stream 452 src/isomedia/data_map.c gf_fclose(ptr->stream); stream 538 src/isomedia/data_map.c if (ptr->stream) fflush(ptr->stream); stream 1267 src/isomedia/isom_store.c FILE *stream; stream 1309 src/isomedia/isom_store.c stream = is_stdout ? stdout : gf_fopen(movie->finalName, "w+b"); stream 1310 src/isomedia/isom_store.c if (!stream) stream 1312 src/isomedia/isom_store.c bs = gf_bs_from_file(stream, GF_BITSTREAM_WRITE); stream 1315 src/isomedia/isom_store.c gf_fclose(stream); stream 1346 src/isomedia/isom_store.c gf_fclose(stream); stream 62 src/media_tools/ait.c GF_M2TS_AIT_CARRY* ait_carry = (GF_M2TS_AIT_CARRY*)pck->stream; stream 74 src/media_tools/ait.c if (ts->on_event) ts->on_event(ts, GF_M2TS_EVT_AIT_FOUND, pck->stream); stream 3820 src/media_tools/dash_segmenter.c if (pck->stream->pid == pck->stream->program->pcr_pid) { stream 3930 src/media_tools/dash_segmenter.c pes = pck->stream; stream 3946 src/media_tools/dash_segmenter.c if (pck->stream->pid != ts_seg->reference_pid) { stream 3967 src/media_tools/dash_segmenter.c ts_seg->first_SAP_offset = (pck->stream->pes_start_packet_number-1)*188; stream 3970 src/media_tools/dash_segmenter.c ts_seg->last_SAP_offset = (pck->stream->pes_start_packet_number-1)*188; stream 114 src/media_tools/dsmcc.c dsmcc_overlord = gf_m2ts_get_dmscc_overlord(ts->dsmcc_controler,pck->stream->service_id); stream 37 src/media_tools/dvb_mpe.c gf_m2ts_process_int(ts, (GF_M2TS_SECTION_ES *)pck->stream, data, u32_data_size, u32_table_id); stream 43 src/media_tools/dvb_mpe.c GF_M2TS_SECTION_MPE* mpe = (GF_M2TS_SECTION_MPE*)pck->stream; stream 81 src/media_tools/filestreamer.c GF_RTPTrack *stream; stream 147 src/media_tools/filestreamer.c track = streamer->stream; stream 154 src/media_tools/filestreamer.c track = streamer->stream; stream 227 src/media_tools/filestreamer.c track = streamer->stream; stream 266 src/media_tools/filestreamer.c track = streamer->stream; stream 314 src/media_tools/filestreamer.c track = streamer->stream; stream 403 src/media_tools/filestreamer.c GF_RTPTrack *track = streamer->stream; stream 494 src/media_tools/filestreamer.c else streamer->stream = track; stream 643 src/media_tools/filestreamer.c GF_RTPTrack *track = streamer->stream; stream 659 src/media_tools/filestreamer.c GF_RTPTrack *track = streamer->stream; stream 100 src/media_tools/m2ts_mux.c void gf_m2ts_mux_table_update(GF_M2TS_Mux_Stream *stream, u8 table_id, u16 table_id_extension, stream 115 src/media_tools/m2ts_mux.c table = stream->tables; stream 137 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_ERROR, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: fail to allocate table id %d\n", stream->pid, table_id)); stream 142 src/media_tools/m2ts_mux.c else stream->tables = table; stream 162 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_ERROR, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: Cannot create sections for table id %d\n", stream->pid, table_id)); stream 188 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_ERROR, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: fail to allocate section for table id %d\n", stream->pid, table_id)); stream 242 src/media_tools/m2ts_mux.c stream->current_table = stream->tables; stream 243 src/media_tools/m2ts_mux.c stream->current_section = stream->current_table->section; stream 244 src/media_tools/m2ts_mux.c stream->current_section_offset = 0; stream 246 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_DEBUG, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: Generating %d sections for table id %d - version number %d - extension ID %d\n", stream->pid, nb_sections, table_id, table->version_number, table_id_extension)); stream 249 src/media_tools/m2ts_mux.c void gf_m2ts_mux_table_update_bitrate(GF_M2TS_Mux *mux, GF_M2TS_Mux_Stream *stream) stream 254 src/media_tools/m2ts_mux.c if (stream->table_needs_update) stream 255 src/media_tools/m2ts_mux.c stream->process(mux, stream); stream 257 src/media_tools/m2ts_mux.c stream->bit_rate = 0; stream 258 src/media_tools/m2ts_mux.c table = stream->tables; stream 264 src/media_tools/m2ts_mux.c stream->bit_rate += nb_bytes; stream 269 src/media_tools/m2ts_mux.c stream->bit_rate *= 8; stream 270 src/media_tools/m2ts_mux.c stream->bit_rate *= 1000; stream 271 src/media_tools/m2ts_mux.c if (stream->refresh_rate_ms) { stream 272 src/media_tools/m2ts_mux.c stream->bit_rate /= stream->refresh_rate_ms; stream 273 src/media_tools/m2ts_mux.c } else if (stream->table_needs_send) { stream 275 src/media_tools/m2ts_mux.c stream->bit_rate /= 100; stream 277 src/media_tools/m2ts_mux.c stream->bit_rate = 0; stream 281 src/media_tools/m2ts_mux.c void gf_m2ts_mux_table_update_mpeg4(GF_M2TS_Mux_Stream *stream, u8 table_id, u16 table_id_extension, stream 298 src/media_tools/m2ts_mux.c table = stream->tables; stream 321 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_ERROR, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: fail to allocate table id %d\n", stream->pid, table_id)); stream 326 src/media_tools/m2ts_mux.c else stream->tables = table; stream 336 src/media_tools/m2ts_mux.c hdr = stream->sl_header; stream 337 src/media_tools/m2ts_mux.c sl_size = gf_sl_get_header_size(stream->ifce->sl_config, &hdr); stream 344 src/media_tools/m2ts_mux.c sl_size = gf_sl_get_header_size(stream->ifce->sl_config, &hdr); stream 354 src/media_tools/m2ts_mux.c hdr = stream->sl_header; stream 361 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_ERROR, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: fail to allocate section for table id %d\n", stream->pid, table_id)); stream 365 src/media_tools/m2ts_mux.c hdr.accessUnitEndFlag = (section_number+1==nb_sections) ? stream->sl_header.accessUnitEndFlag : 0; stream 366 src/media_tools/m2ts_mux.c gf_sl_packetize(stream->ifce->sl_config, &hdr, NULL, 0, &slhdr, &slhdr_size); stream 425 src/media_tools/m2ts_mux.c stream->current_table = stream->tables; stream 426 src/media_tools/m2ts_mux.c stream->current_section = stream->current_table->section; stream 427 src/media_tools/m2ts_mux.c stream->current_section_offset = 0; stream 428 src/media_tools/m2ts_mux.c stream->table_needs_send = GF_TRUE; stream 430 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_DEBUG, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: Generating %d sections for MPEG-4 SL packet - version number %d - extension ID %d\n", stream->pid, nb_sections, table->version_number, table_id_extension)); stream 498 src/media_tools/m2ts_mux.c void gf_m2ts_mux_table_get_next_packet(GF_M2TS_Mux_Stream *stream, char *packet) stream 511 src/media_tools/m2ts_mux.c stream->table_needs_send = GF_FALSE; stream 512 src/media_tools/m2ts_mux.c table = stream->current_table; stream 518 src/media_tools/m2ts_mux.c section = stream->current_section; stream 525 src/media_tools/m2ts_mux.c if (stream->current_section_offset == 0) { stream 532 src/media_tools/m2ts_mux.c if (!stream->current_section_offset) payload_length = 183; stream 537 src/media_tools/m2ts_mux.c if (section->length - stream->current_section_offset >= payload_length) { stream 546 src/media_tools/m2ts_mux.c if (section->length - stream->current_section_offset >= payload_length) { stream 549 src/media_tools/m2ts_mux.c padding_length = payload_length - section->length + stream->current_section_offset; stream 554 src/media_tools/m2ts_mux.c padded_bytes = payload_length - section->length + stream->current_section_offset; stream 555 src/media_tools/m2ts_mux.c payload_length = section->length - stream->current_section_offset; stream 559 src/media_tools/m2ts_mux.c assert(payload_length + stream->current_section_offset <= section->length); stream 563 src/media_tools/m2ts_mux.c if (!stream->continuity_counter) stream->continuity_counter=15; stream 564 src/media_tools/m2ts_mux.c else stream->continuity_counter--; stream 568 src/media_tools/m2ts_mux.c gf_bs_write_int(bs, stream->pid, 13); /*pid*/ stream 571 src/media_tools/m2ts_mux.c gf_bs_write_int(bs, stream->continuity_counter, 4); /*continuity counter*/ stream 573 src/media_tools/m2ts_mux.c if (stream->continuity_counter < 15) stream->continuity_counter++; stream 574 src/media_tools/m2ts_mux.c else stream->continuity_counter=0; stream 578 src/media_tools/m2ts_mux.c gf_m2ts_add_adaptation(stream->program, bs, stream->pid, 0, 0, 0, padding_length, NULL, 0); stream 582 src/media_tools/m2ts_mux.c if (!stream->current_section_offset) { stream 588 src/media_tools/m2ts_mux.c memcpy(packet+188-payload_start, section->data + stream->current_section_offset, payload_length); stream 589 src/media_tools/m2ts_mux.c stream->current_section_offset += payload_length; stream 594 src/media_tools/m2ts_mux.c if (stream->current_section_offset == section->length) { stream 595 src/media_tools/m2ts_mux.c stream->current_section_offset = 0; stream 596 src/media_tools/m2ts_mux.c stream->current_section = stream->current_section->next; stream 597 src/media_tools/m2ts_mux.c if (!stream->current_section) { stream 598 src/media_tools/m2ts_mux.c stream->current_table = stream->current_table->next; stream 600 src/media_tools/m2ts_mux.c if (!stream->current_table) { stream 601 src/media_tools/m2ts_mux.c if (stream->ifce) stream->refresh_rate_ms = stream->ifce->repeat_rate; stream 602 src/media_tools/m2ts_mux.c if (stream->refresh_rate_ms) { stream 603 src/media_tools/m2ts_mux.c stream->current_table = stream->tables; stream 605 src/media_tools/m2ts_mux.c gf_m2ts_time_inc(&stream->time, stream->refresh_rate_ms, 1000); stream 608 src/media_tools/m2ts_mux.c if (stream->current_table) stream->current_section = stream->current_table->section; stream 612 src/media_tools/m2ts_mux.c stream->bytes_since_last_time += 188; stream 616 src/media_tools/m2ts_mux.c u32 gf_m2ts_stream_process_sdt(GF_M2TS_Mux *muxer, GF_M2TS_Mux_Stream *stream) stream 618 src/media_tools/m2ts_mux.c if (stream->table_needs_update) { /* generate table payload */ stream 662 src/media_tools/m2ts_mux.c gf_m2ts_mux_table_update(stream, GF_M2TS_TABLE_ID_SDT_ACTUAL, muxer->ts_id, payload, size, GF_TRUE, GF_FALSE, GF_FALSE); stream 663 src/media_tools/m2ts_mux.c stream->table_needs_update = GF_FALSE; stream 664 src/media_tools/m2ts_mux.c stream->table_needs_send = GF_TRUE; stream 667 src/media_tools/m2ts_mux.c if (stream->table_needs_send) stream 669 src/media_tools/m2ts_mux.c if (stream->refresh_rate_ms) stream 674 src/media_tools/m2ts_mux.c u32 gf_m2ts_stream_process_pat(GF_M2TS_Mux *muxer, GF_M2TS_Mux_Stream *stream) stream 676 src/media_tools/m2ts_mux.c if (stream->table_needs_update) { /* generate table payload */ stream 692 src/media_tools/m2ts_mux.c gf_m2ts_mux_table_update(stream, GF_M2TS_TABLE_ID_PAT, muxer->ts_id, payload, size, GF_TRUE, GF_FALSE, GF_FALSE); stream 693 src/media_tools/m2ts_mux.c stream->table_needs_update = GF_FALSE; stream 694 src/media_tools/m2ts_mux.c stream->table_needs_send = GF_TRUE; stream 697 src/media_tools/m2ts_mux.c if (stream->table_needs_send) stream 699 src/media_tools/m2ts_mux.c if (stream->refresh_rate_ms) stream 704 src/media_tools/m2ts_mux.c u32 gf_m2ts_stream_process_pmt(GF_M2TS_Mux *muxer, GF_M2TS_Mux_Stream *stream) stream 706 src/media_tools/m2ts_mux.c if (stream->table_needs_update) { /* generate table payload */ stream 717 src/media_tools/m2ts_mux.c gf_bs_write_int(bs, stream->program->pcr->pid, 13); stream 721 src/media_tools/m2ts_mux.c if (stream->program->loop_descriptors) { stream 722 src/media_tools/m2ts_mux.c for (i=0; i<gf_list_count(stream->program->loop_descriptors); i++) { stream 723 src/media_tools/m2ts_mux.c GF_M2TSDescriptor *desc = (GF_M2TSDescriptor*)gf_list_get(stream->program->loop_descriptors, i); stream 728 src/media_tools/m2ts_mux.c if (!stream->program->iod) { stream 739 src/media_tools/m2ts_mux.c while (NULL != (esd = (GF_ESD*)gf_list_enum(((GF_ObjectDescriptor*)stream->program->iod)->ESDescriptors, &i))) { stream 740 src/media_tools/m2ts_mux.c GF_M2TS_Mux_Stream *es_stream = stream->program->streams; stream 752 src/media_tools/m2ts_mux.c gf_odf_write_descriptor(bs_iod, stream->program->iod); stream 775 src/media_tools/m2ts_mux.c if (stream->program->loop_descriptors) { stream 776 src/media_tools/m2ts_mux.c for (i=0; i<gf_list_count(stream->program->loop_descriptors); i++) { stream 777 src/media_tools/m2ts_mux.c GF_M2TSDescriptor *desc = (GF_M2TSDescriptor*)gf_list_get(stream->program->loop_descriptors, i); stream 784 src/media_tools/m2ts_mux.c es = stream->program->streams; stream 810 src/media_tools/m2ts_mux.c if (stream->program->iod && !(es->ifce->caps & GF_ESI_STREAM_WITHOUT_MPEG4_SYSTEMS)) stream 830 src/media_tools/m2ts_mux.c if (stream->program->iod && !(es->ifce->caps & GF_ESI_STREAM_WITHOUT_MPEG4_SYSTEMS)) { stream 884 src/media_tools/m2ts_mux.c gf_m2ts_mux_table_update(stream, GF_M2TS_TABLE_ID_PMT, stream->program->number, payload, length, GF_TRUE, GF_FALSE, GF_FALSE); stream 885 src/media_tools/m2ts_mux.c stream->table_needs_update = GF_FALSE; stream 886 src/media_tools/m2ts_mux.c stream->table_needs_send = GF_TRUE; stream 889 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_DEBUG, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: Updating PMT - Program Number %d - %d streams - size %d%s\n", stream->pid, stream->program->number, nb_streams, length, stream->program->iod ? " - MPEG-4 Systems detected":"")); stream 891 src/media_tools/m2ts_mux.c if (stream->table_needs_send) stream 893 src/media_tools/m2ts_mux.c if (stream->refresh_rate_ms) stream 898 src/media_tools/m2ts_mux.c static void gf_m2ts_remap_timestamps_for_pes(GF_M2TS_Mux_Stream *stream, u32 pck_flags, u64 *dts, u64 *cts, u32 *duration) stream 903 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_WARNING, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: DTS "LLD" is greater than CTS "LLD" (likel ISOBMF CTTSv1 input) - adjusting to CTS\n", stream->pid, *dts, *cts)); stream 908 src/media_tools/m2ts_mux.c if (stream->ts_scale.den) { stream 909 src/media_tools/m2ts_mux.c *cts = (u64)( *cts * stream->ts_scale.num / stream->ts_scale.den ) ; stream 910 src/media_tools/m2ts_mux.c *dts = (u64)( *dts * stream->ts_scale.num / stream->ts_scale.den ) ; stream 911 src/media_tools/m2ts_mux.c if (duration) *duration = (u32)( *duration * stream->ts_scale.num / stream->ts_scale.den ) ; stream 915 src/media_tools/m2ts_mux.c if (!stream->program->initial_ts_set) { stream 916 src/media_tools/m2ts_mux.c u32 nb_bits = (u32) (stream->program->mux->tot_pck_sent - stream->program->num_pck_at_pcr_init) * 1504; stream 917 src/media_tools/m2ts_mux.c u32 nb_ticks = 90000*nb_bits / stream->program->mux->bit_rate; stream 918 src/media_tools/m2ts_mux.c stream->program->initial_ts = *dts; stream 920 src/media_tools/m2ts_mux.c if (stream->program->initial_ts > nb_ticks) stream 921 src/media_tools/m2ts_mux.c stream->program->initial_ts -= nb_ticks; stream 923 src/media_tools/m2ts_mux.c stream->program->initial_ts = 0; stream 925 src/media_tools/m2ts_mux.c stream->program->initial_ts_set = GF_TRUE; stream 927 src/media_tools/m2ts_mux.c else if (*dts < stream->program->initial_ts) { stream 928 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_WARNING, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: DTS "LLD" is less than initial DTS "LLD" - adjusting\n", stream->pid, *dts, stream->program->initial_ts)); stream 929 src/media_tools/m2ts_mux.c stream->program->initial_ts = *dts; stream 931 src/media_tools/m2ts_mux.c else if (*dts < stream->last_dts) { stream 932 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_WARNING, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: DTS "LLD" is less than last sent DTS "LLD"\n", stream->pid, *dts, stream->last_dts)); stream 933 src/media_tools/m2ts_mux.c stream->last_dts = *dts; stream 935 src/media_tools/m2ts_mux.c stream->last_dts = *dts; stream 939 src/media_tools/m2ts_mux.c *cts += stream->program->pcr_offset; stream 940 src/media_tools/m2ts_mux.c *dts += stream->program->pcr_offset; stream 943 src/media_tools/m2ts_mux.c pcr_offset = stream->program->pcr_init_time/300; stream 944 src/media_tools/m2ts_mux.c *cts = *cts - stream->program->initial_ts + pcr_offset; stream 945 src/media_tools/m2ts_mux.c *dts = *dts - stream->program->initial_ts + pcr_offset; stream 970 src/media_tools/m2ts_mux.c static Bool gf_m2ts_adjust_next_stream_time_for_pcr(GF_M2TS_Mux *muxer, GF_M2TS_Mux_Stream *stream) stream 980 src/media_tools/m2ts_mux.c next_pcr_time = stream->program->ts_time_at_pcr_init; stream 981 src/media_tools/m2ts_mux.c pck_diff = (u32) (stream->program->nb_pck_last_pcr - stream->program->num_pck_at_pcr_init); stream 982 src/media_tools/m2ts_mux.c gf_m2ts_time_inc(&next_pcr_time, pck_diff*1504, stream->program->mux->bit_rate); stream 983 src/media_tools/m2ts_mux.c gf_m2ts_time_inc(&next_pcr_time, stream->program->mux->pcr_update_ms, 1000); stream 985 src/media_tools/m2ts_mux.c stream_time = stream->pcr_only_mode ? stream->next_time : stream->time; stream 989 src/media_tools/m2ts_mux.c if (!stream->pcr_only_mode) { stream 990 src/media_tools/m2ts_mux.c stream->pcr_only_mode = GF_TRUE; stream 991 src/media_tools/m2ts_mux.c stream->next_time = stream->time; stream 993 src/media_tools/m2ts_mux.c stream->time = next_pcr_time; stream 995 src/media_tools/m2ts_mux.c us_diff = gf_m2ts_time_diff_us(&stream->program->mux->time, &stream->time); stream 998 src/media_tools/m2ts_mux.c } else if (stream->pcr_only_mode) { stream 999 src/media_tools/m2ts_mux.c stream->pcr_only_mode = GF_FALSE; stream 1000 src/media_tools/m2ts_mux.c stream->time = stream->next_time; stream 1005 src/media_tools/m2ts_mux.c static u32 gf_m2ts_stream_process_pes(GF_M2TS_Mux *muxer, GF_M2TS_Mux_Stream *stream) stream 1010 src/media_tools/m2ts_mux.c if (stream->mpeg2_stream_type==GF_M2TS_SYSTEMS_MPEG4_SECTIONS) { stream 1012 src/media_tools/m2ts_mux.c if (stream->table_needs_send) stream 1013 src/media_tools/m2ts_mux.c return stream->scheduling_priority; stream 1015 src/media_tools/m2ts_mux.c if (stream->current_section && (stream->current_section_offset || stream->current_section!=stream->current_table->section)) stream 1016 src/media_tools/m2ts_mux.c return stream->scheduling_priority; stream 1017 src/media_tools/m2ts_mux.c if (stream->ifce->repeat_rate && stream->tables) stream 1018 src/media_tools/m2ts_mux.c ret = stream->program->pcr_init_time ? stream->scheduling_priority : GF_FALSE; stream 1021 src/media_tools/m2ts_mux.c else if (stream->curr_pck.data_len && stream->pck_offset < stream->curr_pck.data_len) { stream 1023 src/media_tools/m2ts_mux.c if ((stream == stream->program->pcr) && stream->pcr_only_mode) { stream 1024 src/media_tools/m2ts_mux.c if (! gf_m2ts_adjust_next_stream_time_for_pcr(muxer, stream)) { stream 1028 src/media_tools/m2ts_mux.c return stream->scheduling_priority; stream 1032 src/media_tools/m2ts_mux.c if (stream->ifce->caps & GF_ESI_AU_PULL_CAP) { stream 1033 src/media_tools/m2ts_mux.c if (stream->curr_pck.data_len) { stream 1035 src/media_tools/m2ts_mux.c if (stream->discard_data) gf_free(stream->curr_pck.data); stream 1037 src/media_tools/m2ts_mux.c stream->ifce->input_ctrl(stream->ifce, GF_ESI_INPUT_DATA_RELEASE, NULL); stream 1039 src/media_tools/m2ts_mux.c stream->pck_offset = 0; stream 1040 src/media_tools/m2ts_mux.c stream->curr_pck.data_len = 0; stream 1041 src/media_tools/m2ts_mux.c stream->discard_data = GF_FALSE; stream 1044 src/media_tools/m2ts_mux.c if (stream->ifce->caps & GF_ESI_STREAM_IS_OVER) return ret; stream 1045 src/media_tools/m2ts_mux.c assert( stream->ifce->input_ctrl); stream 1046 src/media_tools/m2ts_mux.c stream->ifce->input_ctrl(stream->ifce, GF_ESI_INPUT_DATA_PULL, &stream->curr_pck); stream 1050 src/media_tools/m2ts_mux.c if (!stream->pck_first && (stream->ifce->caps & GF_ESI_STREAM_IS_OVER)) stream 1054 src/media_tools/m2ts_mux.c if (stream->ifce->input_ctrl) stream->ifce->input_ctrl(stream->ifce, GF_ESI_INPUT_DATA_FLUSH, NULL); stream 1056 src/media_tools/m2ts_mux.c gf_mx_p(stream->mx); stream 1058 src/media_tools/m2ts_mux.c stream->pck_offset = 0; stream 1059 src/media_tools/m2ts_mux.c stream->curr_pck.data_len = 0; stream 1062 src/media_tools/m2ts_mux.c curr_pck = stream->pck_first; stream 1064 src/media_tools/m2ts_mux.c gf_mx_v(stream->mx); stream 1067 src/media_tools/m2ts_mux.c stream->curr_pck.cts = curr_pck->cts; stream 1068 src/media_tools/m2ts_mux.c stream->curr_pck.data = curr_pck->data; stream 1069 src/media_tools/m2ts_mux.c stream->curr_pck.data_len = curr_pck->data_len; stream 1070 src/media_tools/m2ts_mux.c stream->curr_pck.dts = curr_pck->dts; stream 1071 src/media_tools/m2ts_mux.c stream->curr_pck.duration = curr_pck->duration; stream 1072 src/media_tools/m2ts_mux.c stream->curr_pck.flags = curr_pck->flags; stream 1073 src/media_tools/m2ts_mux.c stream->curr_pck.mpeg2_af_descriptors = curr_pck->mpeg2_af_descriptors; stream 1074 src/media_tools/m2ts_mux.c stream->curr_pck.mpeg2_af_descriptors_size = curr_pck->mpeg2_af_descriptors_size; stream 1077 src/media_tools/m2ts_mux.c stream->pck_first = curr_pck->next; stream 1079 src/media_tools/m2ts_mux.c stream->discard_data = GF_TRUE; stream 1081 src/media_tools/m2ts_mux.c gf_mx_v(stream->mx); stream 1084 src/media_tools/m2ts_mux.c if (!(stream->curr_pck.flags & GF_ESI_DATA_HAS_DTS)) stream 1085 src/media_tools/m2ts_mux.c stream->curr_pck.dts = stream->curr_pck.cts; stream 1088 src/media_tools/m2ts_mux.c if (!stream->program->pcr_init_time_set) { stream 1089 src/media_tools/m2ts_mux.c if (stream==stream->program->pcr) { stream 1090 src/media_tools/m2ts_mux.c if (stream->program->mux->init_pcr_value) { stream 1091 src/media_tools/m2ts_mux.c stream->program->pcr_init_time = stream->program->mux->init_pcr_value-1; stream 1093 src/media_tools/m2ts_mux.c while (!stream->program->pcr_init_time) stream 1094 src/media_tools/m2ts_mux.c stream->program->pcr_init_time = gf_rand(); stream 1096 src/media_tools/m2ts_mux.c stream->program->pcr_init_time_set = GF_TRUE; stream 1097 src/media_tools/m2ts_mux.c stream->program->ts_time_at_pcr_init = muxer->time; stream 1098 src/media_tools/m2ts_mux.c stream->program->num_pck_at_pcr_init = muxer->tot_pck_sent; stream 1100 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_INFO, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: Initializing PCR for program number %d: PCR %d - mux time %d:%09d\n", stream->pid, stream->program->number, stream->program->pcr_init_time, muxer->time.sec, muxer->time.nanosec)); stream 1103 src/media_tools/m2ts_mux.c if (stream->discard_data) gf_free(stream->curr_pck.data); stream 1104 src/media_tools/m2ts_mux.c stream->curr_pck.data = NULL; stream 1105 src/media_tools/m2ts_mux.c stream->curr_pck.data_len = 0; stream 1106 src/media_tools/m2ts_mux.c stream->pck_offset = 0; stream 1113 src/media_tools/m2ts_mux.c switch (stream->mpeg2_stream_type) { stream 1116 src/media_tools/m2ts_mux.c stream->sl_header.accessUnitStartFlag = (stream->curr_pck.flags & GF_ESI_DATA_AU_START) ? 1 : 0; stream 1117 src/media_tools/m2ts_mux.c stream->sl_header.accessUnitEndFlag = (stream->curr_pck.flags & GF_ESI_DATA_AU_END) ? 1 : 0; stream 1119 src/media_tools/m2ts_mux.c assert(stream->sl_header.accessUnitLength + stream->curr_pck.data_len < 65536); /*stream->sl_header.accessUnitLength type is u16*/ stream 1120 src/media_tools/m2ts_mux.c stream->sl_header.accessUnitLength += stream->curr_pck.data_len; stream 1122 src/media_tools/m2ts_mux.c stream->sl_header.randomAccessPointFlag = (stream->curr_pck.flags & GF_ESI_DATA_AU_RAP) ? 1: 0; stream 1123 src/media_tools/m2ts_mux.c stream->sl_header.compositionTimeStampFlag = (stream->curr_pck.flags & GF_ESI_DATA_HAS_CTS) ? 1 : 0; stream 1124 src/media_tools/m2ts_mux.c stream->sl_header.compositionTimeStamp = stream->curr_pck.cts; stream 1125 src/media_tools/m2ts_mux.c stream->sl_header.decodingTimeStampFlag = (stream->curr_pck.flags & GF_ESI_DATA_HAS_DTS) ? 1: 0; stream 1126 src/media_tools/m2ts_mux.c stream->sl_header.decodingTimeStamp = stream->curr_pck.dts; stream 1128 src/media_tools/m2ts_mux.c gf_m2ts_mux_table_update_mpeg4(stream, stream->table_id, muxer->ts_id, stream->curr_pck.data, stream->curr_pck.data_len, GF_TRUE, GF_FALSE, (stream->curr_pck.flags & GF_ESI_DATA_REPEAT) ? GF_FALSE : GF_TRUE, GF_FALSE); stream 1131 src/media_tools/m2ts_mux.c if (!(stream->ifce->caps & GF_ESI_AU_PULL_CAP)) { stream 1132 src/media_tools/m2ts_mux.c gf_free(stream->curr_pck.data); stream 1133 src/media_tools/m2ts_mux.c stream->curr_pck.data = NULL; stream 1134 src/media_tools/m2ts_mux.c stream->curr_pck.data_len = 0; stream 1143 src/media_tools/m2ts_mux.c stream->sl_header.accessUnitStartFlag = (stream->curr_pck.flags & GF_ESI_DATA_AU_START) ? 1 : 0; stream 1144 src/media_tools/m2ts_mux.c stream->sl_header.accessUnitEndFlag = (stream->curr_pck.flags & GF_ESI_DATA_AU_END) ? 1 : 0; stream 1146 src/media_tools/m2ts_mux.c assert(stream->sl_header.accessUnitLength + stream->curr_pck.data_len < 65536); /*stream->sl_header.accessUnitLength type is u16*/ stream 1147 src/media_tools/m2ts_mux.c stream->sl_header.accessUnitLength += stream->curr_pck.data_len; stream 1149 src/media_tools/m2ts_mux.c stream->sl_header.randomAccessPointFlag = (stream->curr_pck.flags & GF_ESI_DATA_AU_RAP) ? 1: 0; stream 1150 src/media_tools/m2ts_mux.c stream->sl_header.compositionTimeStampFlag = (stream->curr_pck.flags & GF_ESI_DATA_HAS_CTS) ? 1 : 0; stream 1151 src/media_tools/m2ts_mux.c stream->sl_header.compositionTimeStamp = stream->curr_pck.cts; stream 1152 src/media_tools/m2ts_mux.c stream->sl_header.decodingTimeStampFlag = (stream->curr_pck.flags & GF_ESI_DATA_HAS_DTS) ? 1: 0; stream 1153 src/media_tools/m2ts_mux.c stream->sl_header.decodingTimeStamp = stream->curr_pck.dts; stream 1155 src/media_tools/m2ts_mux.c src_data = stream->curr_pck.data; stream 1156 src/media_tools/m2ts_mux.c src_data_len = stream->curr_pck.data_len; stream 1157 src/media_tools/m2ts_mux.c stream->curr_pck.data_len = 0; stream 1158 src/media_tools/m2ts_mux.c stream->curr_pck.data = NULL; stream 1160 src/media_tools/m2ts_mux.c gf_sl_packetize(stream->ifce->sl_config, &stream->sl_header, src_data, src_data_len, &stream->curr_pck.data, &stream->curr_pck.data_len); stream 1163 src/media_tools/m2ts_mux.c if (!(stream->ifce->caps & GF_ESI_AU_PULL_CAP)) { stream 1166 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_INFO, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: Encapsulating MPEG-4 SL Data (%p - %p) on PES - SL Header size %d\n", stream->pid, src_data, stream->curr_pck.data, stream->curr_pck.data_len - src_data_len)); stream 1169 src/media_tools/m2ts_mux.c stream->discard_data = GF_TRUE; stream 1182 src/media_tools/m2ts_mux.c if (stream->ifce->decoder_config && (stream->last_aac_time + stream->ifce->repeat_rate < next_time)) { stream 1184 src/media_tools/m2ts_mux.c stream->last_aac_time = next_time; stream 1194 src/media_tools/m2ts_mux.c gf_m4a_get_config(stream->ifce->decoder_config, stream->ifce->decoder_config_size, &cfg); stream 1205 src/media_tools/m2ts_mux.c size = stream->curr_pck.data_len; stream 1215 src/media_tools/m2ts_mux.c stream->reframe_overhead = stream->curr_pck.data_len; stream 1216 src/media_tools/m2ts_mux.c gf_bs_write_data(bs, stream->curr_pck.data, stream->curr_pck.data_len); stream 1218 src/media_tools/m2ts_mux.c gf_free(stream->curr_pck.data); stream 1219 src/media_tools/m2ts_mux.c gf_bs_get_content(bs, &stream->curr_pck.data, &stream->curr_pck.data_len); stream 1221 src/media_tools/m2ts_mux.c stream->reframe_overhead = stream->curr_pck.data_len - stream->reframe_overhead; stream 1224 src/media_tools/m2ts_mux.c size = stream->curr_pck.data_len - 2; stream 1225 src/media_tools/m2ts_mux.c stream->curr_pck.data[1] |= (size>>8) & 0x1F; stream 1226 src/media_tools/m2ts_mux.c stream->curr_pck.data[2] = (size) & 0xFF; stream 1228 src/media_tools/m2ts_mux.c stream->discard_data = GF_TRUE; stream 1233 src/media_tools/m2ts_mux.c if (stream->ifce->decoder_config) { stream 1236 src/media_tools/m2ts_mux.c gf_m4a_get_config(stream->ifce->decoder_config, stream->ifce->decoder_config_size, &cfg); stream 1249 src/media_tools/m2ts_mux.c gf_bs_write_int(bs, 7+stream->curr_pck.data_len, 13); stream 1253 src/media_tools/m2ts_mux.c gf_bs_write_data(bs, stream->curr_pck.data, stream->curr_pck.data_len); stream 1255 src/media_tools/m2ts_mux.c gf_free(stream->curr_pck.data); stream 1256 src/media_tools/m2ts_mux.c gf_bs_get_content(bs, &stream->curr_pck.data, &stream->curr_pck.data_len); stream 1259 src/media_tools/m2ts_mux.c stream->reframe_overhead = 7; stream 1262 src/media_tools/m2ts_mux.c stream->discard_data = GF_TRUE; stream 1267 src/media_tools/m2ts_mux.c id3_tag_create(&stream->curr_pck.data, &stream->curr_pck.data_len); stream 1268 src/media_tools/m2ts_mux.c stream->discard_data = GF_TRUE; stream 1273 src/media_tools/m2ts_mux.c if (stream->start_pes_at_rap && (stream->curr_pck.flags & GF_ESI_DATA_AU_RAP) stream 1275 src/media_tools/m2ts_mux.c stream->program->mux->force_pat_pmt_state = GF_SEG_BOUNDARY_FORCE_PAT; stream 1276 src/media_tools/m2ts_mux.c stream->program->mux->force_pat = GF_TRUE; stream 1280 src/media_tools/m2ts_mux.c gf_m2ts_remap_timestamps_for_pes(stream, stream->curr_pck.flags, &stream->curr_pck.dts, &stream->curr_pck.cts, &stream->curr_pck.duration); stream 1283 src/media_tools/m2ts_mux.c stream->time = stream->program->ts_time_at_pcr_init; stream 1284 src/media_tools/m2ts_mux.c time_inc = stream->curr_pck.dts - stream->program->pcr_offset; stream 1286 src/media_tools/m2ts_mux.c gf_m2ts_time_inc(&stream->time, time_inc, 90000); stream 1288 src/media_tools/m2ts_mux.c if (stream == stream->program->pcr) { stream 1289 src/media_tools/m2ts_mux.c gf_m2ts_adjust_next_stream_time_for_pcr(muxer, stream); stream 1292 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_DEBUG, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: Next data schedule for %d:%09d - mux time %d:%09d\n", stream->pid, stream->time.sec, stream->time.nanosec, muxer->time.sec, muxer->time.nanosec)); stream 1295 src/media_tools/m2ts_mux.c if (!stream->last_br_time) { stream 1296 src/media_tools/m2ts_mux.c stream->last_br_time = stream->curr_pck.dts + 1; stream 1297 src/media_tools/m2ts_mux.c stream->bytes_since_last_time = 0; stream 1298 src/media_tools/m2ts_mux.c stream->pes_since_last_time = 0; stream 1300 src/media_tools/m2ts_mux.c u32 time_diff = (u32) (stream->curr_pck.dts + 1 - stream->last_br_time ); stream 1301 src/media_tools/m2ts_mux.c if ((stream->pes_since_last_time > 4) && (time_diff >= BITRATE_UPDATE_WINDOW)) { stream 1303 src/media_tools/m2ts_mux.c u64 r = 8*stream->bytes_since_last_time; stream 1307 src/media_tools/m2ts_mux.c if (stream->program->mux->fixed_rate || (stream->bit_rate < bitrate)) { stream 1308 src/media_tools/m2ts_mux.c stream->bit_rate = bitrate; stream 1309 src/media_tools/m2ts_mux.c stream->program->mux->needs_reconfig = GF_TRUE; stream 1311 src/media_tools/m2ts_mux.c stream->last_br_time = 0; stream 1312 src/media_tools/m2ts_mux.c stream->bytes_since_last_time = 0; stream 1313 src/media_tools/m2ts_mux.c stream->pes_since_last_time = 0; stream 1317 src/media_tools/m2ts_mux.c stream->pes_since_last_time ++; stream 1318 src/media_tools/m2ts_mux.c return stream->scheduling_priority; stream 1321 src/media_tools/m2ts_mux.c static GFINLINE u64 gf_m2ts_get_pcr(GF_M2TS_Mux_Stream *stream) stream 1325 src/media_tools/m2ts_mux.c if (stream->program->mux->fixed_rate ) { stream 1326 src/media_tools/m2ts_mux.c Double abs_pcr = (Double) (stream->program->mux->tot_pck_sent - stream->program->num_pck_at_pcr_init); stream 1329 src/media_tools/m2ts_mux.c abs_pcr /= stream->program->mux->bit_rate; stream 1330 src/media_tools/m2ts_mux.c pcr = (u64) abs_pcr + stream->program->pcr_init_time; stream 1334 src/media_tools/m2ts_mux.c pcr = (stream->curr_pck.dts - stream->program->pcr_offset) * 300; stream 1339 src/media_tools/m2ts_mux.c void gf_m2ts_stream_update_data_following(GF_M2TS_Mux_Stream *stream) stream 1342 src/media_tools/m2ts_mux.c stream->next_payload_size = 0; stream 1343 src/media_tools/m2ts_mux.c stream->next_next_payload_size = 0; stream 1345 src/media_tools/m2ts_mux.c stream->next_pck_flags = 0; stream 1346 src/media_tools/m2ts_mux.c stream->copy_from_next_packets = 0; stream 1349 src/media_tools/m2ts_mux.c if (stream->force_single_au) return; stream 1351 src/media_tools/m2ts_mux.c if (stream->ifce->caps & GF_ESI_AU_PULL_CAP) { stream 1355 src/media_tools/m2ts_mux.c stream->ifce->input_ctrl(stream->ifce, GF_ESI_INPUT_DATA_PULL, &test_pck); stream 1357 src/media_tools/m2ts_mux.c stream->next_payload_size = test_pck.data_len; stream 1358 src/media_tools/m2ts_mux.c stream->next_pck_flags = test_pck.flags; stream 1359 src/media_tools/m2ts_mux.c stream->next_pck_cts = test_pck.cts; stream 1360 src/media_tools/m2ts_mux.c stream->next_pck_dts = test_pck.dts; stream 1364 src/media_tools/m2ts_mux.c if (!stream->pck_first && stream->ifce->input_ctrl) stream->ifce->input_ctrl(stream->ifce, GF_ESI_INPUT_DATA_FLUSH, NULL); stream 1365 src/media_tools/m2ts_mux.c if (stream->pck_first) { stream 1366 src/media_tools/m2ts_mux.c stream->next_payload_size = stream->pck_first->data_len; stream 1367 src/media_tools/m2ts_mux.c stream->next_pck_cts = stream->pck_first->cts; stream 1368 src/media_tools/m2ts_mux.c stream->next_pck_dts = stream->pck_first->dts; stream 1369 src/media_tools/m2ts_mux.c stream->next_pck_flags = stream->pck_first->flags; stream 1371 src/media_tools/m2ts_mux.c if (!stream->pck_first->next && stream->ifce->input_ctrl) stream->ifce->input_ctrl(stream->ifce, GF_ESI_INPUT_DATA_FLUSH, NULL); stream 1372 src/media_tools/m2ts_mux.c if (stream->pck_first->next) { stream 1373 src/media_tools/m2ts_mux.c stream->next_next_payload_size = stream->pck_first->next->data_len; stream 1380 src/media_tools/m2ts_mux.c if (stream->start_pes_at_rap && (stream->next_pck_flags & GF_ESI_DATA_AU_RAP) ) { stream 1385 src/media_tools/m2ts_mux.c else if (stream->program->mux->force_pat_pmt_state) { stream 1390 src/media_tools/m2ts_mux.c stream->next_payload_size = 0; stream 1391 src/media_tools/m2ts_mux.c stream->next_pck_cts = 0; stream 1392 src/media_tools/m2ts_mux.c stream->next_pck_dts = 0; stream 1393 src/media_tools/m2ts_mux.c stream->next_pck_flags = 0; stream 1396 src/media_tools/m2ts_mux.c if (stream->next_payload_size) { stream 1397 src/media_tools/m2ts_mux.c stream->next_payload_size += stream->reframe_overhead; stream 1398 src/media_tools/m2ts_mux.c if (stream->next_next_payload_size) stream 1399 src/media_tools/m2ts_mux.c stream->next_next_payload_size += stream->reframe_overhead; stream 1401 src/media_tools/m2ts_mux.c gf_m2ts_remap_timestamps_for_pes(stream, stream->next_pck_flags, &stream->next_pck_dts, &stream->next_pck_cts, NULL); stream 1404 src/media_tools/m2ts_mux.c if (!(stream->next_pck_flags & GF_ESI_DATA_HAS_DTS)) stream 1405 src/media_tools/m2ts_mux.c stream->next_pck_dts = stream->next_pck_cts; stream 1410 src/media_tools/m2ts_mux.c Bool gf_m2ts_stream_compute_pes_length(GF_M2TS_Mux_Stream *stream, u32 payload_length) stream 1412 src/media_tools/m2ts_mux.c assert(stream->pes_data_remain==0); stream 1413 src/media_tools/m2ts_mux.c stream->pes_data_len = stream->curr_pck.data_len - stream->pck_offset; stream 1415 src/media_tools/m2ts_mux.c stream->copy_from_next_packets = 0; stream 1417 src/media_tools/m2ts_mux.c if (stream->next_payload_size) { stream 1418 src/media_tools/m2ts_mux.c u32 pck_size = stream->curr_pck.data_len - stream->pck_offset; stream 1429 src/media_tools/m2ts_mux.c if (stream->prevent_two_au_start_in_pes && !stream->pck_offset) { stream 1436 src/media_tools/m2ts_mux.c else if (stream->next_payload_size) { stream 1438 src/media_tools/m2ts_mux.c while (ts_bytes < pck_size + stream->next_payload_size) { stream 1443 src/media_tools/m2ts_mux.c if ((stream->prevent_two_au_start_in_pes && (ts_bytes>pck_size + stream->next_payload_size)) stream 1444 src/media_tools/m2ts_mux.c || !stream->next_next_payload_size stream 1449 src/media_tools/m2ts_mux.c ts_bytes = pck_size + stream->next_payload_size; stream 1455 src/media_tools/m2ts_mux.c stream->copy_from_next_packets = ts_bytes - pck_size; stream 1458 src/media_tools/m2ts_mux.c if (stream->pes_data_len > skipped) stream 1459 src/media_tools/m2ts_mux.c stream->pes_data_len -= skipped; stream 1462 src/media_tools/m2ts_mux.c if (stream->min_bytes_copy_from_next && stream->copy_from_next_packets) { stream 1465 src/media_tools/m2ts_mux.c if (stream->copy_from_next_packets < stream->min_bytes_copy_from_next) { stream 1466 src/media_tools/m2ts_mux.c stream->copy_from_next_packets = 0; stream 1467 src/media_tools/m2ts_mux.c stream->next_payload_size = 0; stream 1468 src/media_tools/m2ts_mux.c stream->next_pck_flags = 0; stream 1473 src/media_tools/m2ts_mux.c if ((stream->copy_from_next_packets > stream->next_payload_size) stream 1474 src/media_tools/m2ts_mux.c && (stream->copy_from_next_packets - stream->next_payload_size < stream->min_bytes_copy_from_next) stream 1476 src/media_tools/m2ts_mux.c stream->copy_from_next_packets = stream->next_payload_size; stream 1480 src/media_tools/m2ts_mux.c if (stream->pck_offset && !stream->copy_from_next_packets && stream->next_payload_size) { stream 1481 src/media_tools/m2ts_mux.c stream->copy_from_next_packets = 0; stream 1482 src/media_tools/m2ts_mux.c stream->next_payload_size = 0; stream 1483 src/media_tools/m2ts_mux.c stream->next_pck_flags = 0; stream 1487 src/media_tools/m2ts_mux.c if (stream->ifce->caps & GF_ESI_STREAM_IS_OVER) { stream 1489 src/media_tools/m2ts_mux.c while (stream->copy_from_next_packets > stream->next_payload_size) { stream 1490 src/media_tools/m2ts_mux.c if (stream->copy_from_next_packets < 184) { stream 1491 src/media_tools/m2ts_mux.c stream->copy_from_next_packets = 0; stream 1494 src/media_tools/m2ts_mux.c stream->copy_from_next_packets -= 184; stream 1497 src/media_tools/m2ts_mux.c stream->pes_data_len += stream->next_payload_size; stream 1499 src/media_tools/m2ts_mux.c stream->pes_data_len += stream->copy_from_next_packets; stream 1502 src/media_tools/m2ts_mux.c stream->pes_data_remain = stream->pes_data_len; stream 1506 src/media_tools/m2ts_mux.c static u32 gf_m2ts_stream_get_pes_header_length(GF_M2TS_Mux_Stream *stream) stream 1509 src/media_tools/m2ts_mux.c flags = stream->pck_offset ? stream->next_pck_flags : stream->curr_pck.flags; stream 1512 src/media_tools/m2ts_mux.c if (stream->pes_data_remain) return 0; stream 1522 src/media_tools/m2ts_mux.c u32 gf_m2ts_stream_add_pes_header(GF_BitStream *bs, GF_M2TS_Mux_Stream *stream) stream 1529 src/media_tools/m2ts_mux.c gf_bs_write_u8(bs, stream->mpeg2_stream_id);// stream id stream 1532 src/media_tools/m2ts_mux.c if (stream->pck_offset && stream->copy_from_next_packets) { stream 1533 src/media_tools/m2ts_mux.c use_pts = (stream->next_pck_flags & GF_ESI_DATA_HAS_CTS) ? GF_TRUE : GF_FALSE; stream 1534 src/media_tools/m2ts_mux.c use_dts = (stream->next_pck_flags & GF_ESI_DATA_HAS_DTS) ? GF_TRUE : GF_FALSE; stream 1535 src/media_tools/m2ts_mux.c dts = stream->next_pck_dts; stream 1536 src/media_tools/m2ts_mux.c cts = stream->next_pck_cts; stream 1539 src/media_tools/m2ts_mux.c else if (stream->pck_offset) { stream 1543 src/media_tools/m2ts_mux.c use_pts = (stream->curr_pck.flags & GF_ESI_DATA_HAS_CTS) ? GF_TRUE : GF_FALSE; stream 1544 src/media_tools/m2ts_mux.c use_dts = (stream->curr_pck.flags & GF_ESI_DATA_HAS_DTS) ? GF_TRUE : GF_FALSE; stream 1545 src/media_tools/m2ts_mux.c dts = stream->curr_pck.dts; stream 1546 src/media_tools/m2ts_mux.c cts = stream->curr_pck.cts; stream 1550 src/media_tools/m2ts_mux.c assert(stream->pes_data_len); stream 1551 src/media_tools/m2ts_mux.c pes_len = stream->pes_data_len + 3; // 3 = header size stream 1561 src/media_tools/m2ts_mux.c gf_bs_write_int(bs, stream->pck_offset ? 0 : 1, 1); // alignment indicator - we could also check start codes to see if we are aligned at slice/video packet level stream 1596 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_DEBUG, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: Adding PES header at PCR "LLD" - has PTS %d ("LLU") - has DTS %d ("LLU") - Payload length %d\n", stream->pid, gf_m2ts_get_pcr(stream)/300, use_pts, cts, use_dts, dts, pes_len)); stream 1601 src/media_tools/m2ts_mux.c void gf_m2ts_mux_pes_get_next_packet(GF_M2TS_Mux_Stream *stream, char *packet) stream 1607 src/media_tools/m2ts_mux.c assert(stream->pid); stream 1610 src/media_tools/m2ts_mux.c if (stream->pcr_only_mode) { stream 1616 src/media_tools/m2ts_mux.c hdr_len = gf_m2ts_stream_get_pes_header_length(stream); stream 1625 src/media_tools/m2ts_mux.c gf_m2ts_stream_update_data_following(stream); stream 1626 src/media_tools/m2ts_mux.c hdr_len = gf_m2ts_stream_get_pes_header_length(stream); stream 1633 src/media_tools/m2ts_mux.c if (stream == stream->program->pcr) { stream 1637 src/media_tools/m2ts_mux.c if (stream->program->mux->force_pat_pmt_state == GF_SEG_BOUNDARY_FORCE_PCR) { stream 1638 src/media_tools/m2ts_mux.c stream->program->mux->force_pat_pmt_state = GF_SEG_BOUNDARY_NONE; stream 1642 src/media_tools/m2ts_mux.c if (!needs_pcr && (stream->program->mux->real_time || stream->program->mux->fixed_rate) ) { stream 1645 src/media_tools/m2ts_mux.c if (stream->program->mux->fixed_rate) { stream 1647 src/media_tools/m2ts_mux.c clock = 1 + stream->program->mux->tot_pck_sent - stream->program->nb_pck_last_pcr; stream 1649 src/media_tools/m2ts_mux.c clock /= stream->program->mux->bit_rate; stream 1650 src/media_tools/m2ts_mux.c if (clock >= 500 + stream->program->mux->pcr_update_ms*1000) { stream 1655 src/media_tools/m2ts_mux.c if (!needs_pcr && stream->program->mux->real_time) { stream 1657 src/media_tools/m2ts_mux.c diff = (u32) (clock - stream->program->sys_clock_at_last_pcr); stream 1659 src/media_tools/m2ts_mux.c if (diff >= 100 + stream->program->mux->pcr_update_ms*1000) { stream 1672 src/media_tools/m2ts_mux.c if (hdr_len && stream->curr_pck.mpeg2_af_descriptors) { stream 1677 src/media_tools/m2ts_mux.c payload_length -= 2 + stream->curr_pck.mpeg2_af_descriptors_size; //AF extension field and AF descriptor stream 1681 src/media_tools/m2ts_mux.c assert(!stream->pes_data_remain); stream 1682 src/media_tools/m2ts_mux.c if (! gf_m2ts_stream_compute_pes_length(stream, payload_length)) { stream 1687 src/media_tools/m2ts_mux.c assert(stream->pes_data_remain==stream->pes_data_len); stream 1693 src/media_tools/m2ts_mux.c copy_next = stream->copy_from_next_packets; stream 1694 src/media_tools/m2ts_mux.c payload_to_copy = stream->curr_pck.data_len - stream->pck_offset; stream 1696 src/media_tools/m2ts_mux.c if (payload_to_copy >= stream->pes_data_remain) { stream 1697 src/media_tools/m2ts_mux.c payload_to_copy = stream->pes_data_remain; stream 1734 src/media_tools/m2ts_mux.c u64 pcr = (s64) gf_m2ts_get_pcr(stream)/300; stream 1736 src/media_tools/m2ts_mux.c stream->pid, stream->curr_pck.data_len, stream->curr_pck.dts, pcr, (s64) stream->curr_pck.dts - (s64) pcr, stream 1737 src/media_tools/m2ts_mux.c stream->time.sec, stream->time.nanosec, stream->program->mux->time.sec, stream->program->mux->time.nanosec, stream 1738 src/media_tools/m2ts_mux.c gf_m2ts_time_diff_us(&stream->program->mux->time, &stream->time) stream 1745 src/media_tools/m2ts_mux.c if (!stream->continuity_counter) stream->continuity_counter=15; stream 1746 src/media_tools/m2ts_mux.c else stream->continuity_counter--; stream 1753 src/media_tools/m2ts_mux.c gf_bs_write_int(bs, stream->pid, 13); // pid stream 1756 src/media_tools/m2ts_mux.c gf_bs_write_int(bs, stream->continuity_counter, 4); // continuity counter stream 1758 src/media_tools/m2ts_mux.c if (stream->continuity_counter < 15) stream->continuity_counter++; stream 1759 src/media_tools/m2ts_mux.c else stream->continuity_counter=0; stream 1766 src/media_tools/m2ts_mux.c pcr = gf_m2ts_get_pcr(stream); stream 1768 src/media_tools/m2ts_mux.c if (stream->program->mux->real_time || stream->program->mux->fixed_rate) { stream 1770 src/media_tools/m2ts_mux.c clock = stream->program->mux->tot_pck_sent - stream->program->nb_pck_last_pcr; stream 1772 src/media_tools/m2ts_mux.c clock /= stream->program->mux->bit_rate; stream 1775 src/media_tools/m2ts_mux.c if (clock > 2000 + stream->program->mux->pcr_update_ms*1000) { stream 1776 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_INFO, GF_LOG_CONTAINER, ("[MPEG2-TS Muxer] PCR sent %d us later than requested PCR send rate %d ms\n", (s32) (clock - stream->program->mux->pcr_update_ms*1000), stream->program->mux->pcr_update_ms )); stream 1779 src/media_tools/m2ts_mux.c if (stream->program->mux->real_time) { stream 1780 src/media_tools/m2ts_mux.c u32 diff = (s32) (now - stream->program->sys_clock_at_last_pcr); stream 1783 src/media_tools/m2ts_mux.c if (diff > 5000 + 2*stream->program->mux->pcr_update_ms*1000 ) { stream 1784 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_INFO, GF_LOG_CONTAINER, ("[MPEG2-TS Muxer] Sending PCR %d us too late (PCR send rate %d ms)\n", (u32) (diff - stream->program->mux->pcr_update_ms*1000), stream->program->mux->pcr_update_ms )); stream 1789 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_INFO, GF_LOG_CONTAINER, ("[MPEG2-TS Muxer] Inserted PCR "LLD" (%d @90kHz) at mux time %d:%09d\n", pcr, (u32) (pcr/300), stream->program->mux->time.sec, stream->program->mux->time.nanosec )); stream 1790 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_DEBUG, GF_LOG_CONTAINER, ("[MPEG2-TS Muxer] PCR diff to STB in ms %d - sys clock diff in ms %d - DTS diff %d\n", (u32) (pcr - stream->program->last_pcr) / 27000, now - stream->program->sys_clock_at_last_pcr, (stream->curr_pck.dts - stream->program->last_dts)/90)); stream 1792 src/media_tools/m2ts_mux.c stream->program->sys_clock_at_last_pcr = now; stream 1793 src/media_tools/m2ts_mux.c stream->program->last_dts = stream->curr_pck.dts; stream 1794 src/media_tools/m2ts_mux.c stream->program->nb_pck_last_pcr = stream->program->mux->tot_pck_sent; stream 1796 src/media_tools/m2ts_mux.c is_rap = (hdr_len && (stream->curr_pck.flags & GF_ESI_DATA_AU_RAP) ) ? GF_TRUE : GF_FALSE; stream 1797 src/media_tools/m2ts_mux.c gf_m2ts_add_adaptation(stream->program, bs, stream->pid, needs_pcr, pcr, is_rap, padding_length, hdr_len ? stream->curr_pck.mpeg2_af_descriptors : NULL, hdr_len ? stream->curr_pck.mpeg2_af_descriptors_size : 0); stream 1799 src/media_tools/m2ts_mux.c if (stream->curr_pck.mpeg2_af_descriptors) { stream 1800 src/media_tools/m2ts_mux.c gf_free(stream->curr_pck.mpeg2_af_descriptors); stream 1801 src/media_tools/m2ts_mux.c stream->curr_pck.mpeg2_af_descriptors = NULL; stream 1802 src/media_tools/m2ts_mux.c stream->curr_pck.mpeg2_af_descriptors_size = 0; stream 1806 src/media_tools/m2ts_mux.c stream->program->mux->tot_pes_pad_bytes += padding_length; stream 1808 src/media_tools/m2ts_mux.c if (hdr_len) gf_m2ts_stream_add_pes_header(bs, stream); stream 1818 src/media_tools/m2ts_mux.c assert(stream->curr_pck.data_len - stream->pck_offset >= payload_to_copy); stream 1819 src/media_tools/m2ts_mux.c memcpy(packet+pos, stream->curr_pck.data + stream->pck_offset, payload_to_copy); stream 1820 src/media_tools/m2ts_mux.c stream->pck_offset += payload_to_copy; stream 1821 src/media_tools/m2ts_mux.c assert(stream->pes_data_remain >= payload_to_copy); stream 1822 src/media_tools/m2ts_mux.c stream->pes_data_remain -= payload_to_copy; stream 1825 src/media_tools/m2ts_mux.c gf_m2ts_time_inc(&stream->time, 1504/*188*8*/, stream->program->mux->bit_rate); stream 1827 src/media_tools/m2ts_mux.c if (stream->pck_offset == stream->curr_pck.data_len) { stream 1828 src/media_tools/m2ts_mux.c u64 pcr = gf_m2ts_get_pcr(stream)/300; stream 1829 src/media_tools/m2ts_mux.c if (stream->program->mux->real_time && !stream->program->mux->fixed_rate && gf_m2ts_time_less(&stream->time, &stream->program->mux->time) ) { stream 1831 src/media_tools/m2ts_mux.c stream->pid, stream->curr_pck.dts, pcr, stream 1832 src/media_tools/m2ts_mux.c stream->time.sec, stream->time.nanosec, stream->program->mux->time.sec, stream->program->mux->time.nanosec, stream 1833 src/media_tools/m2ts_mux.c stream->program->mux->bit_rate stream 1835 src/media_tools/m2ts_mux.c } else if (stream->curr_pck.dts < pcr) { stream 1837 src/media_tools/m2ts_mux.c (pcr - stream->curr_pck.dts)*100/9, stream->pid, stream->curr_pck.dts, stream->curr_pck.data_len, pcr, stream 1838 src/media_tools/m2ts_mux.c stream->time.sec, stream->time.nanosec, stream->program->mux->time.sec, stream->program->mux->time.nanosec stream 1840 src/media_tools/m2ts_mux.c } else if (stream->curr_pck.cts < pcr) { stream 1842 src/media_tools/m2ts_mux.c pcr - stream->curr_pck.dts, stream->pid, stream->curr_pck.dts, stream->curr_pck.data_len, pcr, stream 1843 src/media_tools/m2ts_mux.c stream->time.sec, stream->time.nanosec, stream->program->mux->time.sec, stream->program->mux->time.nanosec stream 1847 src/media_tools/m2ts_mux.c stream->pid, stream->curr_pck.dts, pcr, stream 1848 src/media_tools/m2ts_mux.c stream->time.sec, stream->time.nanosec, stream->program->mux->time.sec, stream->program->mux->time.nanosec stream 1854 src/media_tools/m2ts_mux.c if (stream->discard_data) gf_free(stream->curr_pck.data); stream 1855 src/media_tools/m2ts_mux.c stream->curr_pck.data = NULL; stream 1856 src/media_tools/m2ts_mux.c stream->curr_pck.data_len = 0; stream 1857 src/media_tools/m2ts_mux.c stream->pck_offset = 0; stream 1861 src/media_tools/m2ts_mux.c if (gf_m2ts_time_less(&stream->program->mux->time, &stream->time) ) { stream 1862 src/media_tools/m2ts_mux.c s32 drift = gf_m2ts_time_diff_us(&stream->program->mux->time, &stream->time); stream 1863 src/media_tools/m2ts_mux.c GF_LOG( (drift>1000) ? GF_LOG_WARNING : GF_LOG_INFO, GF_LOG_CONTAINER, ("[MPEG2-TS Muxer] PES PID %d sent %d us too late\n", stream->pid, drift) ); stream 1868 src/media_tools/m2ts_mux.c if (stream->copy_from_next_packets) { stream 1873 src/media_tools/m2ts_mux.c while (stream->pes_data_remain) { stream 1875 src/media_tools/m2ts_mux.c Bool res = stream->process(stream->program->mux, stream); stream 1877 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_WARNING, GF_LOG_CONTAINER, ("[MPEG2-TS Muxer] Not enough data to fill current PES (PID %d) - filling with 0xFF\n", stream->pid) ); stream 1880 src/media_tools/m2ts_mux.c if (stream->copy_from_next_packets > copy_next) { stream 1881 src/media_tools/m2ts_mux.c stream->copy_from_next_packets -= copy_next; stream 1883 src/media_tools/m2ts_mux.c stream->copy_from_next_packets = 0; stream 1887 src/media_tools/m2ts_mux.c if (copy_next > stream->curr_pck.data_len) { stream 1888 src/media_tools/m2ts_mux.c remain = copy_next - stream->curr_pck.data_len; stream 1889 src/media_tools/m2ts_mux.c copy_next = stream->curr_pck.data_len; stream 1892 src/media_tools/m2ts_mux.c memcpy(packet+pos, stream->curr_pck.data + stream->pck_offset, copy_next); stream 1893 src/media_tools/m2ts_mux.c stream->pck_offset += copy_next; stream 1894 src/media_tools/m2ts_mux.c assert(stream->pes_data_remain >= copy_next); stream 1895 src/media_tools/m2ts_mux.c stream->pes_data_remain -= copy_next; stream 1897 src/media_tools/m2ts_mux.c if (stream->copy_from_next_packets > copy_next) { stream 1898 src/media_tools/m2ts_mux.c stream->copy_from_next_packets -= copy_next; stream 1900 src/media_tools/m2ts_mux.c stream->copy_from_next_packets = 0; stream 1903 src/media_tools/m2ts_mux.c if (stream->pck_offset == stream->curr_pck.data_len) { stream 1904 src/media_tools/m2ts_mux.c assert(!remain || (remain>=stream->min_bytes_copy_from_next)); stream 1906 src/media_tools/m2ts_mux.c if (stream->discard_data) gf_free(stream->curr_pck.data); stream 1907 src/media_tools/m2ts_mux.c stream->curr_pck.data = NULL; stream 1908 src/media_tools/m2ts_mux.c stream->curr_pck.data_len = 0; stream 1909 src/media_tools/m2ts_mux.c stream->pck_offset = 0; stream 1916 src/media_tools/m2ts_mux.c else if (stream->program->mux->force_pat_pmt_state==GF_SEG_BOUNDARY_START) { stream 1917 src/media_tools/m2ts_mux.c stream->program->mux->force_pat_pmt_state = GF_SEG_BOUNDARY_FORCE_PAT; stream 1918 src/media_tools/m2ts_mux.c stream->program->mux->force_pat = GF_TRUE; stream 1921 src/media_tools/m2ts_mux.c stream->bytes_since_last_time += 188; stream 1926 src/media_tools/m2ts_mux.c GF_M2TS_Mux_Stream *stream; stream 1928 src/media_tools/m2ts_mux.c GF_SAFEALLOC(stream, GF_M2TS_Mux_Stream); stream 1929 src/media_tools/m2ts_mux.c if (!stream) { stream 1933 src/media_tools/m2ts_mux.c stream->pid = pid; stream 1934 src/media_tools/m2ts_mux.c stream->process = gf_m2ts_stream_process_pes; stream 1936 src/media_tools/m2ts_mux.c return stream; stream 1943 src/media_tools/m2ts_mux.c GF_M2TS_Mux_Stream *stream = (GF_M2TS_Mux_Stream *)_self->output_udta; stream 1948 src/media_tools/m2ts_mux.c if (stream->force_new || (esi_pck->flags & GF_ESI_DATA_AU_START)) { stream 1949 src/media_tools/m2ts_mux.c if (stream->pck_reassembler) { stream 1950 src/media_tools/m2ts_mux.c gf_mx_p(stream->mx); stream 1951 src/media_tools/m2ts_mux.c if (!stream->pck_first) { stream 1952 src/media_tools/m2ts_mux.c stream->pck_first = stream->pck_last = stream->pck_reassembler; stream 1954 src/media_tools/m2ts_mux.c stream->pck_last->next = stream->pck_reassembler; stream 1955 src/media_tools/m2ts_mux.c stream->pck_last = stream->pck_reassembler; stream 1957 src/media_tools/m2ts_mux.c gf_mx_v(stream->mx); stream 1958 src/media_tools/m2ts_mux.c stream->pck_reassembler = NULL; stream 1961 src/media_tools/m2ts_mux.c if (!stream->pck_reassembler) { stream 1962 src/media_tools/m2ts_mux.c GF_SAFEALLOC(stream->pck_reassembler, GF_M2TS_Packet); stream 1963 src/media_tools/m2ts_mux.c if (!stream->pck_reassembler) { stream 1964 src/media_tools/m2ts_mux.c GF_LOG(GF_LOG_ERROR, GF_LOG_CONTAINER, ("[MPEG-2 TS Muxer] PID %d: fail to allocate packet reassembler\n", stream->pid)); stream 1968 src/media_tools/m2ts_mux.c stream->pck_reassembler->cts = esi_pck->cts; stream 1969 src/media_tools/m2ts_mux.c stream->pck_reassembler->dts = esi_pck->dts; stream 1970 src/media_tools/m2ts_mux.c stream->pck_reassembler->duration = esi_pck->duration; stream 1972 src/media_tools/m2ts_mux.c stream->pck_reassembler->mpeg2_af_descriptors = (char*)gf_realloc(stream->pck_reassembler->mpeg2_af_descriptors, sizeof(u8)* (stream->pck_reassembler->mpeg2_af_descriptors_size + esi_pck->mpeg2_af_descriptors_size) ); stream 1973 src/media_tools/m2ts_mux.c memcpy(stream->pck_reassembler->mpeg2_af_descriptors + stream->pck_reassembler->mpeg2_af_descriptors_size, esi_pck->mpeg2_af_descriptors, sizeof(u8)* esi_pck->mpeg2_af_descriptors_size ); stream 1974 src/media_tools/m2ts_mux.c stream->pck_reassembler->mpeg2_af_descriptors_size += esi_pck->mpeg2_af_descriptors_size; stream 1978 src/media_tools/m2ts_mux.c stream->force_new = esi_pck->flags & GF_ESI_DATA_AU_END ? GF_TRUE : GF_FALSE; stream 1980 src/media_tools/m2ts_mux.c stream->pck_reassembler->data = (char*)gf_realloc(stream->pck_reassembler->data , sizeof(char)*(stream->pck_reassembler->data_len+esi_pck->data_len) ); stream 1981 src/media_tools/m2ts_mux.c memcpy(stream->pck_reassembler->data + stream->pck_reassembler->data_len, esi_pck->data, esi_pck->data_len); stream 1982 src/media_tools/m2ts_mux.c stream->pck_reassembler->data_len += esi_pck->data_len; stream 1984 src/media_tools/m2ts_mux.c stream->pck_reassembler->flags |= esi_pck->flags; stream 1985 src/media_tools/m2ts_mux.c if (stream->force_new) { stream 1986 src/media_tools/m2ts_mux.c gf_mx_p(stream->mx); stream 1987 src/media_tools/m2ts_mux.c if (!stream->pck_first) { stream 1988 src/media_tools/m2ts_mux.c stream->pck_first = stream->pck_last = stream->pck_reassembler; stream 1990 src/media_tools/m2ts_mux.c stream->pck_last->next = stream->pck_reassembler; stream 1991 src/media_tools/m2ts_mux.c stream->pck_last = stream->pck_reassembler; stream 1993 src/media_tools/m2ts_mux.c gf_mx_v(stream->mx); stream 1994 src/media_tools/m2ts_mux.c stream->pck_reassembler = NULL; stream 2001 src/media_tools/m2ts_mux.c static void gf_m2ts_stream_set_default_slconfig(GF_M2TS_Mux_Stream *stream) stream 2003 src/media_tools/m2ts_mux.c if (!stream->ifce->sl_config) { stream 2004 src/media_tools/m2ts_mux.c stream->ifce->sl_config = (GF_SLConfig *)gf_odf_desc_new(GF_ODF_SLC_TAG); stream 2005 src/media_tools/m2ts_mux.c stream->ifce->sl_config->useAccessUnitStartFlag = 1; stream 2006 src/media_tools/m2ts_mux.c stream->ifce->sl_config->useAccessUnitEndFlag = 1; stream 2007 src/media_tools/m2ts_mux.c stream->ifce->sl_config->useRandomAccessPointFlag = 1; stream 2008 src/media_tools/m2ts_mux.c stream->ifce->sl_config->useTimestampsFlag = 1; stream 2028 src/media_tools/m2ts_mux.c static void gf_m2ts_stream_add_hierarchy_descriptor(GF_M2TS_Mux_Stream *stream) stream 2033 src/media_tools/m2ts_mux.c if (!stream || !stream->program || !stream->program->pmt) return; stream 2049 src/media_tools/m2ts_mux.c gf_bs_write_int(bs, gf_m2ts_stream_index(stream->program, stream->pid, 0), 6); stream 2055 src/media_tools/m2ts_mux.c gf_bs_write_int(bs, gf_m2ts_stream_index(stream->program, 0, stream->ifce->depends_on_stream), 6); stream 2059 src/media_tools/m2ts_mux.c gf_bs_write_int(bs, stream->ifce->stream_id, 6); stream 2068 src/media_tools/m2ts_mux.c gf_list_add(stream->loop_descriptors, desc); stream 2096 src/media_tools/m2ts_mux.c static void gf_m2ts_stream_add_metadata_descriptor(GF_M2TS_Mux_Stream *stream) stream 2117 src/media_tools/m2ts_mux.c gf_list_add(stream->loop_descriptors, desc); stream 2123 src/media_tools/m2ts_mux.c GF_M2TS_Mux_Stream *stream, *st; stream 2125 src/media_tools/m2ts_mux.c stream = gf_m2ts_stream_new(pid); stream 2126 src/media_tools/m2ts_mux.c stream->ifce = ifce; stream 2127 src/media_tools/m2ts_mux.c stream->pid = pid; stream 2128 src/media_tools/m2ts_mux.c stream->program = program; stream 2129 src/media_tools/m2ts_mux.c if (is_pcr) program->pcr = stream; stream 2130 src/media_tools/m2ts_mux.c stream->loop_descriptors = gf_list_new(); stream 2135 src/media_tools/m2ts_mux.c stream->next = program->streams; stream 2136 src/media_tools/m2ts_mux.c program->streams = stream; stream 2140 src/media_tools/m2ts_mux.c st->next = stream; stream 2143 src/media_tools/m2ts_mux.c program->streams = stream; stream 2146 src/media_tools/m2ts_mux.c stream->bit_rate = ifce->bit_rate; stream 2147 src/media_tools/m2ts_mux.c stream->scheduling_priority = 1; stream 2149 src/media_tools/m2ts_mux.c stream->force_single_au = (stream->program->mux->au_pes_mode == GF_M2TS_PACK_ALL) ? GF_FALSE : GF_TRUE; stream 2154 src/media_tools/m2ts_mux.c stream->mpeg2_stream_id = 0xE0; stream 2158 src/media_tools/m2ts_mux.c stream->prevent_two_au_start_in_pes = GF_TRUE; stream 2161 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_VIDEO_MPEG4; stream 2164 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_VIDEO_H264; stream 2167 src/media_tools/m2ts_mux.c stream->min_bytes_copy_from_next = 11; stream 2170 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_VIDEO_SVC; stream 2173 src/media_tools/m2ts_mux.c stream->min_bytes_copy_from_next = 11; stream 2174 src/media_tools/m2ts_mux.c gf_m2ts_stream_add_hierarchy_descriptor(stream); stream 2177 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_VIDEO_HEVC; stream 2180 src/media_tools/m2ts_mux.c stream->min_bytes_copy_from_next = 12; stream 2184 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_VIDEO_SHVC; stream 2187 src/media_tools/m2ts_mux.c stream->min_bytes_copy_from_next = 12; stream 2188 src/media_tools/m2ts_mux.c gf_m2ts_stream_add_hierarchy_descriptor(stream); stream 2190 src/media_tools/m2ts_mux.c stream->force_single_au = GF_TRUE; stream 2193 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_VIDEO_MPEG1; stream 2201 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_VIDEO_MPEG2; stream 2206 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_SYSTEMS_MPEG4_PES; stream 2207 src/media_tools/m2ts_mux.c stream->force_single_au = GF_TRUE; stream 2208 src/media_tools/m2ts_mux.c stream->mpeg2_stream_id = 0xFA; stream 2209 src/media_tools/m2ts_mux.c gf_m2ts_stream_set_default_slconfig(stream); stream 2217 src/media_tools/m2ts_mux.c stream->force_single_au = (stream->program->mux->au_pes_mode == GF_M2TS_PACK_NONE) ? GF_TRUE : GF_FALSE; stream 2220 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_AUDIO_MPEG1; stream 2223 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_AUDIO_MPEG2; stream 2229 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_AUDIO_LATM_AAC; stream 2230 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_AUDIO_AAC; stream 2234 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_AUDIO_AC3; stream 2238 src/media_tools/m2ts_mux.c stream->mpeg2_stream_id = 0xC0; stream 2242 src/media_tools/m2ts_mux.c stream->scheduling_priority = 20; stream 2243 src/media_tools/m2ts_mux.c stream->mpeg2_stream_id = 0xFA; stream 2244 src/media_tools/m2ts_mux.c stream->table_id = GF_M2TS_TABLE_ID_MPEG4_OD; stream 2245 src/media_tools/m2ts_mux.c gf_m2ts_stream_set_default_slconfig(stream); stream 2247 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_SYSTEMS_MPEG4_PES; stream 2248 src/media_tools/m2ts_mux.c stream->force_single_au = GF_TRUE; stream 2250 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_SYSTEMS_MPEG4_SECTIONS; stream 2254 src/media_tools/m2ts_mux.c stream->mpeg2_stream_id = 0xFA; stream 2255 src/media_tools/m2ts_mux.c stream->table_id = GF_M2TS_TABLE_ID_MPEG4_BIFS; stream 2256 src/media_tools/m2ts_mux.c gf_m2ts_stream_set_default_slconfig(stream); stream 2259 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_SYSTEMS_MPEG4_PES; stream 2260 src/media_tools/m2ts_mux.c stream->force_single_au = GF_TRUE; stream 2262 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_SYSTEMS_MPEG4_SECTIONS; stream 2266 src/media_tools/m2ts_mux.c stream->mpeg2_stream_id = 0xBD; stream 2267 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_METADATA_PES; stream 2268 src/media_tools/m2ts_mux.c gf_m2ts_stream_add_metadata_pointer_descriptor(stream->program); stream 2269 src/media_tools/m2ts_mux.c gf_m2ts_stream_add_metadata_descriptor(stream); stream 2275 src/media_tools/m2ts_mux.c if (stream->mpeg2_stream_type != GF_M2TS_SYSTEMS_MPEG4_SECTIONS) { stream 2276 src/media_tools/m2ts_mux.c stream->mpeg2_stream_type = GF_M2TS_SYSTEMS_MPEG4_PES; stream 2277 src/media_tools/m2ts_mux.c stream->force_single_au = GF_TRUE; stream 2278 src/media_tools/m2ts_mux.c stream->mpeg2_stream_id = 0xFA;/*ISO/IEC14496-1_SL-packetized_stream*/ stream 2279 src/media_tools/m2ts_mux.c gf_m2ts_stream_set_default_slconfig(stream); stream 2284 src/media_tools/m2ts_mux.c stream->ifce->output_ctrl = gf_m2ts_output_ctrl; stream 2285 src/media_tools/m2ts_mux.c stream->ifce->output_udta = stream; stream 2286 src/media_tools/m2ts_mux.c stream->mx = gf_mx_new("M2TS PID"); stream 2288 src/media_tools/m2ts_mux.c stream->ts_scale.num = 90000; stream 2289 src/media_tools/m2ts_mux.c stream->ts_scale.den = ifce->timescale; stream 2291 src/media_tools/m2ts_mux.c return stream; stream 2297 src/media_tools/m2ts_mux.c GF_M2TS_Mux_Stream *stream = (GF_M2TS_Mux_Stream *)_self->output_udta; stream 2298 src/media_tools/m2ts_mux.c if (!stream || !time_scale) stream 2301 src/media_tools/m2ts_mux.c stream->ts_scale.num = 90000; stream 2302 src/media_tools/m2ts_mux.c stream->ts_scale.den = time_scale; stream 2504 src/media_tools/m2ts_mux.c GF_M2TS_Mux_Stream *stream = prog->streams; stream 2505 src/media_tools/m2ts_mux.c while (stream) { stream 2507 src/media_tools/m2ts_mux.c mux->bit_rate += stream->bit_rate; stream 2510 src/media_tools/m2ts_mux.c if (reset_time) stream->time.sec = stream->time.nanosec = 0; stream 2511 src/media_tools/m2ts_mux.c stream = stream->next; stream 2575 src/media_tools/m2ts_mux.c GF_M2TS_Mux_Stream *stream, *stream_to_process; stream 2630 src/media_tools/m2ts_mux.c stream = program->streams; stream 2631 src/media_tools/m2ts_mux.c while (stream) { stream 2632 src/media_tools/m2ts_mux.c if (stream->pes_data_remain) { stream 2636 src/media_tools/m2ts_mux.c stream = stream->next; stream 2703 src/media_tools/m2ts_mux.c stream = program->pcr; stream 2704 src/media_tools/m2ts_mux.c if (!flush_all_pes || (stream->copy_from_next_packets + stream->pes_data_remain) ) { stream 2705 src/media_tools/m2ts_mux.c res = stream->process(muxer, stream); stream 2706 src/media_tools/m2ts_mux.c if (res && gf_m2ts_time_less_or_equal(&stream->time, &time)) { stream 2707 src/media_tools/m2ts_mux.c time = stream->time; stream 2708 src/media_tools/m2ts_mux.c stream_to_process = stream; stream 2720 src/media_tools/m2ts_mux.c stream = program->streams; stream 2721 src/media_tools/m2ts_mux.c while (stream) { stream 2723 src/media_tools/m2ts_mux.c if (stream != program->pcr) stream 2726 src/media_tools/m2ts_mux.c if (flush_all_pes && !stream->pes_data_remain) { stream 2728 src/media_tools/m2ts_mux.c stream = stream->next; stream 2732 src/media_tools/m2ts_mux.c res = stream->process(muxer, stream); stream 2739 src/media_tools/m2ts_mux.c if (gf_m2ts_time_less(&stream->time, &time)) { stream 2741 src/media_tools/m2ts_mux.c time = stream->time; stream 2742 src/media_tools/m2ts_mux.c stream_to_process = stream; stream 2747 src/media_tools/m2ts_mux.c else if (gf_m2ts_time_equal(&stream->time, &time)) { stream 2749 src/media_tools/m2ts_mux.c if ((res > highest_priority) || ((res == highest_priority) && !stream->ifce->depends_on_stream)) { stream 2751 src/media_tools/m2ts_mux.c time = stream->time; stream 2752 src/media_tools/m2ts_mux.c stream_to_process = stream; stream 2757 src/media_tools/m2ts_mux.c } else if (check_max_time && gf_m2ts_time_less(&max_time, &stream->time)) { stream 2758 src/media_tools/m2ts_mux.c max_time = stream->time; stream 2763 src/media_tools/m2ts_mux.c if ((stream->ifce->caps & GF_ESI_STREAM_IS_OVER) && (!res || stream->refresh_rate_ms) ) stream 2766 src/media_tools/m2ts_mux.c stream = stream->next; stream 229 src/media_tools/m3u8.c static GF_Err stream_del(Stream *stream) { stream 231 src/media_tools/m3u8.c if (stream == NULL) stream 233 src/media_tools/m3u8.c if (stream->variants) { stream 234 src/media_tools/m3u8.c while (gf_list_count(stream->variants)) { stream 235 src/media_tools/m3u8.c GF_List *l = gf_list_get(stream->variants, 0); stream 237 src/media_tools/m3u8.c gf_list_rem(stream->variants, 0); stream 239 src/media_tools/m3u8.c gf_list_del(stream->variants); stream 241 src/media_tools/m3u8.c stream->variants = NULL; stream 242 src/media_tools/m3u8.c gf_free(stream); stream 780 src/media_tools/m3u8.c Stream *stream = in_stream; stream 782 src/media_tools/m3u8.c stream = master_playlist_find_matching_stream(*playlist, attribs->stream_id); stream 784 src/media_tools/m3u8.c if (stream == NULL) { stream 785 src/media_tools/m3u8.c stream = stream_new(attribs->stream_id); stream 786 src/media_tools/m3u8.c if (stream == NULL) { stream 791 src/media_tools/m3u8.c gf_list_add((*playlist)->streams, stream); stream 793 src/media_tools/m3u8.c if ((*playlist)->current_stream < 0 && stream->stream_id < MEDIA_TYPE_AUDIO) stream 794 src/media_tools/m3u8.c (*playlist)->current_stream = stream->stream_id; stream 798 src/media_tools/m3u8.c assert(stream); stream 799 src/media_tools/m3u8.c assert(stream->variants); stream 800 src/media_tools/m3u8.c count = gf_list_count(stream->variants); stream 804 src/media_tools/m3u8.c PlaylistElement *i_playlist_element = gf_list_get(stream->variants, i); stream 806 src/media_tools/m3u8.c if (stream->stream_id < MEDIA_TYPE_AUDIO) { stream 849 src/media_tools/m3u8.c gf_list_add(stream->variants, curr_playlist); stream 876 src/media_tools/m3u8.c gf_list_add(stream->variants, curr_playlist); stream 878 src/media_tools/m3u8.c assert(stream); stream 879 src/media_tools/m3u8.c assert(stream->variants); stream 2965 src/media_tools/media_export.c gf_bs_write_int(bs, pck->stream->aud_aac_obj_type - 1 , 2); stream 2967 src/media_tools/media_export.c gf_bs_write_int(bs, pck->stream->aud_aac_sr_idx, 4); stream 2969 src/media_tools/media_export.c gf_bs_write_int(bs, pck->stream->aud_nb_ch, 3); stream 2988 src/media_tools/media_export.c GF_M2TS_PES *stream; stream 3023 src/media_tools/media_export.c stream = NULL; stream 3028 src/media_tools/media_export.c stream = pes; stream 3035 src/media_tools/media_export.c if (!stream) { stream 3042 src/media_tools/media_export.c sprintf(szFile, "%s_pid%d", dumper->out_name ? dumper->out_name : "", stream->pid); stream 3043 src/media_tools/media_export.c switch (stream->stream_type) { stream 3048 src/media_tools/media_import.c z_stream stream; stream 3051 src/media_tools/media_import.c stream.next_in = (Bytef*)samp->data + offset; stream 3052 src/media_tools/media_import.c stream.avail_in = (uInt)samp->dataLength - offset; stream 3053 src/media_tools/media_import.c stream.next_out = ( Bytef*)dest; stream 3054 src/media_tools/media_import.c stream.avail_out = (uInt)samp->dataLength*ZLIB_COMPRESS_SAFE; stream 3055 src/media_tools/media_import.c stream.zalloc = (alloc_func)NULL; stream 3056 src/media_tools/media_import.c stream.zfree = (free_func)NULL; stream 3057 src/media_tools/media_import.c stream.opaque = (voidpf)NULL; stream 3059 src/media_tools/media_import.c err = deflateInit(&stream, 9); stream 3065 src/media_tools/media_import.c err = deflateSetDictionary(&stream, (Bytef *)*dict, (u32) strlen(*dict)); stream 3068 src/media_tools/media_import.c deflateEnd(&stream); stream 3073 src/media_tools/media_import.c err = deflate(&stream, Z_FINISH); stream 3075 src/media_tools/media_import.c deflateEnd(&stream); stream 3079 src/media_tools/media_import.c if (samp->dataLength - offset<stream.total_out) { stream 3080 src/media_tools/media_import.c GF_LOG(GF_LOG_WARNING, GF_LOG_PARSER, ("[NHML import] compressed data (%d) bigger than input data (%d)\n", (u32) stream.total_out, (u32) samp->dataLength - offset)); stream 3087 src/media_tools/media_import.c if (*max_size < stream.total_out) { stream 3092 src/media_tools/media_import.c memcpy(samp->data + offset, dest, sizeof(char)*stream.total_out); stream 3093 src/media_tools/media_import.c samp->dataLength = (u32) (offset + stream.total_out); stream 3096 src/media_tools/media_import.c deflateEnd(&stream); stream 8311 src/media_tools/media_import.c gf_isom_set_audio_info(import->dest, tsimp->track, 1, ((GF_M2TS_PES_PCK*)par)->stream->aud_sr, ((GF_M2TS_PES_PCK*)par)->stream->aud_nb_ch, 8); stream 8322 src/media_tools/media_import.c if (import->tk_info[i].track_num == pck->stream->pid) { stream 8323 src/media_tools/media_import.c if (pck->stream->aud_sr && ! import->tk_info[i].audio_info.sample_rate) { stream 8324 src/media_tools/media_import.c import->tk_info[i].audio_info.sample_rate = pck->stream->aud_sr; stream 8325 src/media_tools/media_import.c import->tk_info[i].audio_info.nb_channels = pck->stream->aud_nb_ch; stream 8326 src/media_tools/media_import.c if ((pck->stream->stream_type==GF_M2TS_AUDIO_AAC) || (pck->stream->stream_type==GF_M2TS_AUDIO_LATM_AAC)) { stream 8327 src/media_tools/media_import.c sprintf(import->tk_info[i].szCodecProfile, "mp4a.40.%02x", (u8) pck->stream->aud_aac_obj_type); stream 8329 src/media_tools/media_import.c import->tk_info[i].audio_info.sample_rate = pck->stream->aud_sr; stream 8330 src/media_tools/media_import.c import->tk_info[i].audio_info.nb_channels = pck->stream->aud_nb_ch; stream 8334 src/media_tools/media_import.c else if (((pck->stream->stream_type==GF_M2TS_VIDEO_H264) || (pck->stream->stream_type==GF_M2TS_VIDEO_SVC)) && !pck->data[0] && !pck->data[1]) { stream 8340 src/media_tools/media_import.c else if (pck->stream->stream_type==GF_M2TS_VIDEO_HEVC) { stream 8347 src/media_tools/media_import.c else if ((pck->stream->stream_type==GF_M2TS_AUDIO_EC3) || (pck->stream->stream_type==GF_M2TS_AUDIO_AC3) || (pck->stream->stream_type==GF_M2TS_AUDIO_DTS)) { stream 8356 src/media_tools/media_import.c if (pck->stream->vid_w && ! import->tk_info[i].video_info.width ) { stream 8357 src/media_tools/media_import.c import->tk_info[i].video_info.width = pck->stream->vid_w; stream 8358 src/media_tools/media_import.c import->tk_info[i].video_info.height = pck->stream->vid_h; stream 8373 src/media_tools/media_import.c if (!ts->has_4on2 && (import->trackID==pck->stream->pid) && (pck->stream->vid_h || pck->stream->aud_sr) ) stream 8379 src/media_tools/media_import.c if (!(pck->stream->flags & GF_M2TS_ES_FIRST_DTS) && is_au_start) { stream 8380 src/media_tools/media_import.c pck->stream->flags |= GF_M2TS_ES_FIRST_DTS; stream 8381 src/media_tools/media_import.c pck->stream->first_dts = (pck->PTS!=pck->DTS) ? pck->DTS : pck->PTS; stream 8382 src/media_tools/media_import.c if (!pck->stream->program->first_dts || pck->stream->program->first_dts > pck->stream->first_dts) { stream 8383 src/media_tools/media_import.c pck->stream->program->first_dts = 1 + pck->stream->first_dts; stream 8385 src/media_tools/media_import.c if (pck->stream->pid != import->trackID) { stream 8386 src/media_tools/media_import.c gf_m2ts_set_pes_framing((GF_M2TS_PES *)pck->stream, GF_M2TS_PES_FRAMING_SKIP); stream 8390 src/media_tools/media_import.c if (pck->stream->pid != import->trackID) return; stream 8427 src/media_tools/media_import.c if (pck->stream->vid_w < tsimp->avc.sps[idx].width) stream 8428 src/media_tools/media_import.c pck->stream->vid_w = tsimp->avc.sps[idx].width; stream 8429 src/media_tools/media_import.c if (pck->stream->vid_h < tsimp->avc.sps[idx].height) stream 8430 src/media_tools/media_import.c pck->stream->vid_h = tsimp->avc.sps[idx].height; stream 8522 src/media_tools/media_import.c if (pck->stream->vid_w < tsimp->avc.sps[idx].width) stream 8523 src/media_tools/media_import.c pck->stream->vid_w = tsimp->avc.sps[idx].width; stream 8524 src/media_tools/media_import.c if (pck->stream->vid_h < tsimp->avc.sps[idx].height) stream 8525 src/media_tools/media_import.c pck->stream->vid_h = tsimp->avc.sps[idx].height; stream 8604 src/media_tools/media_import.c if (pck->stream->first_dts==samp->DTS) { stream 8605 src/media_tools/media_import.c switch (pck->stream->stream_type) { stream 8607 src/media_tools/media_import.c gf_import_message(import, GF_OK, "MPEG-1 Video import (TS PID %d)", pck->stream->pid); stream 8610 src/media_tools/media_import.c gf_import_message(import, GF_OK, "MPEG-2 Video import (TS PID %d)", pck->stream->pid); stream 8613 src/media_tools/media_import.c gf_import_message(import, GF_OK, "MPEG-4 Video import (TS PID %d)", pck->stream->pid); stream 8616 src/media_tools/media_import.c gf_import_message(import, GF_OK, "MPEG-4 AVC/H264 Video import (TS PID %d)", pck->stream->pid); stream 8619 src/media_tools/media_import.c gf_import_message(import, GF_OK, "MPEG-H HEVC Video import (TS PID %d)", pck->stream->pid); stream 8622 src/media_tools/media_import.c gf_import_message(import, GF_OK, "H264-SVC Video import (TS PID %d)", pck->stream->pid); stream 8625 src/media_tools/media_import.c gf_import_message(import, GF_OK, "MPEG-1 Audio import - SampleRate %d Channels %d Language %s (TS PID %d)", pck->stream->aud_sr, pck->stream->aud_nb_ch, gf_4cc_to_str(pck->stream->lang), pck->stream->pid); stream 8628 src/media_tools/media_import.c gf_import_message(import, GF_OK, "MPEG-2 Audio import - SampleRate %d Channels %d Language %s (TS PID %d)", pck->stream->aud_sr, pck->stream->aud_nb_ch, gf_4cc_to_str(pck->stream->lang), pck->stream->pid); stream 8631 src/media_tools/media_import.c gf_import_message(import, GF_OK, "MPEG-4 AAC Audio import - SampleRate %d Channels %d Language %s (TS PID %d)", pck->stream->aud_sr, pck->stream->aud_nb_ch, gf_4cc_to_str(pck->stream->lang), pck->stream->pid); stream 8634 src/media_tools/media_import.c gf_import_message(import, GF_OK, "Dolby AC3 Audio import - SampleRate %d Channels %d Language %s (TS PID %d)", pck->stream->aud_sr, pck->stream->aud_nb_ch, gf_4cc_to_str(pck->stream->lang), pck->stream->pid); stream 8637 src/media_tools/media_import.c gf_import_message(import, GF_OK, "Dolby E-AC3 Audio import - SampleRate %d Channels %d Language %s (TS PID %d)", pck->stream->aud_sr, pck->stream->aud_nb_ch, gf_4cc_to_str(pck->stream->lang), pck->stream->pid); stream 8640 src/media_tools/media_import.c if (pck->stream->lang) stream 8641 src/media_tools/media_import.c gf_isom_set_media_language(import->dest, tsimp->track, (char *) gf_4cc_to_str(pck->stream->lang)+1); stream 8644 src/media_tools/media_import.c if (pck->stream->aud_sr) { stream 8645 src/media_tools/media_import.c gf_isom_set_audio_info(import->dest, tsimp->track, 1, pck->stream->aud_sr, pck->stream->aud_nb_ch, 16); stream 8648 src/media_tools/media_import.c else if (pck->stream->vid_w) { stream 8649 src/media_tools/media_import.c u32 w = pck->stream->vid_w; stream 8650 src/media_tools/media_import.c if (pck->stream->vid_par) w = w * (pck->stream->vid_par>>16) / (pck->stream->vid_par&0xffff); stream 8651 src/media_tools/media_import.c gf_isom_set_visual_info(import->dest, tsimp->track, 1, pck->stream->vid_w, pck->stream->vid_h); stream 8652 src/media_tools/media_import.c gf_isom_set_track_layout_info(import->dest, tsimp->track, w<<16, pck->stream->vid_h<<16, 0, 0, 0); stream 8653 src/media_tools/media_import.c if (w != pck->stream->vid_w) { stream 8654 src/media_tools/media_import.c e = gf_isom_set_pixel_aspect_ratio(import->dest, tsimp->track, 1, pck->stream->vid_par>>16, pck->stream->vid_par&0xff); stream 8663 src/media_tools/media_import.c if (samp->DTS < pck->stream->first_dts) { stream 8667 src/media_tools/media_import.c pck->stream->first_dts = samp->DTS - (tsimp->last_dts + 1 + dur); stream 8668 src/media_tools/media_import.c pck->stream->program->first_dts = pck->stream->first_dts; stream 8671 src/media_tools/media_import.c if (samp->DTS >= pck->stream->first_dts) { stream 8672 src/media_tools/media_import.c samp->DTS -= pck->stream->first_dts; stream 8677 src/media_tools/media_import.c if ((pck->stream->flags & GF_M2TS_ES_FIRST_DTS) && (samp->DTS + 1 == tsimp->last_dts)) { stream 8686 src/media_tools/media_import.c GF_LOG(GF_LOG_ERROR, GF_LOG_CONTAINER, ("[MPEG-2 TS Import] PID %d: Error adding sample: %s\n", pck->stream->pid, gf_error_to_string(e))); stream 8710 src/media_tools/media_import.c if (!sl_pck->stream->program->pmt_iod) return; stream 8712 src/media_tools/media_import.c if (sl_pck->stream->flags & GF_M2TS_ES_IS_SECTION) { stream 8715 src/media_tools/media_import.c pes = (GF_M2TS_PES *)sl_pck->stream; stream 8718 src/media_tools/media_import.c if (sl_pck->stream->flags & GF_M2TS_ES_IS_MPEG4_OD) { stream 8720 src/media_tools/media_import.c GF_ESD *esd = gf_m2ts_get_esd(sl_pck->stream); stream 8741 src/media_tools/media_import.c gf_list_add(sl_pck->stream->program->additional_ods, od); stream 8744 src/media_tools/media_import.c m2ts_set_tracks_mpeg4_probe_info(import, sl_pck->stream->program, od->ESDescriptors); stream 8757 src/media_tools/media_import.c if (import->tk_info[i].track_num == sl_pck->stream->pid) { stream 8773 src/media_tools/media_import.c if (sl_pck->stream->pid != import->trackID) return; stream 8779 src/media_tools/media_import.c import->esd = gf_m2ts_get_esd(sl_pck->stream); stream 8781 src/media_tools/media_import.c m2ts_create_track(tsimp, mtype, stype, oti, sl_pck->stream->mpeg4_es_id, GF_FALSE); stream 8795 src/media_tools/media_import.c if (!(sl_pck->stream->flags & GF_M2TS_ES_FIRST_DTS)) { stream 8796 src/media_tools/media_import.c sl_pck->stream->flags |= GF_M2TS_ES_FIRST_DTS; stream 8799 src/media_tools/media_import.c hdr.compositionTimeStamp = sl_pck->stream->program->first_dts - 1; stream 8800 src/media_tools/media_import.c GF_LOG(GF_LOG_ERROR, GF_LOG_CONTAINER, ("[MPEG-2 TS Import] PID %d First SL Access unit start flag set without any composition time stamp - defaulting to last CTS seen on program\n", sl_pck->stream->pid)); stream 8802 src/media_tools/media_import.c sl_pck->stream->first_dts = (hdr.decodingTimeStamp?hdr.decodingTimeStamp:hdr.compositionTimeStamp); stream 8803 src/media_tools/media_import.c if (!sl_pck->stream->program->first_dts || (sl_pck->stream->program->first_dts > sl_pck->stream->first_dts)) { stream 8804 src/media_tools/media_import.c sl_pck->stream->program->first_dts = sl_pck->stream->first_dts + 1; stream 8808 src/media_tools/media_import.c hdr.compositionTimeStamp = sl_pck->stream->first_dts + tsimp->last_dts - 1; stream 8809 src/media_tools/media_import.c GF_LOG(GF_LOG_ERROR, GF_LOG_CONTAINER, ("[MPEG-2 TS Import] PID %d SL Access unit start flag set without any composition time stamp - defaulting to last CTS seen on stream + 1\n", sl_pck->stream->pid)); stream 8816 src/media_tools/media_import.c if (samp->DTS >= sl_pck->stream->first_dts) { stream 8817 src/media_tools/media_import.c samp->DTS -= sl_pck->stream->first_dts; stream 8830 src/media_tools/media_import.c GF_LOG(GF_LOG_ERROR, GF_LOG_CONTAINER, ("[MPEG-2 TS Import] PID %d Error adding sample\n", sl_pck->stream->pid)); stream 8839 src/media_tools/media_import.c sl_pck->stream->first_dts = samp->DTS; stream 8840 src/media_tools/media_import.c if (!sl_pck->stream->program->first_dts || (sl_pck->stream->program->first_dts > sl_pck->stream->first_dts)) { stream 8841 src/media_tools/media_import.c sl_pck->stream->program->first_dts = sl_pck->stream->first_dts + 1; stream 1128 src/media_tools/mpd.c Stream *stream; stream 1221 src/media_tools/mpd.c stream = gf_list_get(pl->streams, i); stream 1222 src/media_tools/mpd.c count_variants = gf_list_count(stream->variants); stream 1227 src/media_tools/mpd.c pe = gf_list_get(stream->variants, j); stream 1321 src/media_tools/mpd.c pe = gf_list_get(stream->variants, j); stream 1657 src/media_tools/mpd.c Stream *stream; stream 1679 src/media_tools/mpd.c while ((stream = gf_list_enum(pl->streams, &i))) { stream 1681 src/media_tools/mpd.c while (NULL != (pe = gf_list_enum(stream->variants, &j))) { stream 1689 src/media_tools/mpd.c PlaylistElement *a_pe = gf_list_get(stream->variants, k); stream 1724 src/media_tools/mpd.c pe->load_error = gf_m3u8_parse_sub_playlist(getter->get_cache_name(getter), &pl, suburl, stream, pe); stream 1732 src/media_tools/mpd.c e = gf_m3u8_parse_sub_playlist("tmp.m3u8", &pl, suburl, stream, pe); stream 1739 src/media_tools/mpd.c e = gf_m3u8_parse_sub_playlist(suburl, &pl, suburl, stream, pe); stream 1748 src/media_tools/mpd.c if (max_dur < (u32) stream->computed_duration) { stream 1749 src/media_tools/mpd.c max_dur = (u32) stream->computed_duration; stream 1804 src/media_tools/mpd.c Stream *stream; stream 1839 src/media_tools/mpd.c stream = (Stream *)gf_list_get(pl->streams, 0); stream 1840 src/media_tools/mpd.c assert(gf_list_count(stream->variants) == 1); stream 1841 src/media_tools/mpd.c pe = (PlaylistElement *)gf_list_get(stream->variants, 0); stream 1844 src/media_tools/mpd.c *duration = (u32) (stream->computed_duration * 1000); stream 178 src/media_tools/mpegts.c pck.stream = pes; stream 223 src/media_tools/mpegts.c pck.stream = pes; stream 536 src/media_tools/mpegts.c pck.stream = pes; stream 646 src/media_tools/mpegts.c pck.stream = pes; stream 654 src/media_tools/mpegts.c pck.stream = pes; stream 682 src/media_tools/mpegts.c pck.stream = pes; stream 736 src/media_tools/mpegts.c pck.stream = pes; stream 761 src/media_tools/mpegts.c pck.stream = pes; stream 806 src/media_tools/mpegts.c pck.stream = pes; stream 911 src/media_tools/mpegts.c pck.stream = pes; stream 960 src/media_tools/mpegts.c pck.stream = pes; stream 1001 src/media_tools/mpegts.c pck.stream = pes; stream 1109 src/media_tools/mpegts.c pck.stream = pes; stream 1136 src/media_tools/mpegts.c pck.stream = pes; stream 1319 src/media_tools/mpegts.c pck.stream = pes; stream 1479 src/media_tools/mpegts.c pck.stream = (GF_M2TS_ES *)ses; stream 1490 src/media_tools/mpegts.c pck.stream = (GF_M2TS_ES *)ses; stream 1500 src/media_tools/mpegts.c pck.stream = (GF_M2TS_ES *)ses; stream 1508 src/media_tools/mpegts.c pck.stream = (GF_M2TS_ES *)ses; stream 1539 src/media_tools/mpegts.c pck.stream = (GF_M2TS_ES *)ses; stream 1942 src/media_tools/mpegts.c sl_pck.stream = (GF_M2TS_ES *)es; stream 2902 src/media_tools/mpegts.c pck.stream = pes; stream 2952 src/media_tools/mpegts.c sl_pck.stream = (GF_M2TS_ES *)pes; stream 3409 src/media_tools/mpegts.c pck.stream = (GF_M2TS_PES *)es; stream 2276 src/scene_manager/loader_xmt.c GF_StreamContext *stream = gf_sm_stream_find(parser->load->ctx, (u16) stream_id); stream 2277 src/scene_manager/loader_xmt.c if (!stream || (stream->streamType!=GF_STREAM_SCENE)) stream_id = parser->base_scene_id; stream 2423 src/scene_manager/loader_xmt.c GF_StreamContext *stream; stream 2458 src/scene_manager/loader_xmt.c stream = gf_sm_stream_find(parser->load->ctx, (u16) stream_id); stream 2459 src/scene_manager/loader_xmt.c if (stream && (stream->streamType!=GF_STREAM_OD)) stream_id = parser->base_od_id; stream 175 src/scene_manager/scene_manager.c GF_AUContext *gf_sm_stream_au_new(GF_StreamContext *stream, u64 timing, Double time_sec, Bool isRap) stream 182 src/scene_manager/scene_manager.c if (stream->imp_exp_time >= tmp_timing) { stream 185 src/scene_manager/scene_manager.c while ((tmp = (GF_AUContext *)gf_list_enum(stream->AUs, &i))) { stream 197 src/scene_manager/scene_manager.c tmp->owner = stream; stream 198 src/scene_manager/scene_manager.c gf_list_insert(stream->AUs, tmp, i-1); stream 209 src/scene_manager/scene_manager.c tmp->owner = stream; stream 210 src/scene_manager/scene_manager.c if (stream->disable_aggregation) tmp->flags |= GF_SM_AU_NOT_AGGREGATED; stream 211 src/scene_manager/scene_manager.c gf_list_add(stream->AUs, tmp); stream 212 src/scene_manager/scene_manager.c stream->imp_exp_time = tmp_timing; stream 200 src/scenegraph/html5_media_smjs.c mo = video_stack->txh.stream; stream 206 src/scenegraph/html5_media_smjs.c mo = audio_stack->input.stream; stream 51 src/terminal/media_control.c ctrl_od = ctrl->stream->odm; stream 54 src/terminal/media_control.c if (ctrl->stream->odm != odm) return; stream 56 src/terminal/media_control.c odm = ctrl->stream->odm; stream 59 src/terminal/media_control.c if (odm->subscene && odm->subscene->root_od==ctrl->stream->odm) { stream 336 src/terminal/media_control.c if (stack->stream) { stream 337 src/terminal/media_control.c if (stack->stream->odm) { stream 338 src/terminal/media_control.c odm = stack->stream->odm; stream 353 src/terminal/media_control.c if (stack->stream && (!stack->changed || !stack->control->enabled)) return; stream 359 src/terminal/media_control.c if (stack->stream) { stream 363 src/terminal/media_control.c prev = stack->stream; stream 367 src/terminal/media_control.c stack->stream = gf_scene_get_media_object(stack->parent, &stack->control->url, GF_MEDIA_OBJECT_UNDEF, 0); stream 368 src/terminal/media_control.c if (stack->stream) { stream 369 src/terminal/media_control.c if (!stack->stream->odm) return; stream 371 src/terminal/media_control.c if (stack->stream->odm->subscene) { stream 372 src/terminal/media_control.c if (stack->stream->odm->subscene->is_dynamic_scene && !stack->stream->odm->subscene->dyn_ck) return; stream 377 src/terminal/media_control.c if (prev && prev->odm && (prev != stack->stream)) gf_odm_remove_mediacontrol(prev->odm, stack); stream 380 src/terminal/media_control.c gf_odm_set_mediacontrol((GF_ObjectManager *) stack->stream->odm, stack); stream 383 src/terminal/media_control.c gf_odm_init_segments((GF_ObjectManager *) stack->stream->odm, stack->seg, &stack->control->url); stream 395 src/terminal/media_control.c stack->ck = gf_odm_get_media_clock(stack->stream->odm); stream 412 src/terminal/media_control.c stack->stream = gf_scene_get_media_object(stack->parent, &stack->control->url, GF_MEDIA_OBJECT_UNDEF, 0); stream 413 src/terminal/media_control.c if (!stack->stream || !stack->stream->odm) { stream 415 src/terminal/media_control.c stack->stream = NULL; stream 419 src/terminal/media_control.c stack->ck = gf_odm_get_media_clock(stack->stream->odm); stream 422 src/terminal/media_control.c stack->stream = NULL; stream 430 src/terminal/media_control.c gf_odm_set_mediacontrol((GF_ObjectManager *) stack->stream->odm, stack); stream 433 src/terminal/media_control.c gf_odm_init_segments((GF_ObjectManager *) stack->stream->odm, stack->seg, &stack->control->url); stream 440 src/terminal/media_control.c if ((stack->is_init && !stack->changed) || !stack->control->enabled || !stack->stream) return; stream 446 src/terminal/media_control.c need_restart = gf_odm_switch_mediacontrol(stack->stream->odm, stack); stream 453 src/terminal/media_control.c odm = (GF_ObjectManager *)stack->stream->odm; stream 470 src/terminal/media_control.c if (stack->stream->num_open) { stream 661 src/terminal/media_control.c if (!ctrl || (ctrl->stream->odm != odm)) return 0; stream 62 src/terminal/media_control.h GF_MediaObject *stream; stream 102 src/terminal/media_control.h GF_MediaObject *stream; stream 1247 src/terminal/media_object.c else if (ctrl->stream->odm != mo->odm) res = GF_FALSE; stream 1249 src/terminal/media_object.c else if (ctrl->stream->odm->state) res = GF_FALSE; stream 43 src/terminal/media_sensor.c if (st->stream && st->stream->odm) stream 44 src/terminal/media_sensor.c gf_list_del_item(st->stream->odm->ms_stack, st); stream 53 src/terminal/media_sensor.c if (!st->stream) st->stream = gf_mo_register(node, &st->sensor->url, 0, 0); stream 54 src/terminal/media_sensor.c if (!st->stream || !st->stream->odm) return; stream 57 src/terminal/media_sensor.c gf_list_add(st->stream->odm->ms_stack, st); stream 58 src/terminal/media_sensor.c gf_odm_init_segments(st->stream->odm, st->seg, &st->sensor->url); stream 69 src/terminal/media_sensor.c if (st->stream->odm->subscene && !st->stream->odm->subscene->needs_restart) { stream 70 src/terminal/media_sensor.c if (st->stream->odm->subscene->scene_codec) ck = st->stream->odm->subscene->scene_codec->ck; stream 72 src/terminal/media_sensor.c else ck = st->stream->odm->subscene->dyn_ck; stream 73 src/terminal/media_sensor.c if (st->stream->odm->subscene->is_dynamic_scene) do_update_clock = 0; stream 76 src/terminal/media_sensor.c else if (st->stream->odm->codec && (st->stream->odm->codec->type==GF_STREAM_SCENE)) ck = st->stream->odm->codec->ck; stream 78 src/terminal/media_sensor.c else if (st->stream->odm->ocr_codec) ck = st->stream->odm->ocr_codec->ck; stream 82 src/terminal/media_sensor.c st->stream->odm->media_current_time = gf_clock_media_time(ck); stream 83 src/terminal/media_sensor.c mediasensor_update_timing(st->stream->odm, 0); stream 86 src/terminal/media_sensor.c else if (st->stream->odm->subscene && st->stream->odm->subscene->sys_clock_at_main_activation) { stream 90 src/terminal/media_sensor.c gf_term_send_event(st->stream->odm->term, &evt); stream 119 src/terminal/media_sensor.c if (st->stream) { stream 121 src/terminal/media_sensor.c if (st->stream->odm && st->stream->odm->ms_stack) stream 122 src/terminal/media_sensor.c gf_list_del_item(st->stream->odm->ms_stack, st); stream 124 src/terminal/media_sensor.c gf_mo_unregister(node, st->stream); stream 130 src/terminal/media_sensor.c st->stream = NULL; stream 282 src/terminal/media_sensor.c GF_LOG(GF_LOG_DEBUG, GF_LOG_INTERACT, ("[ODM%d] Deactivating media sensor\n", st->stream->odm->OD->objectDescriptorID)); stream 68 src/terminal/object_manager.c media_sens->stream = NULL; stream 75 src/terminal/object_manager.c media_ctrl->stream = NULL; stream 200 src/terminal/object_manager.c if (ch->clock->mc && ch->clock->mc->stream && ch->clock->mc->stream->odm==odm) { stream 201 src/terminal/object_manager.c ch->clock->mc->stream = NULL; stream 192 src/utils/base_encoding.c z_stream stream; stream 195 src/utils/base_encoding.c stream.next_in = (Bytef*)(*data) ; stream 196 src/utils/base_encoding.c stream.avail_in = (uInt)data_len ; stream 197 src/utils/base_encoding.c stream.next_out = ( Bytef*)dest; stream 198 src/utils/base_encoding.c stream.avail_out = (uInt)data_len*ZLIB_COMPRESS_SAFE; stream 199 src/utils/base_encoding.c stream.zalloc = (alloc_func)NULL; stream 200 src/utils/base_encoding.c stream.zfree = (free_func)NULL; stream 201 src/utils/base_encoding.c stream.opaque = (voidpf)NULL; stream 203 src/utils/base_encoding.c err = deflateInit(&stream, 9); stream 209 src/utils/base_encoding.c err = deflate(&stream, Z_FINISH); stream 211 src/utils/base_encoding.c deflateEnd(&stream); stream 215 src/utils/base_encoding.c if (data_len <stream.total_out) { stream 216 src/utils/base_encoding.c GF_LOG(GF_LOG_WARNING, GF_LOG_CORE, ("[GZ] compressed data (%d) larger than input (%d)\n", (u32) stream.total_out, (u32) data_len )); stream 219 src/utils/base_encoding.c if (*max_size < stream.total_out) { stream 224 src/utils/base_encoding.c memcpy((*data) , dest, sizeof(char)*stream.total_out); stream 225 src/utils/base_encoding.c *max_size = (u32) stream.total_out; stream 228 src/utils/base_encoding.c deflateEnd(&stream); stream 43 src/utils/bitstream.c FILE *stream; stream 83 src/utils/bitstream.c tmp->stream = NULL; stream 135 src/utils/bitstream.c tmp->stream = f; stream 148 src/utils/bitstream.c u32 nb_write = (u32) fwrite(bs->buffer_io, 1, bs->buffer_written, bs->stream); stream 159 src/utils/bitstream.c if (!bs->stream) return GF_OK; stream 217 src/utils/bitstream.c if (!feof(bs->stream)) { stream 220 src/utils/bitstream.c return (u32) fgetc(bs->stream); stream 422 src/utils/bitstream.c bytes_read = (s32) fread(data, 1, nbBytes, bs->stream); stream 444 src/utils/bitstream.c if (!bs->original && !bs->stream) return; stream 474 src/utils/bitstream.c fputc(val, bs->stream); stream 598 src/utils/bitstream.c if (gf_fwrite(&byte, 1, repeat_count, bs->stream) != repeat_count) return 0; stream 687 src/utils/bitstream.c if (gf_fwrite(data, nbBytes, 1, bs->stream) != 1) return 0; stream 750 src/utils/bitstream.c cur = gf_ftell(bs->stream); stream 751 src/utils/bitstream.c gf_fseek(bs->stream, 0, SEEK_END); stream 752 src/utils/bitstream.c end = gf_ftell(bs->stream); stream 753 src/utils/bitstream.c gf_fseek(bs->stream, cur, SEEK_SET); stream 818 src/utils/bitstream.c gf_fseek(bs->stream, nbBytes, SEEK_CUR); stream 881 src/utils/bitstream.c gf_fseek(bs->stream, offset, SEEK_SET); stream 940 src/utils/bitstream.c offset = gf_ftell(bs->stream); stream 941 src/utils/bitstream.c gf_fseek(bs->stream, 0, SEEK_END); stream 942 src/utils/bitstream.c bs->size = gf_ftell(bs->stream); stream 943 src/utils/bitstream.c gf_fseek(bs->stream, offset, SEEK_SET); stream 1027 src/utils/bitstream.c if (bs->stream) return 0; stream 1035 src/utils/bitstream.c if (bs->stream) return 0; stream 1051 src/utils/bitstream.c if (bs->stream) return; stream 1084 src/utils/bitstream.c if (!bs->stream) return; stream 1087 src/utils/bitstream.c fflush(bs->stream); stream 1090 src/utils/bitstream.c void gf_bs_reassign(GF_BitStream *bs, FILE *stream) stream 1096 src/utils/bitstream.c bs->stream = stream; stream 1097 src/utils/bitstream.c if (gf_ftell(stream) != bs->position) stream 85 src/utils/gzio.cpp z_stream stream; stream 136 src/utils/gzio.cpp s->stream.zalloc = (alloc_func)0; stream 137 src/utils/gzio.cpp s->stream.zfree = (free_func)0; stream 138 src/utils/gzio.cpp s->stream.opaque = (voidpf)0; stream 139 src/utils/gzio.cpp s->stream.next_in = s->inbuf = Z_NULL; stream 140 src/utils/gzio.cpp s->stream.next_out = s->outbuf = Z_NULL; stream 141 src/utils/gzio.cpp s->stream.avail_in = s->stream.avail_out = 0; stream 180 src/utils/gzio.cpp err = deflateInit2(&(s->stream), level, stream 184 src/utils/gzio.cpp s->stream.next_out = s->outbuf = (Byte*)ALLOC(Z_BUFSIZE); stream 190 src/utils/gzio.cpp s->stream.next_in = s->inbuf = (Byte*)ALLOC(Z_BUFSIZE); stream 192 src/utils/gzio.cpp err = inflateInit2(&(s->stream), -MAX_WBITS); stream 203 src/utils/gzio.cpp s->stream.avail_out = Z_BUFSIZE; stream 224 src/utils/gzio.cpp s->start = ftell(s->file) - s->stream.avail_in; stream 264 src/utils/gzio.cpp if (s->stream.avail_out == 0) { stream 266 src/utils/gzio.cpp s->stream.next_out = s->outbuf; stream 270 src/utils/gzio.cpp s->stream.avail_out = Z_BUFSIZE; stream 273 src/utils/gzio.cpp return deflateParams (&(s->stream), level, strategy); stream 284 src/utils/gzio.cpp if (s->stream.avail_in == 0) { stream 286 src/utils/gzio.cpp s->stream.avail_in = (uInt)fread(s->inbuf, 1, Z_BUFSIZE, s->file); stream 287 src/utils/gzio.cpp if (s->stream.avail_in == 0) { stream 292 src/utils/gzio.cpp s->stream.next_in = s->inbuf; stream 294 src/utils/gzio.cpp s->stream.avail_in--; stream 295 src/utils/gzio.cpp return *(s->stream.next_in)++; stream 317 src/utils/gzio.cpp len = s->stream.avail_in; stream 319 src/utils/gzio.cpp if (len) s->inbuf[0] = s->stream.next_in[0]; stream 323 src/utils/gzio.cpp s->stream.avail_in += len; stream 324 src/utils/gzio.cpp s->stream.next_in = s->inbuf; stream 325 src/utils/gzio.cpp if (s->stream.avail_in < 2) { stream 326 src/utils/gzio.cpp s->transparent = s->stream.avail_in; stream 332 src/utils/gzio.cpp if (s->stream.next_in[0] != gz_magic[0] || stream 333 src/utils/gzio.cpp s->stream.next_in[1] != gz_magic[1]) { stream 337 src/utils/gzio.cpp s->stream.avail_in -= 2; stream 338 src/utils/gzio.cpp s->stream.next_in += 2; stream 381 src/utils/gzio.cpp if (s->stream.state != NULL) { stream 386 src/utils/gzio.cpp err = deflateEnd(&(s->stream)); stream 389 src/utils/gzio.cpp err = inflateEnd(&(s->stream)); stream 421 src/utils/gzio.cpp s->stream.next_out = (Bytef*)buf; stream 422 src/utils/gzio.cpp s->stream.avail_out = len; stream 424 src/utils/gzio.cpp if (s->stream.avail_out && s->back != EOF) { stream 426 src/utils/gzio.cpp s->stream.next_out++; stream 427 src/utils/gzio.cpp s->stream.avail_out--; stream 437 src/utils/gzio.cpp while (s->stream.avail_out != 0) { stream 441 src/utils/gzio.cpp uInt n = s->stream.avail_in; stream 442 src/utils/gzio.cpp if (n > s->stream.avail_out) n = s->stream.avail_out; stream 444 src/utils/gzio.cpp zmemcpy(s->stream.next_out, s->stream.next_in, n); stream 446 src/utils/gzio.cpp s->stream.next_out = next_out; stream 447 src/utils/gzio.cpp s->stream.next_in += n; stream 448 src/utils/gzio.cpp s->stream.avail_out -= n; stream 449 src/utils/gzio.cpp s->stream.avail_in -= n; stream 451 src/utils/gzio.cpp if (s->stream.avail_out > 0) { stream 452 src/utils/gzio.cpp s->stream.avail_out -= stream 453 src/utils/gzio.cpp (uInt)fread(next_out, 1, s->stream.avail_out, s->file); stream 455 src/utils/gzio.cpp len -= s->stream.avail_out; stream 461 src/utils/gzio.cpp if (s->stream.avail_in == 0 && !s->z_eof) { stream 464 src/utils/gzio.cpp s->stream.avail_in = (uInt)fread(s->inbuf, 1, Z_BUFSIZE, s->file); stream 465 src/utils/gzio.cpp if (s->stream.avail_in == 0) { stream 472 src/utils/gzio.cpp s->stream.next_in = s->inbuf; stream 474 src/utils/gzio.cpp s->in += s->stream.avail_in; stream 475 src/utils/gzio.cpp s->out += s->stream.avail_out; stream 476 src/utils/gzio.cpp s->z_err = inflate(&(s->stream), Z_NO_FLUSH); stream 477 src/utils/gzio.cpp s->in -= s->stream.avail_in; stream 478 src/utils/gzio.cpp s->out -= s->stream.avail_out; stream 482 src/utils/gzio.cpp s->crc = crc32(s->crc, start, (uInt)(s->stream.next_out - start)); stream 483 src/utils/gzio.cpp start = s->stream.next_out; stream 495 src/utils/gzio.cpp inflateReset(&(s->stream)); stream 502 src/utils/gzio.cpp s->crc = crc32(s->crc, start, (uInt)(s->stream.next_out - start)); stream 504 src/utils/gzio.cpp if (len == s->stream.avail_out && stream 507 src/utils/gzio.cpp return (int)(len - s->stream.avail_out); stream 571 src/utils/gzio.cpp s->stream.next_in = (Bytef*)buf; stream 572 src/utils/gzio.cpp s->stream.avail_in = len; stream 574 src/utils/gzio.cpp while (s->stream.avail_in != 0) { stream 576 src/utils/gzio.cpp if (s->stream.avail_out == 0) { stream 578 src/utils/gzio.cpp s->stream.next_out = s->outbuf; stream 583 src/utils/gzio.cpp s->stream.avail_out = Z_BUFSIZE; stream 585 src/utils/gzio.cpp s->in += s->stream.avail_in; stream 586 src/utils/gzio.cpp s->out += s->stream.avail_out; stream 587 src/utils/gzio.cpp s->z_err = deflate(&(s->stream), Z_NO_FLUSH); stream 588 src/utils/gzio.cpp s->in -= s->stream.avail_in; stream 589 src/utils/gzio.cpp s->out -= s->stream.avail_out; stream 594 src/utils/gzio.cpp return (int)(len - s->stream.avail_in); stream 709 src/utils/gzio.cpp s->stream.avail_in = 0; /* should be zero already anyway */ stream 712 src/utils/gzio.cpp len = Z_BUFSIZE - s->stream.avail_out; stream 719 src/utils/gzio.cpp s->stream.next_out = s->outbuf; stream 720 src/utils/gzio.cpp s->stream.avail_out = Z_BUFSIZE; stream 723 src/utils/gzio.cpp s->out += s->stream.avail_out; stream 724 src/utils/gzio.cpp s->z_err = deflate(&(s->stream), flush); stream 725 src/utils/gzio.cpp s->out -= s->stream.avail_out; stream 733 src/utils/gzio.cpp done = (s->stream.avail_out != 0 || s->z_err == Z_STREAM_END); stream 763 src/utils/gzio.cpp s->stream.avail_in = 0; stream 764 src/utils/gzio.cpp s->stream.next_in = s->inbuf; stream 766 src/utils/gzio.cpp if (!s->transparent) (void)inflateReset(&s->stream); stream 827 src/utils/gzio.cpp s->stream.avail_in = 0; stream 828 src/utils/gzio.cpp s->stream.next_in = s->inbuf; stream 982 src/utils/gzio.cpp m = (char*)(*errnum == Z_ERRNO ? zstrerror(errno) : s->stream.msg); stream 734 src/utils/os_file.c size_t gf_fread(void *ptr, size_t size, size_t nmemb, FILE *stream) { stream 735 src/utils/os_file.c return fread(ptr, size, nmemb, stream); stream 740 src/utils/os_file.c FILE *stream) stream 742 src/utils/os_file.c size_t result = fwrite(ptr, size, nmemb, stream);