summaryrefslogtreecommitdiffstats
path: root/stream/tcp.c
diff options
context:
space:
mode:
Diffstat (limited to 'stream/tcp.c')
-rw-r--r--stream/tcp.c279
1 files changed, 0 insertions, 279 deletions
diff --git a/stream/tcp.c b/stream/tcp.c
deleted file mode 100644
index be27c490dc..0000000000
--- a/stream/tcp.c
+++ /dev/null
@@ -1,279 +0,0 @@
-/*
- * Network layer for MPlayer
- *
- * Copyright (C) 2001 Bertrand BAUDET <bertrand_baudet@yahoo.com>
- *
- * This file is part of MPlayer.
- *
- * MPlayer is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * MPlayer 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 General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License along
- * with MPlayer; if not, write to the Free Software Foundation, Inc.,
- * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
- */
-
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-
-#include <errno.h>
-#include <ctype.h>
-
-#include <fcntl.h>
-#include <sys/time.h>
-#include <sys/types.h>
-
-#include "config.h"
-
-#include "core/mp_msg.h"
-
-#if !HAVE_WINSOCK2_H
-#include <netdb.h>
-#include <netinet/in.h>
-#include <sys/socket.h>
-#include <arpa/inet.h>
-#else
-#include <winsock2.h>
-#include <ws2tcpip.h>
-#endif
-
-#include "network.h"
-#include "stream.h"
-#include "tcp.h"
-#include "libavutil/avstring.h"
-
-/* IPv6 options */
-int network_prefer_ipv4 = 0;
-
-// Converts an address family constant to a string
-
-static const char *af2String(int af) {
- switch (af) {
- case AF_INET: return "AF_INET";
-
-#ifdef HAVE_AF_INET6
- case AF_INET6: return "AF_INET6";
-#endif
- default: return "Unknown address family!";
- }
-}
-
-
-
-// Connect to a server using a TCP connection, with specified address family
-// return -2 for fatal error, like unable to resolve name, connection timeout...
-// return -1 is unable to connect to a particular port
-
-static int
-connect2Server_with_af(char *host, int port, int af,int verb) {
- int socket_server_fd;
- int err;
- socklen_t err_len;
- int ret,count = 0;
- fd_set set;
- struct timeval tv;
- union {
- struct sockaddr_in four;
-#ifdef HAVE_AF_INET6
- struct sockaddr_in6 six;
-#endif
- } server_address;
- size_t server_address_size;
- void *our_s_addr; // Pointer to sin_addr or sin6_addr
- struct hostent *hp=NULL;
- char buf[255];
-
-#if HAVE_WINSOCK2_H
- unsigned long val;
- int to;
-#else
- struct timeval to;
-#endif
-
-#if HAVE_WINSOCK2_H && defined(HAVE_AF_INET6)
- // our winsock name resolution code can not handle IPv6
- if (af == AF_INET6) {
- mp_msg(MSGT_NETWORK, MSGL_WARN, "IPv6 not supported for winsock2\n");
- return TCP_ERROR_FATAL;
- }
-#endif
-
- socket_server_fd = socket(af, SOCK_STREAM, 0);
-
-
- if( socket_server_fd==-1 ) {
-// mp_msg(MSGT_NETWORK,MSGL_ERR,"Failed to create %s socket:\n", af2String(af));
- return TCP_ERROR_FATAL;
- }
-
-#if defined(SO_RCVTIMEO) && defined(SO_SNDTIMEO)
-#if HAVE_WINSOCK2_H
- /* timeout in milliseconds */
- to = 10 * 1000;
-#else
- to.tv_sec = 10;
- to.tv_usec = 0;
-#endif
- setsockopt(socket_server_fd, SOL_SOCKET, SO_RCVTIMEO, &to, sizeof(to));
- setsockopt(socket_server_fd, SOL_SOCKET, SO_SNDTIMEO, &to, sizeof(to));
-#endif
-
- switch (af) {
- case AF_INET: our_s_addr = &server_address.four.sin_addr; break;
-#ifdef HAVE_AF_INET6
- case AF_INET6: our_s_addr = &server_address.six.sin6_addr; break;
-#endif
- default:
- mp_tmsg(MSGT_NETWORK,MSGL_ERR, "Unknown address family %d\n", af);
- return TCP_ERROR_FATAL;
- }
-
-
- memset(&server_address, 0, sizeof(server_address));
-
-#if HAVE_INET_PTON
- if (inet_pton(af, host, our_s_addr)!=1)
-#elif HAVE_INET_ATON
- if (inet_aton(host, our_s_addr)!=1)
-#elif HAVE_WINSOCK2_H
- if ( inet_addr(host)==INADDR_NONE )
-#endif
- {
- if(verb) mp_tmsg(MSGT_NETWORK,MSGL_STATUS,"Resolving %s for %s...\n", host, af2String(af));
-
-#ifdef HAVE_GETHOSTBYNAME2
- hp=gethostbyname2( host, af );
-#else
- hp=gethostbyname( host );
-#endif
- if( hp==NULL ) {
- if(verb) mp_tmsg(MSGT_NETWORK,MSGL_ERR,"Couldn't resolve name for %s: %s\n", af2String(af), host);
- return TCP_ERROR_FATAL;
- }
-
- memcpy( our_s_addr, hp->h_addr_list[0], hp->h_length );
- }
-#if HAVE_WINSOCK2_H
- else {
- unsigned long addr = inet_addr(host);
- memcpy( our_s_addr, &addr, sizeof(addr) );
- }
-#endif
-
- switch (af) {
- case AF_INET:
- server_address.four.sin_family=af;
- server_address.four.sin_port=htons(port);
- server_address_size = sizeof(server_address.four);
- break;
-#ifdef HAVE_AF_INET6
- case AF_INET6:
- server_address.six.sin6_family=af;
- server_address.six.sin6_port=htons(port);
- server_address_size = sizeof(server_address.six);
- break;
-#endif
- default:
- mp_tmsg(MSGT_NETWORK,MSGL_ERR, "Unknown address family %d\n", af);
- return TCP_ERROR_FATAL;
- }
-
-#if HAVE_INET_PTON
- inet_ntop(af, our_s_addr, buf, 255);
-#elif HAVE_INET_ATON || defined(HAVE_WINSOCK2_H)
- av_strlcpy( buf, inet_ntoa( *((struct in_addr*)our_s_addr) ), 255);
-#endif
- if(verb) mp_tmsg(MSGT_NETWORK,MSGL_STATUS,"Connecting to server %s[%s]: %d...\n", host, buf , port );
-
- // Turn the socket as non blocking so we can timeout on the connection
-#if !HAVE_WINSOCK2_H
- fcntl( socket_server_fd, F_SETFL, fcntl(socket_server_fd, F_GETFL) | O_NONBLOCK );
-#else
- val = 1;
- ioctlsocket( socket_server_fd, FIONBIO, &val );
-#endif
- if( connect( socket_server_fd, (struct sockaddr*)&server_address, server_address_size )==-1 ) {
-#if !HAVE_WINSOCK2_H
- if( errno!=EINPROGRESS ) {
-#else
- if( (WSAGetLastError() != WSAEINPROGRESS) && (WSAGetLastError() != WSAEWOULDBLOCK) ) {
-#endif
- if(verb) mp_tmsg(MSGT_NETWORK,MSGL_ERR,"Failed to connect to server with %s\n", af2String(af));
- closesocket(socket_server_fd);
- return TCP_ERROR_PORT;
- }
- }
- tv.tv_sec = 0;
- tv.tv_usec = 500000;
- FD_ZERO( &set );
- FD_SET( socket_server_fd, &set );
- // When the connection will be made, we will have a writeable fd
- while((ret = select(socket_server_fd+1, NULL, &set, NULL, &tv)) == 0) {
- if(count > 30 || stream_check_interrupt(500)) {
- if(count > 30)
- mp_tmsg(MSGT_NETWORK,MSGL_ERR,"connection timeout\n");
- else
- mp_msg(MSGT_NETWORK,MSGL_V,"Connection interrupted by user\n");
- return TCP_ERROR_TIMEOUT;
- }
- count++;
- FD_ZERO( &set );
- FD_SET( socket_server_fd, &set );
- tv.tv_sec = 0;
- tv.tv_usec = 500000;
- }
- if (ret < 0) mp_tmsg(MSGT_NETWORK,MSGL_ERR,"Select failed.\n");
-
- // Turn back the socket as blocking
-#if !HAVE_WINSOCK2_H
- fcntl( socket_server_fd, F_SETFL, fcntl(socket_server_fd, F_GETFL) & ~O_NONBLOCK );
-#else
- val = 0;
- ioctlsocket( socket_server_fd, FIONBIO, &val );
-#endif
- // Check if there were any errors
- err_len = sizeof(int);
- ret = getsockopt(socket_server_fd,SOL_SOCKET,SO_ERROR,&err,&err_len);
- if(ret < 0) {
- mp_tmsg(MSGT_NETWORK,MSGL_ERR,"getsockopt failed: %s\n",strerror(errno));
- return TCP_ERROR_FATAL;
- }
- if(err > 0) {
- mp_tmsg(MSGT_NETWORK,MSGL_ERR,"connect error: %s\n",strerror(err));
- return TCP_ERROR_PORT;
- }
-
- return socket_server_fd;
-}
-
-// Connect to a server using a TCP connection
-// return -2 for fatal error, like unable to resolve name, connection timeout...
-// return -1 is unable to connect to a particular port
-
-
-int
-connect2Server(char *host, int port, int verb) {
-#ifdef HAVE_AF_INET6
- int r;
- int s = TCP_ERROR_FATAL;
-
- r = connect2Server_with_af(host, port, network_prefer_ipv4 ? AF_INET:AF_INET6,verb);
- if (r >= 0) return r;
-
- s = connect2Server_with_af(host, port, network_prefer_ipv4 ? AF_INET6:AF_INET,verb);
- if (s == TCP_ERROR_FATAL) return r;
- return s;
-#else
- return connect2Server_with_af(host, port, AF_INET,verb);
-#endif
-
-
-}