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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
#ifndef __STREAM_H
#define __STREAM_H
#define STREAM_BUFFER_SIZE 2048
#define STREAMTYPE_FILE 0
#define STREAMTYPE_VCD 1
#define STREAMTYPE_STREAM 2 // same as FILE but no seeking (for stdin)
#define VCD_SECTOR_SIZE 2352
#define VCD_SECTOR_OFFS 24
#define VCD_SECTOR_DATA 2324
int vcd_seek_to_track(int fd,int track);
void vcd_read_toc(int fd);
#ifdef VCD_CACHE
void vcd_cache_init(int s);
#endif
typedef struct {
int fd;
long pos;
int eof;
int type; // 0=file 1=VCD
unsigned int buf_pos,buf_len;
long start_pos,end_pos;
unsigned char buffer[STREAM_BUFFER_SIZE>VCD_SECTOR_SIZE?STREAM_BUFFER_SIZE:VCD_SECTOR_SIZE];
} stream_t;
int stream_fill_buffer(stream_t *s);
int stream_seek_long(stream_t *s,unsigned int pos);
inline static int stream_read_char(stream_t *s){
return (s->buf_pos<s->buf_len)?s->buffer[s->buf_pos++]:
(stream_fill_buffer(s)?s->buffer[s->buf_pos++]:-256);
// if(s->buf_pos<s->buf_len) return s->buffer[s->buf_pos++];
// stream_fill_buffer(s);
// if(s->buf_pos<s->buf_len) return s->buffer[s->buf_pos++];
// return 0; // EOF
}
inline static unsigned int stream_read_word(stream_t *s){
int x,y;
x=stream_read_char(s);
y=stream_read_char(s);
return (x<<8)|y;
}
inline static unsigned int stream_read_dword(stream_t *s){
unsigned int y;
y=stream_read_char(s);
y=(y<<8)|stream_read_char(s);
y=(y<<8)|stream_read_char(s);
y=(y<<8)|stream_read_char(s);
return y;
}
inline static unsigned int stream_read_word_le(stream_t *s){
int x,y;
x=stream_read_char(s);
y=stream_read_char(s);
return (y<<8)|x;
}
inline static unsigned int stream_read_dword_le(stream_t *s){
unsigned int y;
y=stream_read_char(s);
y|=stream_read_char(s)<<8;
y|=stream_read_char(s)<<16;
y|=stream_read_char(s)<<24;
return y;
}
inline static void stream_read(stream_t *s,char* mem,int len){
while(len>0){
int x;
x=s->buf_len-s->buf_pos;
if(x==0){
if(!stream_fill_buffer(s)) return; // EOF
x=s->buf_len-s->buf_pos;
}
if(s->buf_pos>s->buf_len) printf("stream_read: WARNING! s->buf_pos>s->buf_len\n");
if(x>len) x=len;
memcpy(mem,&s->buffer[s->buf_pos],x);
s->buf_pos+=x; mem+=x; len-=x;
}
}
inline static int stream_eof(stream_t *s){
return s->eof;
}
inline static int stream_tell(stream_t *s){
return s->pos+s->buf_pos-s->buf_len;
}
inline static int stream_seek(stream_t *s,unsigned int pos){
// if(verbose>=3) printf("seek to 0x%X\n",pos);
if(pos<s->pos){
int x=pos-(s->pos-s->buf_len);
if(x>=0){
s->buf_pos=x;
// putchar('*');fflush(stdout);
return 1;
}
}
return stream_seek_long(s,pos);
}
inline static void stream_skip(stream_t *s,int len){
if(len<0 || (len>2*STREAM_BUFFER_SIZE && s->type!=STREAMTYPE_STREAM)){
// negative or big skip!
stream_seek(s,stream_tell(s)+len);
return;
}
while(len>0){
int x=s->buf_len-s->buf_pos;
if(x==0){
if(!stream_fill_buffer(s)) return; // EOF
x=s->buf_len-s->buf_pos;
}
if(x>len) x=len;
//memcpy(mem,&s->buf[s->buf_pos],x);
s->buf_pos+=x; len-=x;
}
}
void stream_reset(stream_t *s);
stream_t* new_stream(int fd,int type);
void free_stream(stream_t *s);
#endif // __STREAM_H
|
