diff options
Diffstat (limited to 'libmpdemux/network.c')
| -rw-r--r-- | libmpdemux/network.c | 657 |
1 files changed, 0 insertions, 657 deletions
diff --git a/libmpdemux/network.c b/libmpdemux/network.c deleted file mode 100644 index d9e18f7e94..0000000000 --- a/libmpdemux/network.c +++ /dev/null @@ -1,657 +0,0 @@ -/* - * Network layer for MPlayer - * by Bertrand BAUDET <bertrand_baudet@yahoo.com> - * (C) 2001, MPlayer team. - */ - -//#define DUMP2FILE - -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include <unistd.h> - -#include <errno.h> -#include <ctype.h> - -#include "config.h" - -#include "mp_msg.h" -#include "help_mp.h" - -#ifndef HAVE_WINSOCK2 -#define closesocket close -#else -#include <winsock2.h> -#include <ws2tcpip.h> -#endif - -#include "stream.h" -#include "demuxer.h" -#include "m_config.h" - -#include "network.h" -#include "http.h" -#include "cookies.h" -#include "url.h" - -#include "version.h" - -extern int stream_cache_size; - -extern int mp_input_check_interrupt(int time); - -/* Variables for the command line option -user, -passwd, -bandwidth, - -user-agent and -nocookies */ - -char *network_username=NULL; -char *network_password=NULL; -int network_bandwidth=0; -int network_cookies_enabled = 0; -char *network_useragent=NULL; - -/* IPv6 options */ -int network_prefer_ipv4 = 0; -int network_ipv4_only_proxy = 0; - - -mime_struct_t mime_type_table[] = { - // MP3 streaming, some MP3 streaming server answer with audio/mpeg - { "audio/mpeg", DEMUXER_TYPE_AUDIO }, - // MPEG streaming - { "video/mpeg", DEMUXER_TYPE_UNKNOWN }, - { "video/x-mpeg", DEMUXER_TYPE_UNKNOWN }, - { "video/x-mpeg2", DEMUXER_TYPE_UNKNOWN }, - // AVI ??? => video/x-msvideo - { "video/x-msvideo", DEMUXER_TYPE_AVI }, - // MOV => video/quicktime - { "video/quicktime", DEMUXER_TYPE_MOV }, - // ASF - { "audio/x-ms-wax", DEMUXER_TYPE_ASF }, - { "audio/x-ms-wma", DEMUXER_TYPE_ASF }, - { "video/x-ms-asf", DEMUXER_TYPE_ASF }, - { "video/x-ms-afs", DEMUXER_TYPE_ASF }, - { "video/x-ms-wvx", DEMUXER_TYPE_ASF }, - { "video/x-ms-wmv", DEMUXER_TYPE_ASF }, - { "video/x-ms-wma", DEMUXER_TYPE_ASF }, - { "application/x-mms-framed", DEMUXER_TYPE_ASF }, - { "application/vnd.ms.wms-hdr.asfv1", DEMUXER_TYPE_ASF }, - { "application/octet-stream", DEMUXER_TYPE_ASF }, - // Playlists - { "video/x-ms-wmx", DEMUXER_TYPE_PLAYLIST }, - { "audio/x-scpls", DEMUXER_TYPE_PLAYLIST }, - { "audio/x-mpegurl", DEMUXER_TYPE_PLAYLIST }, - { "audio/x-pls", DEMUXER_TYPE_PLAYLIST }, - // Real Media -// { "audio/x-pn-realaudio", DEMUXER_TYPE_REAL }, - // OGG Streaming - { "application/x-ogg", DEMUXER_TYPE_OGG }, - // NullSoft Streaming Video - { "video/nsv", DEMUXER_TYPE_NSV}, - { "misc/ultravox", DEMUXER_TYPE_NSV}, - { NULL, DEMUXER_TYPE_UNKNOWN}, -}; - - -streaming_ctrl_t * -streaming_ctrl_new(void) { - streaming_ctrl_t *streaming_ctrl; - streaming_ctrl = malloc(sizeof(streaming_ctrl_t)); - if( streaming_ctrl==NULL ) { - mp_msg(MSGT_NETWORK,MSGL_FATAL,MSGTR_MemAllocFailed); - return NULL; - } - memset( streaming_ctrl, 0, sizeof(streaming_ctrl_t) ); - return streaming_ctrl; -} - -void -streaming_ctrl_free( streaming_ctrl_t *streaming_ctrl ) { - if( streaming_ctrl==NULL ) return; - if( streaming_ctrl->url ) url_free( streaming_ctrl->url ); - if( streaming_ctrl->buffer ) free( streaming_ctrl->buffer ); - if( streaming_ctrl->data ) free( streaming_ctrl->data ); - free( streaming_ctrl ); -} - - -// Converts an address family constant to a string - -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 - -int -connect2Server_with_af(char *host, int port, int af,int verb) { - int socket_server_fd; - int err, 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]; - -#ifdef HAVE_WINSOCK2 - u_long val; -#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 -2; - } - - switch (af) { - case AF_INET: our_s_addr = (void *) &server_address.four.sin_addr; break; -#ifdef HAVE_AF_INET6 - case AF_INET6: our_s_addr = (void *) &server_address.six.sin6_addr; break; -#endif - default: - mp_msg(MSGT_NETWORK,MSGL_ERR, MSGTR_MPDEMUX_NW_UnknownAF, af); - return -2; - } - - - memset(&server_address, 0, sizeof(server_address)); - -#ifndef HAVE_WINSOCK2 -#ifdef USE_ATON - if (inet_aton(host, our_s_addr)!=1) -#else - if (inet_pton(af, host, our_s_addr)!=1) -#endif -#else - if ( inet_addr(host)==INADDR_NONE ) -#endif - { - if(verb) mp_msg(MSGT_NETWORK,MSGL_STATUS,MSGTR_MPDEMUX_NW_ResolvingHostForAF, host, af2String(af)); - -#ifdef HAVE_GETHOSTBYNAME2 - hp=(struct hostent*)gethostbyname2( host, af ); -#else - hp=(struct hostent*)gethostbyname( host ); -#endif - if( hp==NULL ) { - if(verb) mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_CantResolv, af2String(af), host); - return -2; - } - - memcpy( our_s_addr, (void*)hp->h_addr_list[0], hp->h_length ); - } -#ifdef HAVE_WINSOCK2 - else { - unsigned long addr = inet_addr(host); - memcpy( our_s_addr, (void*)&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_msg(MSGT_NETWORK,MSGL_ERR, MSGTR_MPDEMUX_NW_UnknownAF, af); - return -2; - } - -#if defined(USE_ATON) || defined(HAVE_WINSOCK2) - strncpy( buf, inet_ntoa( *((struct in_addr*)our_s_addr) ), 255); -#else - inet_ntop(af, our_s_addr, buf, 255); -#endif - if(verb) mp_msg(MSGT_NETWORK,MSGL_STATUS,MSGTR_MPDEMUX_NW_ConnectingToServer, host, buf , port ); - - // Turn the socket as non blocking so we can timeout on the connection -#ifndef HAVE_WINSOCK2 - 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 ) { -#ifndef HAVE_WINSOCK2 - if( errno!=EINPROGRESS ) { -#else - if( (WSAGetLastError() != WSAEINPROGRESS) && (WSAGetLastError() != WSAEWOULDBLOCK) ) { -#endif - if(verb) mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_CantConnect2Server, af2String(af)); - closesocket(socket_server_fd); - return -1; - } - } - 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 writable fd - while((ret = select(socket_server_fd+1, NULL, &set, NULL, &tv)) == 0) { - if( ret<0 ) mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_SelectFailed); - else if(ret > 0) break; - else if(count > 30 || mp_input_check_interrupt(500)) { - if(count > 30) - mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_ConnTimeout); - else - mp_msg(MSGT_NETWORK,MSGL_V,"Connection interuppted by user\n"); - return -3; - } - count++; - FD_ZERO( &set ); - FD_SET( socket_server_fd, &set ); - tv.tv_sec = 0; - tv.tv_usec = 500000; - } - - // Turn back the socket as blocking -#ifndef HAVE_WINSOCK2 - 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 error - err_len = sizeof(int); - ret = getsockopt(socket_server_fd,SOL_SOCKET,SO_ERROR,&err,&err_len); - if(ret < 0) { - mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_GetSockOptFailed,strerror(errno)); - return -2; - } - if(err > 0) { - mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_ConnectError,strerror(err)); - return -1; - } - - 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 = -2; - - r = connect2Server_with_af(host, port, network_prefer_ipv4 ? AF_INET:AF_INET6,verb); - if (r > -1) return r; - - s = connect2Server_with_af(host, port, network_prefer_ipv4 ? AF_INET6:AF_INET,verb); - if (s == -2) return r; - return s; -#else - return connect2Server_with_af(host, port, AF_INET,verb); -#endif - - -} - -URL_t* -check4proxies( URL_t *url ) { - URL_t *url_out = NULL; - if( url==NULL ) return NULL; - url_out = url_new( url->url ); - if( !strcasecmp(url->protocol, "http_proxy") ) { - mp_msg(MSGT_NETWORK,MSGL_V,"Using HTTP proxy: http://%s:%d\n", url->hostname, url->port ); - return url_out; - } - // Check if the http_proxy environment variable is set. - if( !strcasecmp(url->protocol, "http") ) { - char *proxy; - proxy = getenv("http_proxy"); - if( proxy!=NULL ) { - // We got a proxy, build the URL to use it - int len; - char *new_url; - URL_t *tmp_url; - URL_t *proxy_url = url_new( proxy ); - - if( proxy_url==NULL ) { - mp_msg(MSGT_NETWORK,MSGL_WARN, - MSGTR_MPDEMUX_NW_InvalidProxySettingTryingWithout); - return url_out; - } - -#ifdef HAVE_AF_INET6 - if (network_ipv4_only_proxy && (gethostbyname(url->hostname)==NULL)) { - mp_msg(MSGT_NETWORK,MSGL_WARN, - MSGTR_MPDEMUX_NW_CantResolvTryingWithoutProxy); - url_free(proxy_url); - return url_out; - } -#endif - - mp_msg(MSGT_NETWORK,MSGL_V,"Using HTTP proxy: %s\n", proxy_url->url ); - len = strlen( proxy_url->hostname ) + strlen( url->url ) + 20; // 20 = http_proxy:// + port - new_url = malloc( len+1 ); - if( new_url==NULL ) { - mp_msg(MSGT_NETWORK,MSGL_FATAL,MSGTR_MemAllocFailed); - url_free(proxy_url); - return url_out; - } - sprintf(new_url, "http_proxy://%s:%d/%s", proxy_url->hostname, proxy_url->port, url->url ); - tmp_url = url_new( new_url ); - if( tmp_url==NULL ) { - free( new_url ); - url_free( proxy_url ); - return url_out; - } - url_free( url_out ); - url_out = tmp_url; - free( new_url ); - url_free( proxy_url ); - } - } - return url_out; -} - -int -http_send_request( URL_t *url, off_t pos ) { - HTTP_header_t *http_hdr; - URL_t *server_url; - char str[256]; - int fd; - int ret; - int proxy = 0; // Boolean - - http_hdr = http_new_header(); - - if( !strcasecmp(url->protocol, "http_proxy") ) { - proxy = 1; - server_url = url_new( (url->file)+1 ); - http_set_uri( http_hdr, server_url->url ); - } else { - server_url = url; - http_set_uri( http_hdr, server_url->file ); - } - if (server_url->port && server_url->port != 80) - snprintf(str, 256, "Host: %s:%d", server_url->hostname, server_url->port ); - else - snprintf(str, 256, "Host: %s", server_url->hostname ); - http_set_field( http_hdr, str); - if (network_useragent) - { - snprintf(str, 256, "User-Agent: %s", network_useragent); - http_set_field(http_hdr, str); - } - else - http_set_field( http_hdr, "User-Agent: MPlayer/"VERSION); - - http_set_field(http_hdr, "Icy-MetaData: 1"); - - if(pos>0) { - // Extend http_send_request with possibility to do partial content retrieval - snprintf(str, 256, "Range: bytes=%"PRId64"-", (int64_t)pos); - http_set_field(http_hdr, str); - } - - if (network_cookies_enabled) cookies_set( http_hdr, server_url->hostname, server_url->url ); - - http_set_field( http_hdr, "Connection: close"); - http_add_basic_authentication( http_hdr, url->username, url->password ); - if( http_build_request( http_hdr )==NULL ) { - goto err_out; - } - - if( proxy ) { - if( url->port==0 ) url->port = 8080; // Default port for the proxy server - fd = connect2Server( url->hostname, url->port,1 ); - url_free( server_url ); - server_url = NULL; - } else { - if( server_url->port==0 ) server_url->port = 80; // Default port for the web server - fd = connect2Server( server_url->hostname, server_url->port,1 ); - } - if( fd<0 ) { - goto err_out; - } - mp_msg(MSGT_NETWORK,MSGL_DBG2,"Request: [%s]\n", http_hdr->buffer ); - - ret = send( fd, http_hdr->buffer, http_hdr->buffer_size, 0 ); - if( ret!=(int)http_hdr->buffer_size ) { - mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_ErrSendingHTTPRequest); - goto err_out; - } - - http_free( http_hdr ); - - return fd; -err_out: - http_free(http_hdr); - if (proxy && server_url) - url_free(server_url); - return -1; -} - -HTTP_header_t * -http_read_response( int fd ) { - HTTP_header_t *http_hdr; - char response[BUFFER_SIZE]; - int i; - - http_hdr = http_new_header(); - if( http_hdr==NULL ) { - return NULL; - } - - do { - i = recv( fd, response, BUFFER_SIZE, 0 ); - if( i<0 ) { - mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_ReadFailed); - http_free( http_hdr ); - return NULL; - } - if( i==0 ) { - mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_Read0CouldBeEOF); - http_free( http_hdr ); - return NULL; - } - http_response_append( http_hdr, response, i ); - } while( !http_is_header_entire( http_hdr ) ); - http_response_parse( http_hdr ); - return http_hdr; -} - -int -http_authenticate(HTTP_header_t *http_hdr, URL_t *url, int *auth_retry) { - char *aut; - - if( *auth_retry==1 ) { - mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_AuthFailed); - return -1; - } - if( *auth_retry>0 ) { - if( url->username ) { - free( url->username ); - url->username = NULL; - } - if( url->password ) { - free( url->password ); - url->password = NULL; - } - } - - aut = http_get_field(http_hdr, "WWW-Authenticate"); - if( aut!=NULL ) { - char *aut_space; - aut_space = strstr(aut, "realm="); - if( aut_space!=NULL ) aut_space += 6; - mp_msg(MSGT_NETWORK,MSGL_INFO,MSGTR_MPDEMUX_NW_AuthRequiredFor, aut_space); - } else { - mp_msg(MSGT_NETWORK,MSGL_INFO,MSGTR_MPDEMUX_NW_AuthRequired); - } - if( network_username ) { - url->username = strdup(network_username); - if( url->username==NULL ) { - mp_msg(MSGT_NETWORK,MSGL_FATAL,MSGTR_MemAllocFailed); - return -1; - } - } else { - mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_AuthFailed); - return -1; - } - if( network_password ) { - url->password = strdup(network_password); - if( url->password==NULL ) { - mp_msg(MSGT_NETWORK,MSGL_FATAL,MSGTR_MemAllocFailed); - return -1; - } - } else { - mp_msg(MSGT_NETWORK,MSGL_INFO,MSGTR_MPDEMUX_NW_NoPasswdProvidedTryingBlank); - } - (*auth_retry)++; - return 0; -} - -int -http_seek( stream_t *stream, off_t pos ) { - HTTP_header_t *http_hdr = NULL; - int fd; - if( stream==NULL ) return 0; - - if( stream->fd>0 ) closesocket(stream->fd); // need to reconnect to seek in http-stream - fd = http_send_request( stream->streaming_ctrl->url, pos ); - if( fd<0 ) return 0; - - http_hdr = http_read_response( fd ); - - if( http_hdr==NULL ) return 0; - - switch( http_hdr->status_code ) { - case 200: - case 206: // OK - mp_msg(MSGT_NETWORK,MSGL_V,"Content-Type: [%s]\n", http_get_field(http_hdr, "Content-Type") ); - mp_msg(MSGT_NETWORK,MSGL_V,"Content-Length: [%s]\n", http_get_field(http_hdr, "Content-Length") ); - if( http_hdr->body_size>0 ) { - if( streaming_bufferize( stream->streaming_ctrl, http_hdr->body, http_hdr->body_size )<0 ) { - http_free( http_hdr ); - return -1; - } - } - break; - default: - mp_msg(MSGT_NETWORK,MSGL_ERR,MSGTR_MPDEMUX_NW_ErrServerReturned, http_hdr->status_code, http_hdr->reason_phrase ); - close( fd ); - fd = -1; - } - stream->fd = fd; - - if( http_hdr ) { - http_free( http_hdr ); - stream->streaming_ctrl->data = NULL; - } - - stream->pos=pos; - - return 1; -} - - -int -streaming_bufferize( streaming_ctrl_t *streaming_ctrl, char *buffer, int size) { -//printf("streaming_bufferize\n"); - streaming_ctrl->buffer = malloc(size); - if( streaming_ctrl->buffer==NULL ) { - mp_msg(MSGT_NETWORK,MSGL_FATAL,MSGTR_MemAllocFailed); - return -1; - } - memcpy( streaming_ctrl->buffer, buffer, size ); - streaming_ctrl->buffer_size = size; - return size; -} - -int -nop_streaming_read( int fd, char *buffer, int size, streaming_ctrl_t *stream_ctrl ) { - int len=0; -//printf("nop_streaming_read\n"); - if( stream_ctrl->buffer_size!=0 ) { - int buffer_len = stream_ctrl->buffer_size-stream_ctrl->buffer_pos; -//printf("%d bytes in buffer\n", stream_ctrl->buffer_size); - len = (size<buffer_len)?size:buffer_len; - memcpy( buffer, (stream_ctrl->buffer)+(stream_ctrl->buffer_pos), len ); - stream_ctrl->buffer_pos += len; -//printf("buffer_pos = %d\n", stream_ctrl->buffer_pos ); - if( stream_ctrl->buffer_pos>=stream_ctrl->buffer_size ) { - free( stream_ctrl->buffer ); - stream_ctrl->buffer = NULL; - stream_ctrl->buffer_size = 0; - stream_ctrl->buffer_pos = 0; -//printf("buffer cleaned\n"); - } -//printf("read %d bytes from buffer\n", len ); - } - - if( len<size ) { - int ret; - ret = recv( fd, buffer+len, size-len, 0 ); - if( ret<0 ) { - mp_msg(MSGT_NETWORK,MSGL_ERR,"nop_streaming_read error : %s\n",strerror(errno)); - } - len += ret; -//printf("read %d bytes from network\n", len ); - } - - return len; -} - -int -nop_streaming_seek( int fd, off_t pos, streaming_ctrl_t *stream_ctrl ) { - return -1; - // To shut up gcc warning - fd++; - pos++; - stream_ctrl=NULL; -} - - -void fixup_network_stream_cache(stream_t *stream) { - if(stream->streaming_ctrl->buffering) { - if(stream_cache_size<0) { - // cache option not set, will use our computed value. - // buffer in KBytes, *5 because the prefill is 20% of the buffer. - stream_cache_size = (stream->streaming_ctrl->prebuffer_size/1024)*5; - if( stream_cache_size<64 ) stream_cache_size = 64; // 16KBytes min buffer - } - mp_msg(MSGT_NETWORK,MSGL_INFO,MSGTR_MPDEMUX_NW_CacheSizeSetTo, stream_cache_size); - } -} - - -int -streaming_stop( stream_t *stream ) { - stream->streaming_ctrl->status = streaming_stopped_e; - return 0; -} |