50 #define OFFSET(x) offsetof(TCPContext, x)
51 #define D AV_OPT_FLAG_DECODING_PARAM
52 #define E AV_OPT_FLAG_ENCODING_PARAM
54 {
"listen",
"Listen for incoming connections",
OFFSET(listen),
AV_OPT_TYPE_INT, { .i64 = 0 }, 0, 2, .flags =
D|
E },
55 {
"timeout",
"set timeout (in microseconds) of socket I/O operations",
OFFSET(rw_timeout),
AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags =
D|
E },
56 {
"listen_timeout",
"Connection awaiting timeout (in milliseconds)",
OFFSET(listen_timeout),
AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags =
D|
E },
57 {
"send_buffer_size",
"Socket send buffer size (in bytes)",
OFFSET(send_buffer_size),
AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags =
D|
E },
58 {
"recv_buffer_size",
"Socket receive buffer size (in bytes)",
OFFSET(recv_buffer_size),
AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags =
D|
E },
59 {
"tcp_nodelay",
"Use TCP_NODELAY to disable nagle's algorithm",
OFFSET(tcp_nodelay),
AV_OPT_TYPE_BOOL, { .i64 = 0 }, 0, 1, .flags =
D|
E },
61 {
"tcp_mss",
"Maximum segment size for outgoing TCP packets",
OFFSET(tcp_mss),
AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags =
D|
E },
78 if (
s->recv_buffer_size > 0) {
79 if (setsockopt (fd, SOL_SOCKET, SO_RCVBUF, &
s->recv_buffer_size, sizeof (
s->recv_buffer_size))) {
83 if (
s->send_buffer_size > 0) {
84 if (setsockopt (fd, SOL_SOCKET, SO_SNDBUF, &
s->send_buffer_size, sizeof (
s->send_buffer_size))) {
88 if (
s->tcp_nodelay > 0) {
89 if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &
s->tcp_nodelay, sizeof (
s->tcp_nodelay))) {
95 if (setsockopt (fd, IPPROTO_TCP, TCP_MAXSEG, &
s->tcp_mss, sizeof (
s->tcp_mss))) {
105 struct addrinfo hints = { 0 }, *ai, *cur_ai;
111 char hostname[1024],proto[1024],path[1024];
113 s->open_timeout = 5000000;
116 &port, path,
sizeof(path), uri);
117 if (strcmp(proto,
"tcp"))
119 if (port <= 0 || port >= 65536) {
123 p = strchr(uri,
'?');
127 s->listen = strtol(buf, &endptr, 10);
133 s->rw_timeout = strtol(buf,
NULL, 10);
136 s->listen_timeout = strtol(buf,
NULL, 10);
139 if (
s->rw_timeout >= 0) {
141 h->rw_timeout =
s->rw_timeout;
145 snprintf(portstr,
sizeof(portstr),
"%d", port);
154 "Failed to resolve hostname %s: %s\n",
161 #if HAVE_STRUCT_SOCKADDR_IN6
163 if (cur_ai->ai_family == AF_INET6){
164 struct sockaddr_in6 * sockaddr_v6 = (
struct sockaddr_in6 *)cur_ai->ai_addr;
165 if (!sockaddr_v6->sin6_port){
166 sockaddr_v6->sin6_port = htons(port);
172 while (cur_ai && fd < 0) {
175 cur_ai->ai_protocol);
178 cur_ai = cur_ai->ai_next;
186 if (
s->listen == 2) {
188 if ((ret =
ff_listen(fd, cur_ai->ai_addr, cur_ai->ai_addrlen)) < 0)
190 }
else if (
s->listen == 1) {
192 if ((ret =
ff_listen_bind(fd, cur_ai->ai_addr, cur_ai->ai_addrlen,
193 s->listen_timeout,
h)) < 0)
222 if ((ret =
ffurl_alloc(
c,
s->filename,
s->flags, &
s->interrupt_callback)) < 0)
224 cc = (*c)->priv_data;
244 ret = recv(
s->fd, buf,
size, 0);
277 return shutdown(
s->fd, how);
297 socklen_t avail_len =
sizeof(avail);
302 if (
s->recv_buffer_size < 0) {
307 if (getsockopt(
s->fd, SOL_SOCKET, SO_RCVBUF, &avail, &avail_len)) {
simple assert() macros that are a bit more flexible than ISO C assert().
#define av_assert0(cond)
assert() equivalent, that is always enabled.
int ffurl_alloc(URLContext **puc, const char *filename, int flags, const AVIOInterruptCB *int_cb)
Create a URLContext for accessing to the resource indicated by url, but do not initiate the connectio...
int ffurl_closep(URLContext **hh)
Close the resource accessed by the URLContext h, and free the memory used by it.
#define AVIO_FLAG_READ
read-only
#define AVIO_FLAG_WRITE
write-only
#define AVIO_FLAG_NONBLOCK
Use non-blocking mode.
#define flags(name, subs,...)
void av_url_split(char *proto, int proto_size, char *authorization, int authorization_size, char *hostname, int hostname_size, int *port_ptr, char *path, int path_size, const char *url)
Split a URL string into components.
#define AVERROR_EOF
End of file.
#define AV_LOG_WARNING
Something somehow does not look correct.
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
const char * av_default_item_name(void *ptr)
Return the context name.
#define LIBAVUTIL_VERSION_INT
common internal API header
int ff_listen(int fd, const struct sockaddr *addr, socklen_t addrlen)
Bind to a file descriptor to an address without accepting connections.
int ff_socket(int af, int type, int proto)
void ff_log_net_error(void *ctx, int level, const char *prefix)
int ff_listen_bind(int fd, const struct sockaddr *addr, socklen_t addrlen, int timeout, URLContext *h)
Bind to a file descriptor and poll for a connection.
int ff_connect_parallel(struct addrinfo *addrs, int timeout_ms_per_address, int parallel, URLContext *h, int *fd, void(*customize_fd)(void *, int), void *customize_ctx)
Connect to any of the given addrinfo addresses, with multiple attempts running in parallel.
int ff_network_wait_fd_timeout(int fd, int write, int64_t timeout, AVIOInterruptCB *int_cb)
This works similarly to ff_network_wait_fd, but waits up to 'timeout' microseconds Uses ff_network_wa...
int ff_accept(int fd, int timeout, URLContext *h)
Poll for a single connection on the passed file descriptor.
miscellaneous OS support macros and functions.
int av_find_info_tag(char *arg, int arg_size, const char *tag1, const char *info)
Attempt to find a specific tag in a URL.
Describe the class of an AVClass context structure.
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
static int tcp_close(URLContext *h)
static const AVClass tcp_class
static int tcp_accept(URLContext *s, URLContext **c)
static const AVOption options[]
static int tcp_write(URLContext *h, const uint8_t *buf, int size)
static int tcp_get_window_size(URLContext *h)
static int tcp_open(URLContext *h, const char *uri, int flags)
static void customize_fd(void *ctx, int fd)
static int tcp_read(URLContext *h, uint8_t *buf, int size)
const URLProtocol ff_tcp_protocol
static int tcp_shutdown(URLContext *h, int flags)
static int tcp_get_file_handle(URLContext *h)
unbuffered private I/O API
#define URL_PROTOCOL_FLAG_NETWORK