Lines Matching defs:pes
42 static AVStream* new_pes_av_stream(PESContext *pes, uint32_t code);
314 MpegTSPESFilter *pes;
325 pes = &filter->u.pes_filter;
326 pes->pes_cb = pes_cb;
327 pes->opaque = opaque;
485 PESContext *pes;
644 pes= ts->pids[pid]->u.pes_filter.opaque;
645 st= pes->st;
648 pes = add_pes_stream(ts, pid, pcr_pid, stream_type);
649 if (pes)
650 st = new_pes_av_stream(pes, 0);
826 PESContext *pes = filter->u.pes_filter.opaque;
827 MpegTSContext *ts = pes->ts;
835 pes->state = MPEGTS_HEADER;
836 pes->data_index = 0;
837 pes->ts_packet_pos = pos;
841 switch(pes->state) {
843 len = PES_START_SIZE - pes->data_index;
846 memcpy(pes->header + pes->data_index, p, len);
847 pes->data_index += len;
850 if (pes->data_index == PES_START_SIZE) {
854 av_hex_dump_log(pes->stream, AV_LOG_DEBUG, pes->header, pes->data_index);
856 if (pes->header[0] == 0x00 && pes->header[1] == 0x00 &&
857 pes->header[2] == 0x01) {
859 code = pes->header[3] | 0x100;
864 if (!pes->st) {
866 new_pes_av_stream(pes, code);
868 pes->state = MPEGTS_PESHEADER_FILL;
869 pes->total_size = AV_RB16(pes->header + 4);
872 if (pes->total_size)
873 pes->total_size += 6;
874 pes->pes_header_size = pes->header[8] + 9;
879 pes->state = MPEGTS_SKIP;
887 len = pes->pes_header_size - pes->data_index;
890 memcpy(pes->header + pes->data_index, p, len);
891 pes->data_index += len;
894 if (pes->data_index == pes->pes_header_size) {
898 flags = pes->header[7];
899 r = pes->header + 9;
900 pes->pts = AV_NOPTS_VALUE;
901 pes->dts = AV_NOPTS_VALUE;
903 pes->dts = pes->pts = get_pts(r);
906 pes->pts = get_pts(r);
908 pes->dts = get_pts(r);
912 pes->state = MPEGTS_PAYLOAD;
916 if (pes->total_size) {
917 len = pes->total_size - pes->data_index;
925 if (pes->st && av_new_packet(pkt, len) == 0) {
927 pkt->stream_index = pes->st->index;
928 pkt->pts = pes->pts;
929 pkt->dts = pes->dts;
931 pkt->pos = pes->ts_packet_pos;
933 pes->pts = AV_NOPTS_VALUE;
934 pes->dts = AV_NOPTS_VALUE;
948 static AVStream* new_pes_av_stream(PESContext *pes, uint32_t code)
954 switch(pes->stream_type){
1011 st = av_new_stream(pes->stream, pes->pid);
1014 st->priv_data = pes;
1018 pes->st = st;
1027 PESContext *pes;
1030 pes = av_mallocz(sizeof(PESContext));
1031 if (!pes)
1033 pes->ts = ts;
1034 pes->stream = ts->stream;
1035 pes->pid = pid;
1036 pes->pcr_pid = pcr_pid;
1037 pes->stream_type = stream_type;
1038 tss = mpegts_open_pes_filter(ts, pid, mpegts_push_data, pes);
1040 av_free(pes);
1043 return pes;