-
Notifications
You must be signed in to change notification settings - Fork 25
/
Copy pathstream.h
162 lines (138 loc) · 5.28 KB
/
stream.h
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
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
#ifndef __STREAM_H__
#define __STREAM_H__
// ���Ͷ���.
#ifndef _STDINT_H
typedef signed char int8_t;
typedef unsigned char uint8_t;
typedef short int16_t;
typedef unsigned short uint16_t;
typedef int int32_t;
typedef unsigned uint32_t;
typedef long long int64_t;
typedef unsigned long long uint64_t;
//typedef unsigned long size_t;
#endif
// ��ʽ.
#define MODE_READ (1)
#define MODE_WRITE (2)
#define MODE_READWRITEFILTER (3)
#define MODE_EXISTING (4)
#define MODE_CREATE (8)
// ��д�ṹ����.
typedef struct stream {
void* (*open)(struct stream *stream_s, const char* filename, int mode);
int (*read)(struct stream *stream_s, void* buf, int size);
int (*write)(struct stream *stream_s, void *buf, int size);
int (*peek)(struct stream *stream_s, void* buf, int size);
uint64_t (*seek)(struct stream *stream_s, int64_t offset, int whence);
uint64_t (*tell)(struct stream *stream_s);
int (*close)(struct stream *stream_s);
void* opaque;
} stream_t;
// ��д�궨��.
#define stream_open(s, filename, mode) ((stream_t*)s)->open(((stream_t*)s), filename, mode)
#define stream_read(s, buf, size) ((stream_t*)s)->read(((stream_t*)s), buf, size)
#define stream_write(s, buf, size) ((stream_t*)s)->write(((stream_t*)s), buf, size)
#define stream_peek(s, buf, size) ((stream_t*)s)->peek(((stream_t*)s), buf, size)
#define stream_seek(s, offset, whence) ((stream_t*)s)->seek(((stream_t*)s), offset, whence)
#define stream_tell(s) ((stream_t*)s)->tell(((stream_t*)s))
#define stream_close(s) ((stream_t*)s)->close(((stream_t*)s))
// �ļ���д.
void* file_open(stream_t *stream_s, const char* filename, int mode);
int file_read(stream_t *stream_s, void* buf, int size);
int file_write(stream_t *stream_s, void *buf, int size);
int file_peek(stream_t *stream_s, void* buf, int size);
uint64_t file_seek(stream_t *stream_s, int64_t offset, int whence);
uint64_t file_tell(stream_t *stream_s);
int file_close(stream_t *stream_s);
// �����ļ���д��.
stream_t* create_file_stream();
void destory_file_stream(stream_t* stream_s);
typedef struct BUFFER {
unsigned char *buf;
unsigned char *begin_addr;
unsigned long offset;
unsigned long filesize;
}BUFFER_t;
//read data form buffer,not binary file
void* buffer_open(stream_t *stream_s, BUFFER_t *buffer);
int buffer_read(stream_t *stream_s, void* buf, int size);
int buffer_write(stream_t *stream_s, void *buf, int size);
int buffer_peek(stream_t *stream_s, void* buf, int size);
uint64_t buffer_seek(stream_t *stream_s, int64_t offset, int whence);
uint64_t buffer_tell(stream_t *stream_s);
int buffer_close(stream_t *stream_s);
stream_t* create_buffer_stream();
void destory_buffer_stream(stream_t* stream_s);
// һ�����д������ļ�streamʵ��.
#define READ_BUFFER_SIZE 10485760
#define WRITE_BUFFER_SIZE 10485760
typedef struct buf_stream {
stream_t s;
struct read_buf {
void* buf; // ������.
int64_t bufsize; // �����С.
int64_t offset; // ���ļ��е�offset.
} read_buf_s;
struct write_buf {
void* buf; // ���.
int64_t bufsize; // �����С.
int64_t offset; // д�ļ���offset.
} write_buf_s;
uint64_t offset; // ��ǰ��дָ�����ļ��е�offset.
} buf_stream_t;
// ���Ķ�дʵ��.
int buf_file_read(stream_t *stream_s, void* buf, int size);
int buf_file_write(stream_t *stream_s, void *buf, int size);
int buf_file_peek(stream_t *stream_s, void* buf, int size);
uint64_t buf_file_seek(stream_t *stream_s, int64_t offset, int whence);
int buf_file_close(stream_t *stream_s);
// ���������ļ���д��.
stream_t* create_buf_file_stream();
void destory_buf_file_stream(stream_t* stream_s);
// ��С�˶�д����ʵ��.
#define LIL_ENDIAN 1234
#define BIG_ENDIAN 4321
/* #define BYTEORDER 1234 ? ���������ϵͳ�����жϴ�С��. */
#ifndef BYTEORDER
#if defined(__hppa__) || \
defined(__m68k__) || defined(mc68000) || defined(_M_M68K) || \
(defined(__MIPS__) && defined(__MISPEB__)) || \
defined(__ppc__) || defined(__POWERPC__) || defined(_M_PPC) || \
defined(__sparc__)
#define BYTEORDER BIG_ENDIAN
#else
#define BYTEORDER LIL_ENDIAN
#endif
#endif /* !BYTEORDER */
uint16_t Swap16(uint16_t x);
uint32_t Swap32(uint32_t x);
uint64_t Swap64(uint64_t x);
#if BYTEORDER == LIL_ENDIAN
#define SwapLE16(X) (X)
#define SwapLE32(X) (X)
#define SwapLE64(X) (X)
#define SwapBE16(X) Swap16(X)
#define SwapBE32(X) Swap32(X)
#define SwapBE64(X) Swap64(X)
#else
#define SwapLE16(X) Swap16(X)
#define SwapLE32(X) Swap32(X)
#define SwapLE64(X) Swap64(X)
#define SwapBE16(X) (X)
#define SwapBE32(X) (X)
#define SwapBE64(X) (X)
#endif
uint16_t read_le16(stream_t *src);
uint16_t read_be16(stream_t *src);
uint32_t read_le32(stream_t *src);
uint32_t read_be32(stream_t *src);
uint64_t read_le64(stream_t *src);
uint64_t read_be64(stream_t *src);
int write_le16(stream_t *dst, uint16_t value);
int write_be16(stream_t *dst, uint16_t value);
int write_le32(stream_t *dst, uint32_t value);
int write_be32(stream_t *dst, uint32_t value);
int write_le64(stream_t *dst, uint64_t value);
int write_be64(stream_t *dst, uint64_t value);
#endif // __STREAM_H__