diff options
author | Fabrice Bellard <fabrice@bellard.org> | 2002-07-04 10:35:45 +0000 |
---|---|---|
committer | Fabrice Bellard <fabrice@bellard.org> | 2002-07-04 10:35:45 +0000 |
commit | 171bbb03adf53fd6209a91284342bb82ee7ad3f3 (patch) | |
tree | edfac42f0fe5617d6d4132611ab4572d98f585f0 /libav | |
parent | c13e1abdec3315945a0b24df67de8affca77ae8a (diff) | |
download | ffmpeg-171bbb03adf53fd6209a91284342bb82ee7ad3f3.tar.gz |
added raw tcp support
Originally committed as revision 717 to svn://svn.ffmpeg.org/ffmpeg/trunk
Diffstat (limited to 'libav')
-rw-r--r-- | libav/tcp.c | 152 |
1 files changed, 152 insertions, 0 deletions
diff --git a/libav/tcp.c b/libav/tcp.c new file mode 100644 index 0000000000..644e139393 --- /dev/null +++ b/libav/tcp.c @@ -0,0 +1,152 @@ +/* + * TCP protocol + * Copyright (c) 2002 Fabrice Bellard. + * + * This library 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 of the License, or (at your option) any later version. + * + * This library 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 this library; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ +#include "avformat.h" +#include <unistd.h> +#include <ctype.h> +#include <sys/types.h> +#include <sys/socket.h> +#include <netinet/in.h> +#include <arpa/inet.h> +#include <netdb.h> + +typedef struct TCPContext { + int fd; +} TCPContext; + +/* resolve host with also IP address parsing */ +int resolve_host(struct in_addr *sin_addr, const char *hostname) +{ + struct hostent *hp; + + if ((inet_aton(hostname, sin_addr)) == 0) { + hp = gethostbyname(hostname); + if (!hp) + return -1; + memcpy (sin_addr, hp->h_addr, sizeof(struct in_addr)); + } + return 0; +} + +/* return non zero if error */ +static int tcp_open(URLContext *h, const char *uri, int flags) +{ + struct sockaddr_in dest_addr; + char hostname[1024], *q; + int port, fd = -1; + TCPContext *s; + const char *p; + + s = av_malloc(sizeof(TCPContext)); + if (!s) + return -ENOMEM; + h->priv_data = s; + p = uri; + if (!strstart(p, "tcp://", &p)) + goto fail; + q = hostname; + while (*p != ':' && *p != '/' && *p != '\0') { + if ((q - hostname) < sizeof(hostname) - 1) + *q++ = *p; + p++; + } + *q = '\0'; + if (*p != ':') + goto fail; + p++; + port = strtoul(p, (char **)&p, 10); + if (port <= 0 || port >= 65536) + goto fail; + + dest_addr.sin_family = AF_INET; + dest_addr.sin_port = htons(port); + if (resolve_host(&dest_addr.sin_addr, hostname) < 0) + goto fail; + + fd = socket(PF_INET, SOCK_STREAM, 0); + if (fd < 0) + goto fail; + + if (connect(fd, (struct sockaddr *)&dest_addr, + sizeof(dest_addr)) < 0) + goto fail; + + s->fd = fd; + return 0; + + fail: + if (fd >= 0) + close(fd); + av_free(s); + return -EIO; +} + +static int tcp_read(URLContext *h, UINT8 *buf, int size) +{ + TCPContext *s = h->priv_data; + int size1, len; + + size1 = size; + while (size > 0) { + len = read (s->fd, buf, size); + if (len < 0) { + if (errno != EINTR && errno != EAGAIN) + return -errno; + else + continue; + } else if (len == 0) { + break; + } + size -= len; + buf += len; + } + return size1 - size; +} + +static int tcp_write(URLContext *h, UINT8 *buf, int size) +{ + TCPContext *s = h->priv_data; + int ret, size1; + + size1 = size; + while (size > 0) { + ret = write (s->fd, buf, size); + if (ret < 0 && errno != EINTR && errno != EAGAIN) + return -errno; + size -= ret; + buf += ret; + } + return size1 - size; +} + +static int tcp_close(URLContext *h) +{ + TCPContext *s = h->priv_data; + close(s->fd); + av_free(s); + return 0; +} + +URLProtocol tcp_protocol = { + "tcp", + tcp_open, + tcp_read, + tcp_write, + NULL, /* seek */ + tcp_close, +}; |