libavformat/tcp.c - third_party/ffmpeg - Git at Google

 /*
  * TCP protocol
  * Copyright (c) 2002 Fabrice Bellard
  *
  * This file is part of FFmpeg.
  *
  * FFmpeg is free software; you can redistribute it and/or
  * modify it under the terms of the GNU Lesser General Public
  * License as published by the Free Software Foundation; either
  * version 2.1 of the License, or (at your option) any later version.
  *
  * FFmpeg is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  * Lesser General Public License for more details.
  *
  * You should have received a copy of the GNU Lesser General Public
  * License along with FFmpeg; if not, write to the Free Software
  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  */
 #include "avformat.h"
 #include "libavutil/parseutils.h"
 #include "libavutil/opt.h"
 #include "internal.h"
 #include "network.h"
 #include "os_support.h"
 #include "url.h"
 #if HAVE_POLL_H
 #include <poll.h>
 #endif

 typedef struct TCPContext {
     const AVClass *class;
     int fd;
     int listen;
     int rw_timeout;
     int listen_timeout;
 } TCPContext;

 #define OFFSET(x) offsetof(TCPContext, x)
 #define D AV_OPT_FLAG_DECODING_PARAM
 #define E AV_OPT_FLAG_ENCODING_PARAM
 static const AVOption options[] = {
 {"listen", "listen on port instead of connecting", OFFSET(listen), AV_OPT_TYPE_INT, {.i64 = 0}, 0, 1, D|E },
 {"timeout", "timeout of socket i/o operations", OFFSET(rw_timeout), AV_OPT_TYPE_INT, {.i64 = 0}, 0, INT_MAX, D|E },
 {"listen_timeout", "connection awaiting timeout", OFFSET(listen_timeout), AV_OPT_TYPE_INT, {.i64 = -1}, -1, INT_MAX, D|E },
 {NULL}
 };

 static const AVClass tcp_context_class = {
     .class_name = "tcp",
     .item_name  = av_default_item_name,
     .option     = options,
     .version    = LIBAVUTIL_VERSION_INT,
 };

 /* return non zero if error */
 static int tcp_open(URLContext *h, const char *uri, int flags)
 {
     struct addrinfo hints = { 0 }, *ai, *cur_ai;
     int port, fd = -1;
     TCPContext *s = h->priv_data;
     const char *p;
     char buf[256];
     int ret;
     socklen_t optlen;
     char hostname[1024],proto[1024],path[1024];
     char portstr[10];
     h->rw_timeout = 5000000;

     av_url_split(proto, sizeof(proto), NULL, 0, hostname, sizeof(hostname),
         &port, path, sizeof(path), uri);
     if (strcmp(proto, "tcp"))
         return AVERROR(EINVAL);
     if (port <= 0 || port >= 65536) {
         av_log(h, AV_LOG_ERROR, "Port missing in uri\n");
         return AVERROR(EINVAL);
     }
     p = strchr(uri, '?');
     if (p) {
         if (av_find_info_tag(buf, sizeof(buf), "listen", p))
             s->listen = 1;
         if (av_find_info_tag(buf, sizeof(buf), "timeout", p)) {
             s->rw_timeout = strtol(buf, NULL, 10);
         }
         if (av_find_info_tag(buf, sizeof(buf), "listen_timeout", p)) {
             s->listen_timeout = strtol(buf, NULL, 10);
         }
     }
     h->rw_timeout = s->rw_timeout;
     hints.ai_family = AF_UNSPEC;
     hints.ai_socktype = SOCK_STREAM;
     snprintf(portstr, sizeof(portstr), "%d", port);
     if (s->listen)
         hints.ai_flags |= AI_PASSIVE;
     if (!hostname[0])
         ret = getaddrinfo(NULL, portstr, &hints, &ai);
     else
         ret = getaddrinfo(hostname, portstr, &hints, &ai);
     if (ret) {
         av_log(h, AV_LOG_ERROR,
                "Failed to resolve hostname %s: %s\n",
                hostname, gai_strerror(ret));
         return AVERROR(EIO);
     }

     cur_ai = ai;

  restart:
     ret = AVERROR(EIO);
     fd = socket(cur_ai->ai_family, cur_ai->ai_socktype, cur_ai->ai_protocol);
     if (fd < 0)
         goto fail;

     if (s->listen) {
         int fd1;
         int reuse = 1;
         struct pollfd lp = { fd, POLLIN, 0 };
         setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse));
         ret = bind(fd, cur_ai->ai_addr, cur_ai->ai_addrlen);
         if (ret) {
             ret = ff_neterrno();
             goto fail1;
         }
         ret = listen(fd, 1);
         if (ret) {
             ret = ff_neterrno();
             goto fail1;
         }
         ret = poll(&lp, 1, s->listen_timeout >= 0 ? s->listen_timeout : -1);
         if (ret <= 0) {
             ret = AVERROR(ETIMEDOUT);
             goto fail1;
         }
         fd1 = accept(fd, NULL, NULL);
         if (fd1 < 0) {
             ret = ff_neterrno();
             goto fail1;
         }
         closesocket(fd);
         fd = fd1;
         ff_socket_nonblock(fd, 1);
     } else {
  redo:
         ff_socket_nonblock(fd, 1);
         ret = connect(fd, cur_ai->ai_addr, cur_ai->ai_addrlen);
     }

     if (ret < 0) {
         struct pollfd p = {fd, POLLOUT, 0};
         int64_t wait_started;
         ret = ff_neterrno();
         if (ret == AVERROR(EINTR)) {
             if (ff_check_interrupt(&h->interrupt_callback)) {
                 ret = AVERROR_EXIT;
                 goto fail1;
             }
             goto redo;
         }
         if (ret != AVERROR(EINPROGRESS) &&
             ret != AVERROR(EAGAIN))
             goto fail;

         /* wait until we are connected or until abort */
         wait_started = av_gettime();
         do {
             if (ff_check_interrupt(&h->interrupt_callback)) {
                 ret = AVERROR_EXIT;
                 goto fail1;
             }
             ret = poll(&p, 1, 100);
             if (ret > 0)
                 break;
         } while (!h->rw_timeout || (av_gettime() - wait_started < h->rw_timeout));
         if (ret <= 0) {
             ret = AVERROR(ETIMEDOUT);
             goto fail;
         }
         /* test error */
         optlen = sizeof(ret);
         if (getsockopt (fd, SOL_SOCKET, SO_ERROR, &ret, &optlen))
             ret = AVUNERROR(ff_neterrno());
         if (ret != 0) {
             char errbuf[100];
             ret = AVERROR(ret);
             av_strerror(ret, errbuf, sizeof(errbuf));
             av_log(h, AV_LOG_ERROR,
                    "TCP connection to %s:%d failed: %s\n",
                    hostname, port, errbuf);
             goto fail;
         }
     }
     h->is_streamed = 1;
     s->fd = fd;
     freeaddrinfo(ai);
     return 0;

  fail:
     if (cur_ai->ai_next) {
         /* Retry with the next sockaddr */
         cur_ai = cur_ai->ai_next;
         if (fd >= 0)
             closesocket(fd);
         goto restart;
     }
  fail1:
     if (fd >= 0)
         closesocket(fd);
     freeaddrinfo(ai);
     return ret;
 }

 static int tcp_read(URLContext *h, uint8_t *buf, int size)
 {
     TCPContext *s = h->priv_data;
     int ret;

     if (!(h->flags & AVIO_FLAG_NONBLOCK)) {
         ret = ff_network_wait_fd_timeout(s->fd, 0, h->rw_timeout, &h->interrupt_callback);
         if (ret)
             return ret;
     }
     ret = recv(s->fd, buf, size, 0);
     return ret < 0 ? ff_neterrno() : ret;
 }

 static int tcp_write(URLContext *h, const uint8_t *buf, int size)
 {
     TCPContext *s = h->priv_data;
     int ret;

     if (!(h->flags & AVIO_FLAG_NONBLOCK)) {
         ret = ff_network_wait_fd_timeout(s->fd, 1, h->rw_timeout, &h->interrupt_callback);
         if (ret)
             return ret;
     }
     ret = send(s->fd, buf, size, 0);
     return ret < 0 ? ff_neterrno() : ret;
 }

 static int tcp_shutdown(URLContext *h, int flags)
 {
     TCPContext *s = h->priv_data;
     int how;

     if (flags & AVIO_FLAG_WRITE && flags & AVIO_FLAG_READ) {
         how = SHUT_RDWR;
     } else if (flags & AVIO_FLAG_WRITE) {
         how = SHUT_WR;
     } else {
         how = SHUT_RD;
     }

     return shutdown(s->fd, how);
 }

 static int tcp_close(URLContext *h)
 {
     TCPContext *s = h->priv_data;
     closesocket(s->fd);
     return 0;
 }

 static int tcp_get_file_handle(URLContext *h)
 {
     TCPContext *s = h->priv_data;
     return s->fd;
 }

 URLProtocol ff_tcp_protocol = {
     .name                = "tcp",
     .url_open            = tcp_open,
     .url_read            = tcp_read,
     .url_write           = tcp_write,
     .url_close           = tcp_close,
     .url_get_file_handle = tcp_get_file_handle,
     .url_shutdown        = tcp_shutdown,
     .priv_data_size      = sizeof(TCPContext),
     .priv_data_class     = &tcp_context_class,
     .flags               = URL_PROTOCOL_FLAG_NETWORK,
 };
	/*
	* TCP protocol
	* Copyright (c) 2002 Fabrice Bellard
	*
	* This file is part of FFmpeg.
	*
	* FFmpeg is free software; you can redistribute it and/or
	* modify it under the terms of the GNU Lesser General Public
	* License as published by the Free Software Foundation; either
	* version 2.1 of the License, or (at your option) any later version.
	*
	* FFmpeg is distributed in the hope that it will be useful,
	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
	* Lesser General Public License for more details.
	*
	* You should have received a copy of the GNU Lesser General Public
	* License along with FFmpeg; if not, write to the Free Software
	* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
	*/
	#include "avformat.h"
	#include "libavutil/parseutils.h"
	#include "libavutil/opt.h"
	#include "internal.h"
	#include "network.h"
	#include "os_support.h"
	#include "url.h"
	#if HAVE_POLL_H
	#include <poll.h>
	#endif

	typedef struct TCPContext {
	const AVClass *class;
	int fd;
	int listen;
	int rw_timeout;
	int listen_timeout;
	} TCPContext;

	#define OFFSET(x) offsetof(TCPContext, x)
	#define D AV_OPT_FLAG_DECODING_PARAM
	#define E AV_OPT_FLAG_ENCODING_PARAM
	static const AVOption options[] = {
	{"listen", "listen on port instead of connecting", OFFSET(listen), AV_OPT_TYPE_INT, {.i64 = 0}, 0, 1, D\|E },
	{"timeout", "timeout of socket i/o operations", OFFSET(rw_timeout), AV_OPT_TYPE_INT, {.i64 = 0}, 0, INT_MAX, D\|E },
	{"listen_timeout", "connection awaiting timeout", OFFSET(listen_timeout), AV_OPT_TYPE_INT, {.i64 = -1}, -1, INT_MAX, D\|E },
	{NULL}
	};

	static const AVClass tcp_context_class = {
	.class_name = "tcp",
	.item_name = av_default_item_name,
	.option = options,
	.version = LIBAVUTIL_VERSION_INT,
	};

	/* return non zero if error */
	static int tcp_open(URLContext h, const char uri, int flags)
	{
	struct addrinfo hints = { 0 }, ai, cur_ai;
	int port, fd = -1;
	TCPContext *s = h->priv_data;
	const char *p;
	char buf[256];
	int ret;
	socklen_t optlen;
	char hostname[1024],proto[1024],path[1024];
	char portstr[10];
	h->rw_timeout = 5000000;

	av_url_split(proto, sizeof(proto), NULL, 0, hostname, sizeof(hostname),
	&port, path, sizeof(path), uri);
	if (strcmp(proto, "tcp"))
	return AVERROR(EINVAL);
	if (port <= 0 \|\| port >= 65536) {
	av_log(h, AV_LOG_ERROR, "Port missing in uri\n");
	return AVERROR(EINVAL);
	}
	p = strchr(uri, '?');
	if (p) {
	if (av_find_info_tag(buf, sizeof(buf), "listen", p))
	s->listen = 1;
	if (av_find_info_tag(buf, sizeof(buf), "timeout", p)) {
	s->rw_timeout = strtol(buf, NULL, 10);
	}
	if (av_find_info_tag(buf, sizeof(buf), "listen_timeout", p)) {
	s->listen_timeout = strtol(buf, NULL, 10);
	}
	}
	h->rw_timeout = s->rw_timeout;
	hints.ai_family = AF_UNSPEC;
	hints.ai_socktype = SOCK_STREAM;
	snprintf(portstr, sizeof(portstr), "%d", port);
	if (s->listen)
	hints.ai_flags \|= AI_PASSIVE;
	if (!hostname[0])
	ret = getaddrinfo(NULL, portstr, &hints, &ai);
	else
	ret = getaddrinfo(hostname, portstr, &hints, &ai);
	if (ret) {
	av_log(h, AV_LOG_ERROR,
	"Failed to resolve hostname %s: %s\n",
	hostname, gai_strerror(ret));
	return AVERROR(EIO);
	}

	cur_ai = ai;

	restart:
	ret = AVERROR(EIO);
	fd = socket(cur_ai->ai_family, cur_ai->ai_socktype, cur_ai->ai_protocol);
	if (fd < 0)
	goto fail;

	if (s->listen) {
	int fd1;
	int reuse = 1;
	struct pollfd lp = { fd, POLLIN, 0 };
	setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse));
	ret = bind(fd, cur_ai->ai_addr, cur_ai->ai_addrlen);
	if (ret) {
	ret = ff_neterrno();
	goto fail1;
	}
	ret = listen(fd, 1);
	if (ret) {
	ret = ff_neterrno();
	goto fail1;
	}
	ret = poll(&lp, 1, s->listen_timeout >= 0 ? s->listen_timeout : -1);
	if (ret <= 0) {
	ret = AVERROR(ETIMEDOUT);
	goto fail1;
	}
	fd1 = accept(fd, NULL, NULL);
	if (fd1 < 0) {
	ret = ff_neterrno();
	goto fail1;
	}
	closesocket(fd);
	fd = fd1;
	ff_socket_nonblock(fd, 1);
	} else {
	redo:
	ff_socket_nonblock(fd, 1);
	ret = connect(fd, cur_ai->ai_addr, cur_ai->ai_addrlen);
	}

	if (ret < 0) {
	struct pollfd p = {fd, POLLOUT, 0};
	int64_t wait_started;
	ret = ff_neterrno();
	if (ret == AVERROR(EINTR)) {
	if (ff_check_interrupt(&h->interrupt_callback)) {
	ret = AVERROR_EXIT;
	goto fail1;
	}
	goto redo;
	}
	if (ret != AVERROR(EINPROGRESS) &&
	ret != AVERROR(EAGAIN))
	goto fail;

	/* wait until we are connected or until abort */
	wait_started = av_gettime();
	do {
	if (ff_check_interrupt(&h->interrupt_callback)) {
	ret = AVERROR_EXIT;
	goto fail1;
	}
	ret = poll(&p, 1, 100);
	if (ret > 0)
	break;
	} while (!h->rw_timeout \|\| (av_gettime() - wait_started < h->rw_timeout));
	if (ret <= 0) {
	ret = AVERROR(ETIMEDOUT);
	goto fail;
	}
	/* test error */
	optlen = sizeof(ret);
	if (getsockopt (fd, SOL_SOCKET, SO_ERROR, &ret, &optlen))
	ret = AVUNERROR(ff_neterrno());
	if (ret != 0) {
	char errbuf[100];
	ret = AVERROR(ret);
	av_strerror(ret, errbuf, sizeof(errbuf));
	av_log(h, AV_LOG_ERROR,
	"TCP connection to %s:%d failed: %s\n",
	hostname, port, errbuf);
	goto fail;
	}
	}
	h->is_streamed = 1;
	s->fd = fd;
	freeaddrinfo(ai);
	return 0;

	fail:
	if (cur_ai->ai_next) {
	/* Retry with the next sockaddr */
	cur_ai = cur_ai->ai_next;
	if (fd >= 0)
	closesocket(fd);
	goto restart;
	}
	fail1:
	if (fd >= 0)
	closesocket(fd);
	freeaddrinfo(ai);
	return ret;
	}

	static int tcp_read(URLContext h, uint8_t buf, int size)
	{
	TCPContext *s = h->priv_data;
	int ret;

	if (!(h->flags & AVIO_FLAG_NONBLOCK)) {
	ret = ff_network_wait_fd_timeout(s->fd, 0, h->rw_timeout, &h->interrupt_callback);
	if (ret)
	return ret;
	}
	ret = recv(s->fd, buf, size, 0);
	return ret < 0 ? ff_neterrno() : ret;
	}

	static int tcp_write(URLContext h, const uint8_t buf, int size)
	{
	TCPContext *s = h->priv_data;
	int ret;

	if (!(h->flags & AVIO_FLAG_NONBLOCK)) {
	ret = ff_network_wait_fd_timeout(s->fd, 1, h->rw_timeout, &h->interrupt_callback);
	if (ret)
	return ret;
	}
	ret = send(s->fd, buf, size, 0);
	return ret < 0 ? ff_neterrno() : ret;
	}

	static int tcp_shutdown(URLContext *h, int flags)
	{
	TCPContext *s = h->priv_data;
	int how;

	if (flags & AVIO_FLAG_WRITE && flags & AVIO_FLAG_READ) {
	how = SHUT_RDWR;
	} else if (flags & AVIO_FLAG_WRITE) {
	how = SHUT_WR;
	} else {
	how = SHUT_RD;
	}

	return shutdown(s->fd, how);
	}

	static int tcp_close(URLContext *h)
	{
	TCPContext *s = h->priv_data;
	closesocket(s->fd);
	return 0;
	}

	static int tcp_get_file_handle(URLContext *h)
	{
	TCPContext *s = h->priv_data;
	return s->fd;
	}

	URLProtocol ff_tcp_protocol = {
	.name = "tcp",
	.url_open = tcp_open,
	.url_read = tcp_read,
	.url_write = tcp_write,
	.url_close = tcp_close,
	.url_get_file_handle = tcp_get_file_handle,
	.url_shutdown = tcp_shutdown,
	.priv_data_size = sizeof(TCPContext),
	.priv_data_class = &tcp_context_class,
	.flags = URL_PROTOCOL_FLAG_NETWORK,
	};