diff options
| author | Tim Redfern <tim@eclectronics.org> | 2014-02-17 13:36:38 +0000 |
|---|---|---|
| committer | Tim Redfern <tim@eclectronics.org> | 2014-02-17 13:36:38 +0000 |
| commit | 22e28216336da876e1fd17f380ce42eaf1446769 (patch) | |
| tree | 444dad3dc7e2656992d29f34f7bce31970c122a5 /ffmpeg/libavformat/tcp.c | |
| parent | ae5e8541f6e06e64c28719467cdf366ac57aff31 (diff) | |
chasing indexing error
Diffstat (limited to 'ffmpeg/libavformat/tcp.c')
| -rw-r--r-- | ffmpeg/libavformat/tcp.c | 233 |
1 files changed, 0 insertions, 233 deletions
diff --git a/ffmpeg/libavformat/tcp.c b/ffmpeg/libavformat/tcp.c deleted file mode 100644 index e457fba..0000000 --- a/ffmpeg/libavformat/tcp.c +++ /dev/null @@ -1,233 +0,0 @@ -/* - * 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 "libavutil/time.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 open_timeout; - 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", "set timeout of socket I/O operations", OFFSET(rw_timeout), AV_OPT_TYPE_INT, {.i64 = -1}, -1, INT_MAX, D|E }, -{"listen_timeout", "set 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; - char hostname[1024],proto[1024],path[1024]; - char portstr[10]; - s->open_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)) { - char *endptr = NULL; - s->listen = strtol(buf, &endptr, 10); - /* assume if no digits were found it is a request to enable it */ - if (buf == endptr) - 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); - } - } - if (s->rw_timeout >= 0) { - s->open_timeout = - 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: - fd = ff_socket(cur_ai->ai_family, - cur_ai->ai_socktype, - cur_ai->ai_protocol); - if (fd < 0) { - ret = ff_neterrno(); - goto fail; - } - - if (s->listen) { - if ((fd = ff_listen_bind(fd, cur_ai->ai_addr, cur_ai->ai_addrlen, - s->listen_timeout, h)) < 0) { - ret = fd; - goto fail1; - } - } else { - if ((ret = ff_listen_connect(fd, cur_ai->ai_addr, cur_ai->ai_addrlen, - s->open_timeout / 1000, h, !!cur_ai->ai_next)) < 0) { - - if (ret == AVERROR_EXIT) - goto fail1; - else - 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); - ret = 0; - 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, -}; |
