summaryrefslogtreecommitdiff
path: root/libavformat/tcp.c
diff options
context:
space:
mode:
authorAman Gupta <aman@tmm1.net>2017-11-13 12:20:18 -0800
committerAman Gupta <aman@tmm1.net>2017-11-17 10:48:55 -0800
commit80bb81a8f34729443bdbcdb3bc2c89c221291fe6 (patch)
tree546aaf82c1ad431bfc096c6a1ea882af3b872056 /libavformat/tcp.c
parentce001bb8fc6677541c401a614e05e5058d58dde1 (diff)
avformat/tcp: add option to enable TCP_NODELAY
This can reduce latency and increase throughput, particularly on high latency networks. Signed-off-by: Aman Gupta <aman@tmm1.net> Reviewed-by: Jeyapal, Karthick <kjeyapal@akamai.com>
Diffstat (limited to 'libavformat/tcp.c')
-rw-r--r--libavformat/tcp.c5
1 files changed, 5 insertions, 0 deletions
diff --git a/libavformat/tcp.c b/libavformat/tcp.c
index 07b4ed9fa3..f3f9d4f431 100644
--- a/libavformat/tcp.c
+++ b/libavformat/tcp.c
@@ -41,6 +41,7 @@ typedef struct TCPContext {
int listen_timeout;
int recv_buffer_size;
int send_buffer_size;
+ int tcp_nodelay;
} TCPContext;
#define OFFSET(x) offsetof(TCPContext, x)
@@ -52,6 +53,7 @@ static const AVOption options[] = {
{ "listen_timeout", "Connection awaiting timeout (in milliseconds)", OFFSET(listen_timeout), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E },
{ "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 },
{ "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 },
+ { "tcp_nodelay", "Use TCP_NODELAY to disable nagle's algorithm", OFFSET(tcp_nodelay), AV_OPT_TYPE_BOOL, { .i64 = 0 }, 0, 1, .flags = D|E },
{ NULL }
};
@@ -148,6 +150,9 @@ static int tcp_open(URLContext *h, const char *uri, int flags)
if (s->send_buffer_size > 0) {
setsockopt (fd, SOL_SOCKET, SO_SNDBUF, &s->send_buffer_size, sizeof (s->send_buffer_size));
}
+ if (s->tcp_nodelay > 0) {
+ setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &s->tcp_nodelay, sizeof (s->tcp_nodelay));
+ }
if (s->listen == 2) {
// multi-client