summaryrefslogtreecommitdiff
path: root/ffmpeg/libavformat/tcp.c
diff options
context:
space:
mode:
authorTim Redfern <tim@eclectronics.org>2014-02-17 13:36:38 +0000
committerTim Redfern <tim@eclectronics.org>2014-02-17 13:36:38 +0000
commit22e28216336da876e1fd17f380ce42eaf1446769 (patch)
tree444dad3dc7e2656992d29f34f7bce31970c122a5 /ffmpeg/libavformat/tcp.c
parentae5e8541f6e06e64c28719467cdf366ac57aff31 (diff)
chasing indexing error
Diffstat (limited to 'ffmpeg/libavformat/tcp.c')
-rw-r--r--ffmpeg/libavformat/tcp.c233
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,
-};