|
|
|
@ -42,8 +42,10 @@ URLProtocol *ffurl_protocol_next(URLProtocol *prev) |
|
|
|
|
static const char *urlcontext_to_name(void *ptr) |
|
|
|
|
{ |
|
|
|
|
URLContext *h = (URLContext *)ptr; |
|
|
|
|
if(h->prot) return h->prot->name; |
|
|
|
|
else return "NULL"; |
|
|
|
|
if (h->prot) |
|
|
|
|
return h->prot->name; |
|
|
|
|
else |
|
|
|
|
return "NULL"; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static void *urlcontext_child_next(void *obj, void *prev) |
|
|
|
@ -68,26 +70,25 @@ static const AVClass *urlcontext_child_class_next(const AVClass *prev) |
|
|
|
|
if (p->priv_data_class) |
|
|
|
|
return p->priv_data_class; |
|
|
|
|
return NULL; |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static const AVOption options[] = {{NULL}}; |
|
|
|
|
static const AVOption options[] = { { NULL } }; |
|
|
|
|
const AVClass ffurl_context_class = { |
|
|
|
|
.class_name = "URLContext", |
|
|
|
|
.item_name = urlcontext_to_name, |
|
|
|
|
.option = options, |
|
|
|
|
.version = LIBAVUTIL_VERSION_INT, |
|
|
|
|
.child_next = urlcontext_child_next, |
|
|
|
|
.class_name = "URLContext", |
|
|
|
|
.item_name = urlcontext_to_name, |
|
|
|
|
.option = options, |
|
|
|
|
.version = LIBAVUTIL_VERSION_INT, |
|
|
|
|
.child_next = urlcontext_child_next, |
|
|
|
|
.child_class_next = urlcontext_child_class_next, |
|
|
|
|
}; |
|
|
|
|
/*@}*/ |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const char *avio_enum_protocols(void **opaque, int output) |
|
|
|
|
{ |
|
|
|
|
URLProtocol *p; |
|
|
|
|
*opaque = ffurl_protocol_next(*opaque); |
|
|
|
|
if (!(p = *opaque)) return NULL; |
|
|
|
|
if (!(p = *opaque)) |
|
|
|
|
return NULL; |
|
|
|
|
if ((output && p->url_write) || (!output && p->url_read)) |
|
|
|
|
return p->name; |
|
|
|
|
return avio_enum_protocols(opaque, output); |
|
|
|
@ -97,20 +98,21 @@ int ffurl_register_protocol(URLProtocol *protocol, int size) |
|
|
|
|
{ |
|
|
|
|
URLProtocol **p; |
|
|
|
|
if (size < sizeof(URLProtocol)) { |
|
|
|
|
URLProtocol* temp = av_mallocz(sizeof(URLProtocol)); |
|
|
|
|
URLProtocol *temp = av_mallocz(sizeof(URLProtocol)); |
|
|
|
|
memcpy(temp, protocol, size); |
|
|
|
|
protocol = temp; |
|
|
|
|
} |
|
|
|
|
p = &first_protocol; |
|
|
|
|
while (*p != NULL) p = &(*p)->next; |
|
|
|
|
*p = protocol; |
|
|
|
|
while (*p != NULL) |
|
|
|
|
p = &(*p)->next; |
|
|
|
|
*p = protocol; |
|
|
|
|
protocol->next = NULL; |
|
|
|
|
return 0; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static int url_alloc_for_protocol (URLContext **puc, struct URLProtocol *up, |
|
|
|
|
const char *filename, int flags, |
|
|
|
|
const AVIOInterruptCB *int_cb) |
|
|
|
|
static int url_alloc_for_protocol(URLContext **puc, struct URLProtocol *up, |
|
|
|
|
const char *filename, int flags, |
|
|
|
|
const AVIOInterruptCB *int_cb) |
|
|
|
|
{ |
|
|
|
|
URLContext *uc; |
|
|
|
|
int err; |
|
|
|
@ -135,11 +137,11 @@ static int url_alloc_for_protocol (URLContext **puc, struct URLProtocol *up, |
|
|
|
|
goto fail; |
|
|
|
|
} |
|
|
|
|
uc->av_class = &ffurl_context_class; |
|
|
|
|
uc->filename = (char *) &uc[1]; |
|
|
|
|
uc->filename = (char *)&uc[1]; |
|
|
|
|
strcpy(uc->filename, filename); |
|
|
|
|
uc->prot = up; |
|
|
|
|
uc->flags = flags; |
|
|
|
|
uc->is_streamed = 0; /* default = not streamed */ |
|
|
|
|
uc->prot = up; |
|
|
|
|
uc->flags = flags; |
|
|
|
|
uc->is_streamed = 0; /* default = not streamed */ |
|
|
|
|
uc->max_packet_size = 0; /* default: stream file */ |
|
|
|
|
if (up->priv_data_size) { |
|
|
|
|
uc->priv_data = av_mallocz(up->priv_data_size); |
|
|
|
@ -150,7 +152,7 @@ static int url_alloc_for_protocol (URLContext **puc, struct URLProtocol *up, |
|
|
|
|
if (up->priv_data_class) { |
|
|
|
|
int proto_len= strlen(up->name); |
|
|
|
|
char *start = strchr(uc->filename, ','); |
|
|
|
|
*(const AVClass**)uc->priv_data = up->priv_data_class; |
|
|
|
|
*(const AVClass **)uc->priv_data = up->priv_data_class; |
|
|
|
|
av_opt_set_defaults(uc->priv_data); |
|
|
|
|
if(!strncmp(up->name, uc->filename, proto_len) && uc->filename + proto_len == start){ |
|
|
|
|
int ret= 0; |
|
|
|
@ -182,7 +184,7 @@ static int url_alloc_for_protocol (URLContext **puc, struct URLProtocol *up, |
|
|
|
|
|
|
|
|
|
*puc = uc; |
|
|
|
|
return 0; |
|
|
|
|
fail: |
|
|
|
|
fail: |
|
|
|
|
*puc = NULL; |
|
|
|
|
if (uc) |
|
|
|
|
av_freep(&uc->priv_data); |
|
|
|
@ -194,19 +196,22 @@ static int url_alloc_for_protocol (URLContext **puc, struct URLProtocol *up, |
|
|
|
|
return err; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
int ffurl_connect(URLContext* uc, AVDictionary **options) |
|
|
|
|
int ffurl_connect(URLContext *uc, AVDictionary **options) |
|
|
|
|
{ |
|
|
|
|
int err = |
|
|
|
|
uc->prot->url_open2 ? uc->prot->url_open2(uc, uc->filename, uc->flags, options) : |
|
|
|
|
uc->prot->url_open2 ? uc->prot->url_open2(uc, |
|
|
|
|
uc->filename, |
|
|
|
|
uc->flags, |
|
|
|
|
options) : |
|
|
|
|
uc->prot->url_open(uc, uc->filename, uc->flags); |
|
|
|
|
if (err) |
|
|
|
|
return err; |
|
|
|
|
uc->is_connected = 1; |
|
|
|
|
//We must be careful here as ffurl_seek() could be slow, for example for http
|
|
|
|
|
if( (uc->flags & AVIO_FLAG_WRITE) |
|
|
|
|
|| !strcmp(uc->prot->name, "file")) |
|
|
|
|
if(!uc->is_streamed && ffurl_seek(uc, 0, SEEK_SET) < 0) |
|
|
|
|
uc->is_streamed= 1; |
|
|
|
|
/* We must be careful here as ffurl_seek() could be slow,
|
|
|
|
|
* for example for http */ |
|
|
|
|
if ((uc->flags & AVIO_FLAG_WRITE) || !strcmp(uc->prot->name, "file")) |
|
|
|
|
if (!uc->is_streamed && ffurl_seek(uc, 0, SEEK_SET) < 0) |
|
|
|
|
uc->is_streamed = 1; |
|
|
|
|
return 0; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -232,7 +237,8 @@ int ffurl_alloc(URLContext **puc, const char *filename, int flags, |
|
|
|
|
is_dos_path(filename)) |
|
|
|
|
strcpy(proto_str, "file"); |
|
|
|
|
else |
|
|
|
|
av_strlcpy(proto_str, filename, FFMIN(proto_len+1, sizeof(proto_str))); |
|
|
|
|
av_strlcpy(proto_str, filename, |
|
|
|
|
FFMIN(proto_len + 1, sizeof(proto_str))); |
|
|
|
|
|
|
|
|
|
if ((ptr = strchr(proto_str, ','))) |
|
|
|
|
*ptr = '\0'; |
|
|
|
@ -242,10 +248,10 @@ int ffurl_alloc(URLContext **puc, const char *filename, int flags, |
|
|
|
|
|
|
|
|
|
while (up = ffurl_protocol_next(up)) { |
|
|
|
|
if (!strcmp(proto_str, up->name)) |
|
|
|
|
return url_alloc_for_protocol (puc, up, filename, flags, int_cb); |
|
|
|
|
return url_alloc_for_protocol(puc, up, filename, flags, int_cb); |
|
|
|
|
if (up->flags & URL_PROTOCOL_FLAG_NESTED_SCHEME && |
|
|
|
|
!strcmp(proto_nested, up->name)) |
|
|
|
|
return url_alloc_for_protocol (puc, up, filename, flags, int_cb); |
|
|
|
|
return url_alloc_for_protocol(puc, up, filename, flags, int_cb); |
|
|
|
|
} |
|
|
|
|
*puc = NULL; |
|
|
|
|
if (!strcmp("https", proto_str)) |
|
|
|
@ -271,8 +277,11 @@ fail: |
|
|
|
|
return ret; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static inline int retry_transfer_wrapper(URLContext *h, unsigned char *buf, int size, int size_min, |
|
|
|
|
int (*transfer_func)(URLContext *h, unsigned char *buf, int size)) |
|
|
|
|
static inline int retry_transfer_wrapper(URLContext *h, uint8_t *buf, |
|
|
|
|
int size, int size_min, |
|
|
|
|
int (*transfer_func)(URLContext *h, |
|
|
|
|
uint8_t *buf, |
|
|
|
|
int size)) |
|
|
|
|
{ |
|
|
|
|
int ret, len; |
|
|
|
|
int fast_retries = 5; |
|
|
|
@ -282,7 +291,7 @@ static inline int retry_transfer_wrapper(URLContext *h, unsigned char *buf, int |
|
|
|
|
while (len < size_min) { |
|
|
|
|
if (ff_check_interrupt(&h->interrupt_callback)) |
|
|
|
|
return AVERROR_EXIT; |
|
|
|
|
ret = transfer_func(h, buf+len, size-len); |
|
|
|
|
ret = transfer_func(h, buf + len, size - len); |
|
|
|
|
if (ret == AVERROR(EINTR)) |
|
|
|
|
continue; |
|
|
|
|
if (h->flags & AVIO_FLAG_NONBLOCK) |
|
|
|
@ -303,7 +312,7 @@ static inline int retry_transfer_wrapper(URLContext *h, unsigned char *buf, int |
|
|
|
|
} else if (ret < 1) |
|
|
|
|
return (ret < 0 && ret != AVERROR_EOF) ? ret : len; |
|
|
|
|
if (ret) |
|
|
|
|
fast_retries = FFMAX(fast_retries, 2); |
|
|
|
|
fast_retries = FFMAX(fast_retries, 2); |
|
|
|
|
len += ret; |
|
|
|
|
} |
|
|
|
|
return len; |
|
|
|
@ -348,7 +357,8 @@ int ffurl_closep(URLContext **hh) |
|
|
|
|
{ |
|
|
|
|
URLContext *h= *hh; |
|
|
|
|
int ret = 0; |
|
|
|
|
if (!h) return 0; /* can happen when ffurl_open fails */ |
|
|
|
|
if (!h) |
|
|
|
|
return 0; /* can happen when ffurl_open fails */ |
|
|
|
|
|
|
|
|
|
if (h->is_connected && h->prot->url_close) |
|
|
|
|
ret = h->prot->url_close(h); |
|
|
|
@ -394,8 +404,8 @@ int64_t ffurl_size(URLContext *h) |
|
|
|
|
{ |
|
|
|
|
int64_t pos, size; |
|
|
|
|
|
|
|
|
|
size= ffurl_seek(h, 0, AVSEEK_SIZE); |
|
|
|
|
if(size<0){ |
|
|
|
|
size = ffurl_seek(h, 0, AVSEEK_SIZE); |
|
|
|
|
if (size < 0) { |
|
|
|
|
pos = ffurl_seek(h, 0, SEEK_CUR); |
|
|
|
|
if ((size = ffurl_seek(h, -1, SEEK_END)) < 0) |
|
|
|
|
return size; |
|
|
|
|