[Mplayer-cvslog] CVS: main/libmpdemux asf_streaming.c,1.25,1.26 network.c,1.42,1.43 http.c,1.11,1.12
Alban Bedel CVS
albeu at mplayerhq.hu
Tue Apr 30 18:58:56 CEST 2002
Update of /cvsroot/mplayer/main/libmpdemux
In directory mail:/var/tmp.root/cvs-serv557/libmpdemux
Modified Files:
asf_streaming.c network.c http.c
Log Message:
Convert printf to mp_msg in the network layer
Index: asf_streaming.c
===================================================================
RCS file: /cvsroot/mplayer/main/libmpdemux/asf_streaming.c,v
retrieving revision 1.25
retrieving revision 1.26
diff -u -r1.25 -r1.26
--- asf_streaming.c 14 Apr 2002 05:51:32 -0000 1.25
+++ asf_streaming.c 30 Apr 2002 16:58:53 -0000 1.26
@@ -51,28 +51,28 @@
strncpy( proto_s, stream->streaming_ctrl->url->protocol, 10 );
if( !strncasecmp( proto_s, "mms", 3) && strncasecmp( proto_s, "mmst", 4) ) {
- printf("Trying ASF/UDP...\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"Trying ASF/UDP...\n");
//fd = asf_mmsu_streaming_start( stream );
if( fd!=-1 ) return fd;
- printf(" ===> ASF/UDP failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_V," ===> ASF/UDP failed\n");
}
if( !strncasecmp( proto_s, "mms", 3) ) {
- printf("Trying ASF/TCP...\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"Trying ASF/TCP...\n");
//fd = asf_mmst_streaming_start( stream );
if( fd!=-1 ) return fd;
- printf(" ===> ASF/TCP failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_V," ===> ASF/TCP failed\n");
}
if( !strncasecmp( proto_s, "http", 4) ||
!strncasecmp( proto_s, "mms", 3) ||
!strncasecmp( proto_s, "http_proxy", 10)
) {
- printf("Trying ASF/HTTP...\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"Trying ASF/HTTP...\n");
fd = asf_http_streaming_start( stream );
if( fd!=-1 ) return fd;
- printf(" ===> ASF/HTTP failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_V," ===> ASF/HTTP failed\n");
}
- printf("Unknown protocol: %s\n", proto_s );
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Unknown protocol: %s\n", proto_s );
return -1;
}
@@ -86,11 +86,11 @@
if( drop_packet!=NULL ) *drop_packet = 0;
if( stream_chunck->size<8 ) {
- printf("Ahhhh, stream_chunck size is too small: %d\n", stream_chunck->size);
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Ahhhh, stream_chunck size is too small: %d\n", stream_chunck->size);
return -1;
}
if( stream_chunck->size!=stream_chunck->size_confirm ) {
- printf("size_confirm mismatch!: %d %d\n", stream_chunck->size, stream_chunck->size_confirm);
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"size_confirm mismatch!: %d %d\n", stream_chunck->size, stream_chunck->size_confirm);
return -1;
}
/*
@@ -102,7 +102,7 @@
*/
switch(stream_chunck->type) {
case ASF_STREAMING_CLEAR: // $C Clear ASF configuration
- printf("=====> Clearing ASF stream configuration!\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> Clearing ASF stream configuration!\n");
if( drop_packet!=NULL ) *drop_packet = 1;
return stream_chunck->size;
break;
@@ -110,15 +110,15 @@
// printf("=====> Data follows\n");
break;
case ASF_STREAMING_END_TRANS: // $E Transfer complete
- printf("=====> Transfer complete\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> Transfer complete\n");
if( drop_packet!=NULL ) *drop_packet = 1;
return stream_chunck->size;
break;
case ASF_STREAMING_HEADER: // $H ASF header chunk follows
- printf("=====> ASF header chunk follows\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> ASF header chunk follows\n");
break;
default:
- printf("=====> Unknown stream type 0x%x\n", stream_chunck->type );
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> Unknown stream type 0x%x\n", stream_chunck->type );
}
return stream_chunck->size+4;
}
@@ -150,19 +150,19 @@
// Endian handling of the stream chunk
le2me_ASF_stream_chunck_t(&chunk);
size = asf_streaming( &chunk, &r) - sizeof(ASF_stream_chunck_t);
- if(r) printf("Warning : drop header ????\n");
+ if(r) mp_msg(MSGT_NETWORK,MSGL_WARN,"Warning : drop header ????\n");
if(size < 0){
- printf("Error while parsing chunk header\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error while parsing chunk header\n");
return -1;
}
if (chunk.type != ASF_STREAMING_HEADER) {
- printf("Don't got a header as first chunk !!!!\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Don't got a header as first chunk !!!!\n");
return -1;
}
buffer = (char*) malloc(size+buffer_size);
if(buffer == NULL) {
- printf("Error can't allocate %d bytes buffer\n",size+buffer_size);
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Error can't allocate %d bytes buffer\n",size+buffer_size);
return -1;
}
if( chunk_buffer!=NULL ) {
@@ -176,7 +176,7 @@
for(r = 0; r < size;) {
i = nop_streaming_read(fd,buffer+r,size-r,streaming_ctrl);
if(i < 0) {
- printf("Error while reading network stream\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error while reading network stream\n");
return -1;
}
r += i;
@@ -184,20 +184,20 @@
if( chunk_size2read==0 ) {
if(size < (int)sizeof(asfh)) {
- printf("Error chunk is too small\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error chunk is too small\n");
return -1;
- } else printf("Got chunk\n");
+ } else mp_msg(MSGT_NETWORK,MSGL_DBG2,"Got chunk\n");
memcpy(&asfh,buffer,sizeof(asfh));
le2me_ASF_header_t(&asfh);
chunk_size2read = asfh.objh.size;
- printf("Size 2 read=%d\n", chunk_size2read);
+ mp_msg(MSGT_NETWORK,MSGL_DBG2,"Size 2 read=%d\n", chunk_size2read);
}
} while( buffer_size<chunk_size2read);
buffer = chunk_buffer;
size = buffer_size;
if(asfh.cno > 256) {
- printf("Error sub chunks number is invalid\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error sub chunks number is invalid\n");
return -1;
}
@@ -280,7 +280,7 @@
streaming_ctrl );
if(r <= 0){
if( r < 0)
- printf("Error while reading chunk header\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error while reading chunk header\n");
return -1;
}
read += r;
@@ -290,14 +290,14 @@
le2me_ASF_stream_chunck_t(&chunk);
chunk_size = asf_streaming( &chunk, &drop_chunk );
if(chunk_size < 0) {
- printf("Error while parsing chunk header\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error while parsing chunk header\n");
return -1;
}
chunk_size -= sizeof(ASF_stream_chunck_t);
if(chunk.type != ASF_STREAMING_HEADER && (!drop_chunk)) {
if (asf_http_ctrl->packet_size < chunk_size) {
- printf("Error chunk_size > packet_size\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error chunk_size > packet_size\n");
return -1;
}
waiting = asf_http_ctrl->packet_size;
@@ -320,7 +320,7 @@
int got = nop_streaming_read( fd,buffer+read,chunk_size-read,streaming_ctrl );
if(got <= 0) {
if(got < 0)
- printf("Error while reading chunk\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error while reading chunk\n");
return -1;
}
read += got;
@@ -361,13 +361,13 @@
if( content_type==NULL ) return ASF_Unknown_e;
if( !strcasecmp(content_type, "application/octet-stream") ) {
if( features==NULL ) {
- printf("=====> ASF Prerecorded\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> ASF Prerecorded\n");
return ASF_Prerecorded_e;
} else if( strstr(features, "broadcast")) {
- printf("=====> ASF Live stream\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> ASF Live stream\n");
return ASF_Live_e;
} else {
- printf("=====> ASF Prerecorded\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> ASF Prerecorded\n");
return ASF_Prerecorded_e;
}
} else {
@@ -377,10 +377,10 @@
// So we have to check for an asf header :(, but it works :p
if( http_hdr->body_size>sizeof(ASF_obj_header_t) ) {
if( asf_header_check( http_hdr )==0 ) {
- printf("=====> ASF Plain text\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> ASF Plain text\n");
return ASF_PlainText_e;
} else {
- printf("=====> ASF Redirector\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> ASF Redirector\n");
return ASF_Redirector_e;
}
} else {
@@ -391,13 +391,13 @@
(!strcasecmp(content_type, "video/x-ms-wvx")) ||
(!strcasecmp(content_type, "video/x-ms-wmv")) ||
(!strcasecmp(content_type, "video/x-ms-wma")) ) {
- printf("=====> ASF Redirector\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"=====> ASF Redirector\n");
return ASF_Redirector_e;
} else if( !strcasecmp(content_type, "text/plain") ) {
- printf("=====> ASF Plain text\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> ASF Plain text\n");
return ASF_PlainText_e;
} else {
- printf("=====> ASF unknown content-type: %s\n", content_type );
+ mp_msg(MSGT_NETWORK,MSGL_V,"=====> ASF unknown content-type: %s\n", content_type );
return ASF_Unknown_e;
}
}
@@ -433,7 +433,7 @@
if( !strcasecmp( url->protocol, "http_proxy" ) ) {
server_url = url_new( (url->file)+1 );
if( server_url==NULL ) {
- printf("Invalid proxy URL\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Invalid proxy URL\n");
http_free( http_hdr );
return NULL;
}
@@ -469,7 +469,7 @@
}
if(as < 0) {
if(audio_id > 0)
- printf("Audio stream %d don't exist\n", as);
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Audio stream %d don't exist\n", as);
as = asf_http_ctrl->audio_streams[0];
}
ptr += sprintf(ptr, " ffff:%d:0",as);
@@ -486,7 +486,7 @@
}
if(vs < 0) {
if(video_id > 0)
- printf("Video stream %d don't exist\n",vs);
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Video stream %d don't exist\n",vs);
vs = asf_http_ctrl->video_streams[0];
}
ptr += sprintf( ptr, " ffff:%d:0",vs);
@@ -502,7 +502,7 @@
// First request goes here.
break;
default:
- printf("Unknown asf stream type\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Unknown asf stream type\n");
}
http_set_field( http_hdr, "Connection: Close" );
@@ -517,11 +517,11 @@
char features[64] = "\0";
int len;
if( http_response_parse(http_hdr)<0 ) {
- printf("Failed to parse HTTP response\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Failed to parse HTTP response\n");
return -1;
}
if( http_hdr->status_code!=200 ) {
- printf("Server return %d:%s\n", http_hdr->status_code, http_hdr->reason_phrase);
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Server return %d:%s\n", http_hdr->status_code, http_hdr->reason_phrase);
return -1;
}
@@ -542,7 +542,7 @@
if( end==NULL ) {
int s = strlen(pragma);
if(s > sizeof(features)) {
- printf("ASF HTTP PARSE WARNING : Pragma %s cuted from %d bytes to %d\n",pragma,s,sizeof(features));
+ mp_msg(MSGT_NETWORK,MSGL_WARN,"ASF HTTP PARSE WARNING : Pragma %s cuted from %d bytes to %d\n",pragma,s,sizeof(features));
len = sizeof(features);
} else {
len = s;
@@ -580,7 +580,7 @@
asf_http_ctrl = (asf_http_streaming_ctrl_t*)malloc(sizeof(asf_http_streaming_ctrl_t));
if( asf_http_ctrl==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return -1;
}
asf_http_ctrl->streaming_type = ASF_Unknown_e;
@@ -602,13 +602,11 @@
if( fd<0 ) return -1;
http_hdr = asf_http_request( stream->streaming_ctrl );
- if( verbose>0 ) {
- printf("Request [%s]\n", http_hdr->buffer );
- }
+ mp_msg(MSGT_NETWORK,MSGL_DBG2,"Request [%s]\n", http_hdr->buffer );
for(i=0; i < http_hdr->buffer_size ; ) {
int r = write( fd, http_hdr->buffer+i, http_hdr->buffer_size-i );
if(r <0) {
- printf("Socket write error : %s\n",strerror(errno));
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Socket write error : %s\n",strerror(errno));
return -1;
}
i += r;
@@ -627,11 +625,11 @@
} while( !http_is_header_entire( http_hdr ) );
if( verbose>0 ) {
http_hdr->buffer[http_hdr->buffer_size]='\0';
- printf("Response [%s]\n", http_hdr->buffer );
+ mp_msg(MSGT_NETWORK,MSGL_DBG2,"Response [%s]\n", http_hdr->buffer );
}
streaming_type = asf_http_parse_response(http_hdr);
if( streaming_type<0 ) {
- printf("Failed to parse header\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Failed to parse header\n");
http_free( http_hdr );
return -1;
}
@@ -652,7 +650,7 @@
ret = asf_streaming_parse_header(fd,stream->streaming_ctrl);
if(ret < 0) return -1;
if(asf_http_ctrl->n_audio == 0 && asf_http_ctrl->n_video == 0) {
- printf("No stream found\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"No stream found\n");
return -1;
}
asf_http_ctrl->request++;
@@ -674,7 +672,7 @@
break;
case ASF_Unknown_e:
default:
- printf("Unknown ASF streaming type\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Unknown ASF streaming type\n");
close(fd);
http_free( http_hdr );
return -1;
Index: network.c
===================================================================
RCS file: /cvsroot/mplayer/main/libmpdemux/network.c,v
retrieving revision 1.42
retrieving revision 1.43
diff -u -r1.42 -r1.43
--- network.c 28 Apr 2002 22:37:35 -0000 1.42
+++ network.c 30 Apr 2002 16:58:54 -0000 1.43
@@ -84,7 +84,7 @@
streaming_ctrl_t *streaming_ctrl;
streaming_ctrl = (streaming_ctrl_t*)malloc(sizeof(streaming_ctrl_t));
if( streaming_ctrl==NULL ) {
- printf("Failed to allocate memory\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Failed to allocate memory\n");
return NULL;
}
memset( streaming_ctrl, 0, sizeof(streaming_ctrl_t) );
@@ -112,7 +112,7 @@
getrtp2(fd, &rh, &data, &len);
if( got_first && rh.b.sequence != (unsigned short)(sequence+1) )
- printf("RTP packet sequence error! Expected: %d, received: %d\n",
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"RTP packet sequence error! Expected: %d, received: %d\n",
sequence+1, rh.b.sequence);
got_first = 1;
sequence = rh.b.sequence;
@@ -130,11 +130,11 @@
struct timeval tv;
struct sockaddr_in server_address;
- printf("Connecting to server %s:%d ...\n", host, port );
+ mp_msg(MSGT_NETWORK,MSGL_STATUS,"Connecting to server %s:%d ...\n", host, port );
socket_server_fd = socket(AF_INET, SOCK_STREAM, 0);
if( socket_server_fd==-1 ) {
- perror("Failed to create socket");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Failed to create socket");
return -1;
}
@@ -142,7 +142,7 @@
struct hostent *hp;
hp=(struct hostent*)gethostbyname( host );
if( hp==NULL ) {
- printf("Counldn't resolve name: %s\n", host);
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Counldn't resolve name: %s\n", host);
return -1;
}
memcpy( (void*)&server_address.sin_addr.s_addr, (void*)hp->h_addr, hp->h_length );
@@ -156,7 +156,7 @@
fcntl( socket_server_fd, F_SETFL, fcntl(socket_server_fd, F_GETFL) | O_NONBLOCK );
if( connect( socket_server_fd, (struct sockaddr*)&server_address, sizeof(server_address) )==-1 ) {
if( errno!=EINPROGRESS ) {
- perror("Failed to connect to server");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Failed to connect to server");
close(socket_server_fd);
return -1;
}
@@ -167,13 +167,13 @@
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 ) perror("select failed");
+ if( ret<0 ) mp_msg(MSGT_NETWORK,MSGL_ERR,"select failed");
else if(ret > 0) break;
else if(count > 15 || mpdemux_check_interrupt(500)) {
if(count > 15)
- printf("Connection timeout\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Connection timeout\n");
else
- printf("Connection interuppted by user\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"Connection interuppted by user\n");
return -1;
}
count++;
@@ -187,11 +187,11 @@
err_len = sizeof(int);
ret = getsockopt(socket_server_fd,SOL_SOCKET,SO_ERROR,&err,&err_len);
if(ret < 0) {
- printf("getsockopt failed : %s\n",strerror(errno));
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"getsockopt failed : %s\n",strerror(errno));
return -1;
}
if(err > 0) {
- printf("Connect error : %s\n",strerror(err));
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Connect error : %s\n",strerror(err));
return -1;
}
return socket_server_fd;
@@ -203,7 +203,7 @@
if( url==NULL ) return NULL;
url_out = url_new( url->url );
if( !strcasecmp(url->protocol, "http_proxy") ) {
- printf("Using HTTP proxy: http://%s:%d\n", url->hostname, url->port );
+ 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.
@@ -218,18 +218,18 @@
URL_t *proxy_url = url_new( proxy );
if( proxy_url==NULL ) {
- printf("Invalid proxy setting...Trying without proxy.\n");
+ mp_msg(MSGT_NETWORK,MSGL_WARN,"Invalid proxy setting...Trying without proxy.\n");
return url_out;
}
- printf("Using HTTP proxy: %s\n", proxy_url->url );
+ 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 ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return url_out;
}
- sprintf( new_url, "http_proxy://%s:%d/%s", proxy_url->hostname, proxy_url->port, url->url );
+ 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 ) {
return url_out;
@@ -281,13 +281,11 @@
if( fd<0 ) {
return -1;
}
- if( verbose ) {
- printf("Request: [%s]\n", http_hdr->buffer );
- }
+ mp_msg(MSGT_NETWORK,MSGL_DBG2,"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");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error while sending HTTP request: didn't sent all the request\n");
return -1;
}
@@ -310,12 +308,12 @@
do {
i = read( fd, response, BUFFER_SIZE );
if( i<0 ) {
- printf("Read failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Read failed\n");
http_free( http_hdr );
return NULL;
}
if( i==0 ) {
- printf("http_read_response read 0 -ie- EOF\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"http_read_response read 0 -ie- EOF\n");
http_free( http_hdr );
return NULL;
}
@@ -362,7 +360,7 @@
}
extension=NULL;
if( extension!=NULL ) {
- printf("Extension: %s\n", extension );
+ mp_msg(MSGT_NETWORK,MSGL_DBG2,"Extension: %s\n", extension );
// Look for the extension in the extensions table
for( i=0 ; i<(sizeof(extensions_table)/sizeof(extensions_table[0])) ; i++ ) {
if( !strcasecmp(extension, extensions_table[i].extension) ) {
@@ -374,14 +372,14 @@
// Checking for RTSP
if( !strcasecmp(url->protocol, "rtsp") ) {
- printf("RTSP protocol not yet implemented!\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"RTSP protocol not yet implemented!\n");
return -1;
}
// Checking for RTP
if( !strcasecmp(url->protocol, "rtp") ) {
if( url->port==0 ) {
- printf("You must enter a port number for RTP streams!\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"You must enter a port number for RTP streams!\n");
return -1;
}
return 0;
@@ -422,28 +420,28 @@
// note: I skip icy-notice1 and 2, as they contain html <BR>
// and are IMHO useless info ::atmos
if( (field_data = http_get_field(http_hdr, "icy-name")) != NULL )
- printf("Name : %s\n", field_data); field_data = NULL;
+ mp_msg(MSGT_NETWORK,MSGL_INFO,"Name : %s\n", field_data); field_data = NULL;
if( (field_data = http_get_field(http_hdr, "icy-genre")) != NULL )
- printf("Genre : %s\n", field_data); field_data = NULL;
+ mp_msg(MSGT_NETWORK,MSGL_INFO,"Genre : %s\n", field_data); field_data = NULL;
if( (field_data = http_get_field(http_hdr, "icy-url")) != NULL )
- printf("Website: %s\n", field_data); field_data = NULL;
+ mp_msg(MSGT_NETWORK,MSGL_INFO,"Website: %s\n", field_data); field_data = NULL;
// XXX: does this really mean public server? ::atmos
if( (field_data = http_get_field(http_hdr, "icy-pub")) != NULL )
- printf("Public : %s\n", atoi(field_data)?"yes":"no"); field_data = NULL;
+ mp_msg(MSGT_NETWORK,MSGL_INFO,"Public : %s\n", atoi(field_data)?"yes":"no"); field_data = NULL;
if( (field_data = http_get_field(http_hdr, "icy-br")) != NULL )
- printf("Bitrate: %skbit/s\n", field_data); field_data = NULL;
+ mp_msg(MSGT_NETWORK,MSGL_INFO,"Bitrate: %skbit/s\n", field_data); field_data = NULL;
// Ok, we have detected an mp3 stream
*file_format = DEMUXER_TYPE_AUDIO;
return 0;
}
case 401: // Service Unavailable
- printf("Error: ICY-Server return service unavailable, skipping!\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error: ICY-Server return service unavailable, skipping!\n");
return -1;
case 404: // Resource Not Found
- printf("Error: ICY-Server couldn't find requested stream, skipping!\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error: ICY-Server couldn't find requested stream, skipping!\n");
return -1;
default:
- printf("Error: unhandled ICY-Errorcode, contact MPlayer developers!\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Error: unhandled ICY-Errorcode, contact MPlayer developers!\n");
return -1;
}
}
@@ -455,9 +453,9 @@
content_type = http_get_field( http_hdr, "Content-Type" );
if( content_type!=NULL ) {
char *content_length = NULL;
- printf("Content-Type: [%s]\n", content_type );
+ mp_msg(MSGT_NETWORK,MSGL_V,"Content-Type: [%s]\n", content_type );
if( (content_length = http_get_field(http_hdr, "Content-Length")) != NULL)
- printf("Content-Length: [%s]\n", http_get_field(http_hdr, "Content-Length"));
+ mp_msg(MSGT_NETWORK,MSGL_V,"Content-Length: [%s]\n", http_get_field(http_hdr, "Content-Length"));
// Check in the mime type table for a demuxer type
for( i=0 ; i<(sizeof(mime_type_table)/sizeof(mime_type_table[0])) ; i++ ) {
if( !strcasecmp( content_type, mime_type_table[i].mime_type ) ) {
@@ -483,11 +481,11 @@
}
break;
default:
- printf("Server returned %d: %s\n", http_hdr->status_code, http_hdr->reason_phrase );
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Server returned %d: %s\n", http_hdr->status_code, http_hdr->reason_phrase );
return -1;
}
} else {
- printf("Unknown protocol '%s'\n", url->protocol );
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Unknown protocol '%s'\n", url->protocol );
return -1;
}
} while( redirect );
@@ -500,7 +498,7 @@
//printf("streaming_bufferize\n");
streaming_ctrl->buffer = (char*)malloc(size);
if( streaming_ctrl->buffer==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return -1;
}
memcpy( streaming_ctrl->buffer, buffer, size );
@@ -533,7 +531,7 @@
int ret;
ret = read( fd, buffer+len, size-len );
if( ret<0 ) {
- printf("nop_streaming_read error : %s\n",strerror(errno));
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"nop_streaming_read error : %s\n",strerror(errno));
}
len += ret;
//printf("read %d bytes from network\n", len );
@@ -562,8 +560,8 @@
switch( http_hdr->status_code ) {
case 200: // OK
- printf("Content-Type: [%s]\n", http_get_field(http_hdr, "Content-Type") );
- printf("Content-Length: [%s]\n", http_get_field(http_hdr, "Content-Length") );
+ 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 );
@@ -572,7 +570,7 @@
}
break;
default:
- printf("Server return %d: %s\n", http_hdr->status_code, http_hdr->reason_phrase );
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Server return %d: %s\n", http_hdr->status_code, http_hdr->reason_phrase );
close( fd );
fd = -1;
}
@@ -611,19 +609,19 @@
struct ip_mreq mcast;
struct timeval tv;
- printf("Listening for traffic on %s:%d ...\n", url->hostname, url->port );
+ mp_msg(MSGT_NETWORK,MSGL_V,"Listening for traffic on %s:%d ...\n", url->hostname, url->port );
socket_server_fd = socket(AF_INET, SOCK_DGRAM, 0);
// fcntl( socket_server_fd, F_SETFL, fcntl(socket_server_fd, F_GETFL) | O_NONBLOCK );
if( socket_server_fd==-1 ) {
- perror("Failed to create socket");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Failed to create socket");
return -1;
}
if( isalpha(url->hostname[0]) ) {
struct hostent *hp =(struct hostent*)gethostbyname( url->hostname );
if( hp==NULL ) {
- printf("Counldn't resolve name: %s\n", url->hostname);
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Counldn't resolve name: %s\n", url->hostname);
return -1;
}
memcpy( (void*)&server_address.sin_addr.s_addr, (void*)hp->h_addr, hp->h_length );
@@ -635,7 +633,7 @@
if( bind( socket_server_fd, (struct sockaddr*)&server_address, sizeof(server_address) )==-1 ) {
if( errno!=EINPROGRESS ) {
- perror("Failed to connect to server");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Failed to connect to server");
close(socket_server_fd);
return -1;
}
@@ -644,7 +642,7 @@
// Increase the socket rx buffer size to maximum -- this is UDP
rxsockbufsz = 240 * 1024;
if( setsockopt( socket_server_fd, SOL_SOCKET, SO_RCVBUF, &rxsockbufsz, sizeof(rxsockbufsz))) {
- perror("Couldn't set receive socket buffer size");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Couldn't set receive socket buffer size");
}
if((ntohl(server_address.sin_addr.s_addr) >> 28) == 0xe) {
@@ -652,7 +650,7 @@
//mcast.imr_interface.s_addr = inet_addr("10.1.1.2");
mcast.imr_interface.s_addr = 0;
if( setsockopt( socket_server_fd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mcast, sizeof(mcast))) {
- perror("IP_ADD_MEMBERSHIP failed (do you have multicasting enabled in your kernel?)");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"IP_ADD_MEMBERSHIP failed (do you have multicasting enabled in your kernel?)");
return -1;
}
}
@@ -666,8 +664,8 @@
err_len = sizeof( err );
getsockopt( socket_server_fd, SOL_SOCKET, SO_ERROR, &err, &err_len );
if( err ) {
- printf("Timeout! No data from host %s\n", url->hostname );
- printf("Socket error: %d\n", err );
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Timeout! No data from host %s\n", url->hostname );
+ mp_msg(MSGT_NETWORK,MSGL_DBG2,"Socket error: %d\n", err );
close(socket_server_fd);
return -1;
}
@@ -723,7 +721,7 @@
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));
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"streaming_start : Closing socket %d failed %s\n",stream->fd,strerror(errno));
}
stream->fd = -1;
ret = rtp_streaming_start( stream );
@@ -736,7 +734,7 @@
// ASF raw stream is encapsulated.
ret = asf_streaming_start( stream );
if( ret<0 ) {
- printf("asf_streaming_start failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"asf_streaming_start failed\n");
}
break;
case DEMUXER_TYPE_MPEG_ES:
@@ -756,13 +754,13 @@
// the network stream, it's a raw stream
ret = nop_streaming_start( stream );
if( ret<0 ) {
- printf("nop_streaming_start failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"nop_streaming_start failed\n");
}
if((*demuxer_type) == DEMUXER_TYPE_PLAYLIST)
stream->type = STREAMTYPE_PLAYLIST;
break;
default:
- printf("Unable to detect the streaming type\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Unable to detect the streaming type\n");
ret = -1;
}
@@ -774,14 +772,14 @@
int ret, val;
ret = m_config_is_option_set(mconfig,"cache");
if(ret < 0) {
- printf("Unable to know if cache size option was set\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Unable to know if cache size option was set\n");
} else if(!ret) {
// cache option not set, will use the our computed value.
// buffer in KBytes, *5 because the prefill is 20% of the buffer.
val = (stream->streaming_ctrl->prebuffer_size/1024)*5;
if( val<16 ) val = 16; // 16KBytes min buffer
if( m_config_set_int( mconfig, "cache", val )<0 ) {
- printf("Unable to set the cache size option\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Unable to set the cache size option\n");
} else {
cache_size = val;
}
@@ -789,12 +787,12 @@
// cache option set, will use the given one.
val = m_config_get_int( mconfig, "cache", NULL );
if( val<0 ) {
- printf("Unable to retrieve the cache option value\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Unable to retrieve the cache option value\n");
} else {
cache_size = val;
}
}
- printf("Cache size set to %d KBytes\n", cache_size );
+ mp_msg(MSGT_NETWORK,MSGL_INFO,"Cache size set to %d KBytes\n", cache_size );
}
return ret;
}
Index: http.c
===================================================================
RCS file: /cvsroot/mplayer/main/libmpdemux/http.c,v
retrieving revision 1.11
retrieving revision 1.12
diff -u -r1.11 -r1.12
--- http.c 23 Feb 2002 07:31:45 -0000 1.11
+++ http.c 30 Apr 2002 16:58:54 -0000 1.12
@@ -10,6 +10,7 @@
#include "http.h"
#include "url.h"
+#include "mp_msg.h"
HTTP_header_t *
http_new_header() {
@@ -49,7 +50,7 @@
if( http_hdr==NULL || response==NULL || length<0 ) return -1;
ptr = (char*)malloc( http_hdr->buffer_size+length );
if( ptr==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return -1;
}
if( http_hdr->buffer_size==0 ) {
@@ -87,27 +88,27 @@
// Get the protocol
hdr_ptr = strstr( http_hdr->buffer, " " );
if( hdr_ptr==NULL ) {
- printf("Malformed answer. No space separator found.\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Malformed answer. No space separator found.\n");
return -1;
}
len = hdr_ptr-http_hdr->buffer;
http_hdr->protocol = (char*)malloc(len+1);
if( http_hdr->protocol==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return -1;
}
strncpy( http_hdr->protocol, http_hdr->buffer, len );
http_hdr->protocol[len]='\0';
if( !strncasecmp( http_hdr->protocol, "HTTP", 4) ) {
if( sscanf( http_hdr->protocol+5,"1.%d", &(http_hdr->http_minor_version) )!=1 ) {
- printf("Malformed answer. Unable to get HTTP minor version.\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Malformed answer. Unable to get HTTP minor version.\n");
return -1;
}
}
// Get the status code
if( sscanf( ++hdr_ptr, "%d", &(http_hdr->status_code) )!=1 ) {
- printf("Malformed answer. Unable to get status code.\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Malformed answer. Unable to get status code.\n");
return -1;
}
hdr_ptr += 4;
@@ -115,13 +116,13 @@
// Get the reason phrase
ptr = strstr( hdr_ptr, "\n" );
if( hdr_ptr==NULL ) {
- printf("Malformed answer. Unable to get the reason phrase.\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Malformed answer. Unable to get the reason phrase.\n");
return -1;
}
len = ptr-hdr_ptr;
http_hdr->reason_phrase = (char*)malloc(len+1);
if( http_hdr->reason_phrase==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return -1;
}
strncpy( http_hdr->reason_phrase, hdr_ptr, len );
@@ -135,7 +136,7 @@
if( ptr==NULL ) {
ptr = strstr( http_hdr->buffer, "\n\n" );
if( ptr==NULL ) {
- printf("Header may be incomplete. No CRLF CRLF found.\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Header may be incomplete. No CRLF CRLF found.\n");
return -1;
}
}
@@ -150,7 +151,7 @@
if( len==0 ) break;
field = (char*)realloc(field, len+1);
if( field==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Memory allocation failed\n");
return -1;
}
strncpy( field, hdr_ptr, len );
@@ -166,7 +167,7 @@
int data_length = http_hdr->buffer_size-(pos_hdr_sep+4);
http_hdr->body = (char*)malloc( data_length );
if( http_hdr->body==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Memory allocation failed\n");
return -1;
}
memcpy( http_hdr->body, http_hdr->buffer+pos_hdr_sep+4, data_length );
@@ -189,7 +190,7 @@
else {
uri = (char*)malloc(strlen(http_hdr->uri)*2);
if( uri==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Memory allocation failed\n");
return NULL;
}
url_escape_string( uri, http_hdr->uri );
@@ -217,7 +218,7 @@
}
http_hdr->buffer = (char*)malloc(len+1);
if( http_hdr->buffer==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_ERR,"Memory allocation failed\n");
return NULL;
}
http_hdr->buffer_size = len;
@@ -248,7 +249,7 @@
http_hdr->field_search_pos = http_hdr->first_field;
http_hdr->field_search = (char*)realloc( http_hdr->field_search, strlen(field_name)+1 );
if( http_hdr->field_search==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return NULL;
}
strcpy( http_hdr->field_search, field_name );
@@ -283,13 +284,13 @@
new_field = (HTTP_field_t*)malloc(sizeof(HTTP_field_t));
if( new_field==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return;
}
new_field->next = NULL;
new_field->field_name = (char*)malloc(strlen(field_name)+1);
if( new_field->field_name==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return;
}
strcpy( new_field->field_name, field_name );
@@ -309,7 +310,7 @@
http_hdr->method = (char*)malloc(strlen(method)+1);
if( http_hdr->method==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return;
}
strcpy( http_hdr->method, method );
@@ -321,7 +322,7 @@
http_hdr->uri = (char*)malloc(strlen(uri)+1);
if( http_hdr->uri==NULL ) {
- printf("Memory allocation failed\n");
+ mp_msg(MSGT_NETWORK,MSGL_FATAL,"Memory allocation failed\n");
return;
}
strcpy( http_hdr->uri, uri );
@@ -333,20 +334,20 @@
int i = 0;
if( http_hdr==NULL ) return;
- printf("--- HTTP DEBUG HEADER --- START ---\n");
- printf("protocol: [%s]\n", http_hdr->protocol );
- printf("http minor version: [%d]\n", http_hdr->http_minor_version );
- printf("uri: [%s]\n", http_hdr->uri );
- printf("method: [%s]\n", http_hdr->method );
- printf("status code: [%d]\n", http_hdr->status_code );
- printf("reason phrase: [%s]\n", http_hdr->reason_phrase );
- printf("body size: [%d]\n", http_hdr->body_size );
+ mp_msg(MSGT_NETWORK,MSGL_V,"--- HTTP DEBUG HEADER --- START ---\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"protocol: [%s]\n", http_hdr->protocol );
+ mp_msg(MSGT_NETWORK,MSGL_V,"http minor version: [%d]\n", http_hdr->http_minor_version );
+ mp_msg(MSGT_NETWORK,MSGL_V,"uri: [%s]\n", http_hdr->uri );
+ mp_msg(MSGT_NETWORK,MSGL_V,"method: [%s]\n", http_hdr->method );
+ mp_msg(MSGT_NETWORK,MSGL_V,"status code: [%d]\n", http_hdr->status_code );
+ mp_msg(MSGT_NETWORK,MSGL_V,"reason phrase: [%s]\n", http_hdr->reason_phrase );
+ mp_msg(MSGT_NETWORK,MSGL_V,"body size: [%d]\n", http_hdr->body_size );
- printf("Fields:\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"Fields:\n");
field = http_hdr->first_field;
while( field!=NULL ) {
- printf(" %d - %s\n", i++, field->field_name );
+ mp_msg(MSGT_NETWORK,MSGL_V," %d - %s\n", i++, field->field_name );
field = field->next;
}
- printf("--- HTTP DEBUG HEADER --- END ---\n");
+ mp_msg(MSGT_NETWORK,MSGL_V,"--- HTTP DEBUG HEADER --- END ---\n");
}
More information about the MPlayer-cvslog
mailing list