34 #define IO_BUFFER_SIZE 32768
41 #define SHORT_SEEK_THRESHOLD 4096
76 int (*
read_packet)(
void *opaque, uint8_t *buf,
int buf_size),
77 int (*
write_packet)(
void *opaque, uint8_t *buf,
int buf_size),
78 int64_t (*seek)(
void *opaque, int64_t offset,
int whence))
109 unsigned char *buffer,
113 int (*
read_packet)(
void *opaque, uint8_t *buf,
int buf_size),
114 int (*
write_packet)(
void *opaque, uint8_t *buf,
int buf_size),
115 int64_t (*seek)(
void *opaque, int64_t offset,
int whence))
121 unsigned char *buffer,
125 int (*
read_packet)(
void *opaque, uint8_t *buf,
int buf_size),
126 int (*
write_packet)(
void *opaque, uint8_t *buf,
int buf_size),
127 int64_t (*seek)(
void *opaque, int64_t offset,
int whence))
135 unsigned char *buffer,
139 int (*
read_packet)(
void *opaque, uint8_t *buf,
int buf_size),
140 int (*
write_packet)(
void *opaque, uint8_t *buf,
int buf_size),
141 int64_t (*seek)(
void *opaque, int64_t offset,
int whence))
216 whence &= ~AVSEEK_FORCE;
223 if (whence != SEEK_CUR && whence != SEEK_SET)
226 if (whence == SEEK_CUR) {
232 offset1 = offset - pos;
240 (whence != SEEK_END || force)) {
249 #if CONFIG_MUXERS || CONFIG_NETWORK
257 if ((res = s->
seek(s->
opaque, offset, SEEK_SET)) < 0)
271 int64_t ret =
avio_seek(s, offset, SEEK_CUR);
272 return ret < 0 ? ret : 0;
292 if ((size = s->
seek(s->
opaque, -1, SEEK_END)) < 0)
338 #define GET(name, type) \
339 type get_be ##name(AVIOContext *s) \
341 return avio_rb ##name(s);\
343 type get_le ##name(AVIOContext *s) \
345 return avio_rl ##name(s);\
348 GET(16,
unsigned int)
349 GET(24,
unsigned int)
350 GET(32,
unsigned int)
355 #define PUT(name, type ) \
356 void put_le ##name(AVIOContext *s, type val)\
358 avio_wl ##name(s, val);\
360 void put_be ##name(AVIOContext *s, type val)\
362 avio_wb ##name(s, val);\
365 PUT(16,
unsigned int)
366 PUT(24,
unsigned int)
367 PUT(32,
unsigned int)
404 int64_t url_fseek(
AVIOContext *s, int64_t offset,
int whence)
416 int url_fprintf(
AVIOContext *s,
const char *fmt, ...)
423 ret = vsnprintf(buf,
sizeof(buf), fmt, ap);
436 int64_t av_url_read_fseek(
AVIOContext *s,
int stream_index,
437 int64_t timestamp,
int flags)
442 unsigned long (*update_checksum)(
unsigned long c,
const uint8_t *p,
unsigned int len),
443 unsigned long checksum)
455 int url_open_dyn_packet_buf(
AVIOContext **s,
int max_packet_size)
459 int url_close_dyn_buf(
AVIOContext *s, uint8_t **pbuffer)
474 avio_write(s, (
const unsigned char *) str, len);
482 const uint8_t *q = str;
510 avio_w8(bc, 128 | (val>>(7*i)));
517 avio_wl32(s, (uint32_t)(val & 0xffffffff));
524 avio_wb32(s, (uint32_t)(val & 0xffffffff));
621 unsigned long (*update_checksum)(
unsigned long c,
const uint8_t *p,
unsigned int len),
622 unsigned long checksum)
778 char *get_strz(
AVIOContext *s,
char *buf,
int maxlen)
792 if (c && i < maxlen-1)
794 }
while (c !=
'\n' && c);
807 buflen =
FFMIN(buflen - 1, maxlen);
808 for (i = 0; i < buflen; i++)
812 for (; i < maxlen; i++)
818 #define GET_STR16(type, read) \
819 int avio_get_str16 ##type(AVIOContext *pb, int maxlen, char *buf, int buflen)\
824 return AVERROR(EINVAL); \
825 while (ret + 1 < maxlen) {\
828 GET_UTF16(ch, (ret += 2) <= maxlen ? read(pb) : 0, break;)\
831 PUT_UTF8(ch, tmp, if (q - buf < buflen - 1) *q++ = tmp;)\
856 val= (val<<7) + (tmp&127);
864 int buffer_size, max_packet_size;
867 if (max_packet_size) {
868 buffer_size = max_packet_size;
886 (*s)->max_packet_size = max_packet_size;
889 (*s)->read_seek = (int64_t (*)(
void *, int, int64_t, int))h->
prot->
url_read_seek;
928 int64_t buffer_start;
930 int overlap, new_size, alloc_size;
938 if ((buffer_start = s->
pos - buffer_size) > buf_size)
941 overlap = buf_size - buffer_start;
942 new_size = buf_size + buffer_size - overlap;
945 if (alloc_size > buf_size)
949 if (new_size > buf_size) {
950 memcpy(buf + buf_size, s->
buffer + overlap, buffer_size - overlap);
976 err =
ffurl_open(&h, filename, flags, int_cb, options);
1010 ret = vsnprintf(buf,
sizeof(buf), fmt, ap);
1017 char *url_fgets(
AVIOContext *s,
char *buf,
int buf_size)
1029 if ((q - buf) < buf_size - 1)
1052 int64_t timestamp,
int flags)
1058 ret = s->
read_seek(h, stream_index, timestamp, flags);
1062 pos = s->
seek(h, 0, SEEK_CUR);
1065 else if (pos !=
AVERROR(ENOSYS))
1106 unsigned new_size, new_allocated_size;
1109 new_size = d->
pos + buf_size;
1111 if(new_size < d->pos || new_size > INT_MAX/2)
1113 while (new_size > new_allocated_size) {
1114 if (!new_allocated_size)
1115 new_allocated_size = new_size;
1117 new_allocated_size += new_allocated_size / 2 + 1;
1126 memcpy(d->
buffer + d->
pos, buf, buf_size);
1135 unsigned char buf1[4];
1152 if (whence == SEEK_CUR)
1154 else if (whence == SEEK_END)
1156 if (offset < 0 || offset > 0x7fffffffLL)
1165 unsigned io_buffer_size = max_packet_size ? max_packet_size : 1024;
1167 if(
sizeof(
DynBuffer) + io_buffer_size < io_buffer_size)
1180 (*s)->max_packet_size = max_packet_size;
1191 if (max_packet_size <= 0)
1215 return size - padding;