tcp流中提取ts

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
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#define TS_SIZE 188
#define RTP_HEDER_SIZE 12
#define SYNC_BYTE 0x47
#define BUFFER_SIZE 1024*1024*2
int main(int argc, char **argv) {
int count = 0;
char buffer[BUFFER_SIZE];
char ts_buf[TS_SIZE];
printf("%s %sn", argv[1], argv[2]);
int inFd = open(argv[1], O_RDONLY);
int outFd = open(argv[2], O_RDWR | O_CREAT);
if(inFd < 0 || outFd < 0) {
printf("open file error !n");
perror("open file error:");
return 0;
}
int ret = -1;
int startPos = 0;
while((ret = read(inFd, buffer+startPos, BUFFER_SIZE - 3*TS_SIZE)) > 0) {
int i = 0;
for(i = 0;i < ret - 3*TS_SIZE; i++) {
int findTs = 0;
if((buffer[i] == 0x47) && (buffer[i+TS_SIZE] == 0x47) && (buffer[i+TS_SIZE*2] == 0x47)) {
for(;i < ret - TS_SIZE; i += TS_SIZE) {
if(buffer[i] == 0x47) {
write(outFd, buffer+i, TS_SIZE);
count++;
} else {
break;
}
}
findTs = 1;
}
}
memcpy(buffer, buffer+i, (size_t)(ret-i));
startPos = ret - i;
printf("startPos %dn", startPos);
}
printf("ts count %dn", count);
close(inFd);
close(outFd);
return 0;
}