generic-library/libupnp
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Debug code for http_RecvMessage().

Browse Source 
git-svn-id: https://pupnp.svn.sourceforge.net/svnroot/pupnp/trunk@448 119443c7-1b9e-41f8-b6fc-b9c35fce742c
This commit is contained in:
Marcelo Roberto Jimenez
2008-07-10 03:55:07 +00:00
parent b0f782f9c2
commit 654363468a
1 changed files with 90 additions and 71 deletions
Download Patch File Download Diff File Expand all files Collapse all files

161
upnp/src/genlib/net/http/httpreadwrite.c
View File

@@ -205,8 +205,12 @@ http_Connect( IN uri_type * destination_url,
} }
/************************************************************************ /*!
* Function: http_RecvMessage * \brief Get the data on the socket and take actions based on the read data to
* modify the parser objects buffer.
*
* If an error is reported while parsing the data, the error code is passed in
* the http_errr_code parameter.
* *
* Parameters: * Parameters:
* IN SOCKINFO *info; Socket information object * IN SOCKINFO *info; Socket information object
@@ -215,81 +219,96 @@ http_Connect( IN uri_type * destination_url,
* IN OUT int* timeout_secs; time out * IN OUT int* timeout_secs; time out
* OUT int* http_error_code; HTTP error code returned * OUT int* http_error_code; HTTP error code returned
* *
* Description: * \return
* Get the data on the socket and take actions based on the read data
* to modify the parser objects buffer. If an error is reported while
* parsing the data, the error code is passed in the http_errr_code
* parameter
*
* Returns:
* UPNP_E_BAD_HTTPMSG
* UPNP_E_SUCCESS * UPNP_E_SUCCESS
************************************************************************/ * UPNP_E_BAD_HTTPMSG
int */
http_RecvMessage( IN SOCKINFO * info, int http_RecvMessage(
OUT http_parser_t * parser, IN SOCKINFO *info,
IN http_method_t request_method, OUT http_parser_t *parser,
IN OUT int *timeout_secs, IN http_method_t request_method,
OUT int *http_error_code ) IN OUT int *timeout_secs,
OUT int *http_error_code)
{ {
parse_status_t status; int ret = UPNP_E_SUCCESS;
int num_read; int line = 0;
xboolean ok_on_close = FALSE; parse_status_t status;
char buf[2 * 1024]; int num_read;
xboolean ok_on_close = FALSE;
char buf[2 * 1024];
if( request_method == HTTPMETHOD_UNKNOWN ) { if (request_method == HTTPMETHOD_UNKNOWN) {
parser_request_init( parser ); parser_request_init(parser);
} else { } else {
parser_response_init( parser, request_method ); parser_response_init(parser, request_method);
} }
while( TRUE ) { while (TRUE) {
num_read = sock_read( info, buf, sizeof( buf ), timeout_secs ); num_read = sock_read(info, buf, sizeof buf, timeout_secs);
if( num_read > 0 ) { if (num_read > 0) {
// got data // got data
status = parser_append( parser, buf, num_read ); status = parser_append(parser, buf, num_read);
if (status == PARSE_SUCCESS) {
UpnpPrintf( UPNP_INFO, HTTP, __FILE__, __LINE__,
"<<< (RECVD) <<<\n%s\n-----------------\n",
parser->msg.msg.buf );
print_http_headers( &parser->msg );
if (parser->content_length > (unsigned int)g_maxContentLength) {
*http_error_code = HTTP_REQ_ENTITY_TOO_LARGE;
line = __LINE__;
ret = UPNP_E_OUTOF_BOUNDS;
goto ExitFunction;
}
line = __LINE__;
ret = 0;
goto ExitFunction;
} else if (status == PARSE_FAILURE) {
*http_error_code = parser->http_error_code;
line = __LINE__;
ret = UPNP_E_BAD_HTTPMSG;
goto ExitFunction;
} else if (status == PARSE_INCOMPLETE_ENTITY) {
// read until close
ok_on_close = TRUE;
} else if (status == PARSE_CONTINUE_1) {
// Web post request.
line = __LINE__;
ret = PARSE_SUCCESS;
goto ExitFunction;
}
} else if (num_read == 0) {
if (ok_on_close) {
UpnpPrintf( UPNP_INFO, HTTP, __FILE__, __LINE__,
"<<< (RECVD) <<<\n%s\n-----------------\n",
parser->msg.msg.buf );
print_http_headers(&parser->msg);
line = __LINE__;
ret = 0;
goto ExitFunction;
} else {
// partial msg
*http_error_code = HTTP_BAD_REQUEST; // or response
line = __LINE__;
ret = UPNP_E_BAD_HTTPMSG;
goto ExitFunction;
}
} else {
*http_error_code = parser->http_error_code;
line = __LINE__;
ret = num_read;
goto ExitFunction;
}
}
if( status == PARSE_SUCCESS ) { ExitFunction:
UpnpPrintf( UPNP_INFO, HTTP, __FILE__, __LINE__, if (ret != UPNP_E_SUCCESS) {
"<<< (RECVD) <<<\n%s\n-----------------\n", UpnpPrintf(UPNP_ALL, HTTP, __FILE__, line,
parser->msg.msg.buf ); "(http_RecvMessage): Error %d, http_error_code = %d.\n",
print_http_headers( &parser->msg ); ret,
*http_error_code);
}
if( parser->content_length > return ret;
( unsigned int )g_maxContentLength ) {
*http_error_code = HTTP_REQ_ENTITY_TOO_LARGE;
return UPNP_E_OUTOF_BOUNDS;
}
return 0;
} else if( status == PARSE_FAILURE ) {
*http_error_code = parser->http_error_code;
return UPNP_E_BAD_HTTPMSG;
} else if( status == PARSE_INCOMPLETE_ENTITY ) {
// read until close
ok_on_close = TRUE;
} else if( status == PARSE_CONTINUE_1 ) //Web post request. murari
{
return PARSE_SUCCESS;
}
} else if( num_read == 0 ) {
if( ok_on_close ) {
UpnpPrintf( UPNP_INFO, HTTP, __FILE__, __LINE__,
"<<< (RECVD) <<<\n%s\n-----------------\n",
parser->msg.msg.buf );
print_http_headers( &parser->msg );
return 0;
} else {
// partial msg
*http_error_code = HTTP_BAD_REQUEST; // or response
return UPNP_E_BAD_HTTPMSG;
}
} else {
*http_error_code = parser->http_error_code;
return num_read;
}
}
} }