comparison libmpdemux/network.c @ 4121:a71d4ffc6c97

Added proxy support.

4120:a66048f5ae2e

#include "network.h"
#include "http.h"
#include "url.h"
#include "asf.h"
#include "rtp.h"

static struct {
	char *mime_type;
	int demuxer_type;
} mime_type_table[] = {

}

int
http_send_request( URL_t *url ) {
	HTTP_header_t *http_hdr;
	char str[80];
	int fd;
	http_hdr = http_new_header();
	http_set_uri( http_hdr, url->file );
	snprintf(str, 80, "Host: %s", url->hostname );
	http_set_field( http_hdr, str);
	http_set_field( http_hdr, "User-Agent: MPlayer");
	http_set_field( http_hdr, "Connection: closed");
	if( http_build_request( http_hdr )==NULL ) {
		return -1;
	}

	if( url->port==0 ) url->port = 80;
	fd = connect2Server( url->hostname, url->port );
	if( fd<0 ) {
		return -1; 
	}
	write( fd, http_hdr->buffer, http_hdr->buffer_size );
	http_free( http_hdr );

	return fd;
}

			*file_format = DEMUXER_TYPE_ASF;
			return 0;
		}

		// HTTP based protocol
		if( !strcasecmp(url->protocol, "http") ) {
			if( url->port==0 ) url->port = 80;

			fd = http_send_request( url );
			if( fd<0 ) {
				return -1;
			}

				http_free( http_hdr );
				return -1;
			}

			*fd_out=fd;
			http_debug_hdr( http_hdr );

			streaming_ctrl->data = (void*)http_hdr;
			
			// Check if the response is an ICY status_code reason_phrase
			if( !strcasecmp(http_hdr->protocol, "ICY") ) {
				// Ok, we have detected an mp3 streaming

streaming_start(stream_t *stream, int demuxer_type) {
	int ret=-1;
	if( stream==NULL ) return -1;
	
	// For RTP streams, we usually don't know the stream type until we open it.
	if( !strcmp( stream->streaming_ctrl->url->protocol, "rtp")) {
		if(stream->fd >= 0) {
			if(close(stream->fd) < 0)
				printf("streaming_start : Closing socket %d failed %s\n",stream->fd,strerror(errno));
		}
		stream->fd = -1;

4121:a71d4ffc6c97

#include "network.h"
#include "http.h"
#include "url.h"
#include "asf.h"
#include "rtp.h"

extern int verbose;

static struct {
	char *mime_type;
	int demuxer_type;
} mime_type_table[] = {

}

int
http_send_request( URL_t *url ) {
	HTTP_header_t *http_hdr;
	URL_t *server_url;
	char str[80];
	int fd;
	int ret;
	int proxy = 0;		// Boolean

	http_hdr = http_new_header();

	if( !strcasecmp(url->protocol, "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 );
	}
	snprintf(str, 80, "Host: %s", server_url->hostname );
	http_set_field( http_hdr, str);
	http_set_field( http_hdr, "User-Agent: MPlayer");
	http_set_field( http_hdr, "Connection: closed");
	if( http_build_request( http_hdr )==NULL ) {
		return -1;
	}

	if( proxy ) {
		if( url->port==0 ) url->port = 8080;			// Default port for the proxy server
		fd = connect2Server( url->hostname, url->port );
		url_free( server_url );
	} else {
		if( server_url->port==0 ) server_url->port = 80;	// Default port for the web server
		fd = connect2Server( server_url->hostname, server_url->port );
	}
	if( fd<0 ) {
		return -1; 
	}
	if( verbose ) {
		printf("Request: [%s]\n", http_hdr->buffer );
	}
	
	ret = write( fd, http_hdr->buffer, http_hdr->buffer_size );
	if( ret!=http_hdr->buffer_size ) {
		printf("Error while sending HTTP request: didn't sent all the request\n");
		return -1;
	}
	
	http_free( http_hdr );

	return fd;
}

			*file_format = DEMUXER_TYPE_ASF;
			return 0;
		}

		// HTTP based protocol
		if( !strcasecmp(url->protocol, "http") || !strcasecmp(url->protocol, "proxy") ) {
			//if( url->port==0 ) url->port = 80;

			fd = http_send_request( url );
			if( fd<0 ) {
				return -1;
			}

				http_free( http_hdr );
				return -1;
			}

			*fd_out=fd;
			if( verbose ) {
				http_debug_hdr( http_hdr );
			}
			
			streaming_ctrl->data = (void*)http_hdr;
			
			// Check if the response is an ICY status_code reason_phrase
			if( !strcasecmp(http_hdr->protocol, "ICY") ) {
				// Ok, we have detected an mp3 streaming

streaming_start(stream_t *stream, int demuxer_type) {
	int ret=-1;
	if( stream==NULL ) return -1;
	
	// For RTP streams, we usually don't know the stream type until we open it.
	if( !strcasecmp( stream->streaming_ctrl->url->protocol, "rtp")) {
		if(stream->fd >= 0) {
			if(close(stream->fd) < 0)
				printf("streaming_start : Closing socket %d failed %s\n",stream->fd,strerror(errno));
		}
		stream->fd = -1;