blob: 0d6988a9205ef060892cf0baac84e49429c52e61 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
//=================== VIDEO PARSER =========================
#define MAX_VIDEO_PACKET_SIZE (224*1024+4)
#define VIDEOBUFFER_SIZE 0x100000
//static unsigned char videobuffer[MAX_VIDEO_PACKET_SIZE];
static unsigned char* videobuffer=NULL;
static int videobuf_len=0;
static unsigned char videobuf_code[4];
static int videobuf_code_len=0;
// sync video stream, and returns next packet code
int sync_video_packet(demux_stream_t *ds){
int skipped=0;
// we need enough bytes in the buffer:
while(videobuf_code_len<4){
#if 0
int c;
c=demux_getc(ds);if(c<0){ return 0;} // EOF
videobuf_code[videobuf_code_len++]=c;
#else
videobuf_code[videobuf_code_len++]=demux_getc(ds);
#endif
}
// sync packet:
while(1){
int c;
if(videobuf_code[0]==0 &&
videobuf_code[1]==0 &&
videobuf_code[2]==1) break; // synced
// shift buffer, drop first byte
++skipped;
videobuf_code[0]=videobuf_code[1];
videobuf_code[1]=videobuf_code[2];
videobuf_code[2]=videobuf_code[3];
c=demux_getc(ds);if(c<0){ return 0;} // EOF
videobuf_code[3]=c;
}
if(verbose>=2) if(skipped) printf("videobuf: %d bytes skipped (next: 0x1%02X)\n",skipped,videobuf_code[3]);
return 0x100|videobuf_code[3];
}
// return: packet length
int read_video_packet(demux_stream_t *ds){
int packet_start;
// SYNC STREAM
// if(!sync_video_packet(ds)) return 0; // cannot sync (EOF)
// COPY STARTCODE:
packet_start=videobuf_len;
videobuffer[videobuf_len+0]=videobuf_code[0];
videobuffer[videobuf_len+1]=videobuf_code[1];
videobuffer[videobuf_len+2]=videobuf_code[2];
videobuffer[videobuf_len+3]=videobuf_code[3];
videobuf_len+=4;
// READ PACKET:
{ unsigned int head=-1;
while(videobuf_len<VIDEOBUFFER_SIZE){
int c=demux_getc(ds);
if(c<0) break; // EOF
videobuffer[videobuf_len++]=c;
#if 1
head<<=8;
if(head==0x100) break; // synced
head|=c;
#else
if(videobuffer[videobuf_len-4]==0 &&
videobuffer[videobuf_len-3]==0 &&
videobuffer[videobuf_len-2]==1) break; // synced
#endif
}
}
if(ds->eof){
videobuf_code_len=0; // EOF, no next code
return videobuf_len-packet_start;
}
videobuf_len-=4;
if(verbose>=2) printf("videobuf: packet 0x1%02X len=%d (total=%d)\n",videobuffer[packet_start+3],videobuf_len-packet_start,videobuf_len);
// Save next packet code:
videobuf_code[0]=videobuffer[videobuf_len];
videobuf_code[1]=videobuffer[videobuf_len+1];
videobuf_code[2]=videobuffer[videobuf_len+2];
videobuf_code[3]=videobuffer[videobuf_len+3];
videobuf_code_len=4;
return videobuf_len-packet_start;
}
// return: next packet code
int skip_video_packet(demux_stream_t *ds){
// SYNC STREAM
// if(!sync_video_packet(ds)) return 0; // cannot sync (EOF)
videobuf_code_len=0; // force resync
// SYNC AGAIN:
return sync_video_packet(ds);
}
|
