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

White spaces.

Browse Source
This commit is contained in:
Marcelo Roberto Jimenez 2010-09-03 21:51:31 -03:00
parent ebc941f265
commit b3b7a91a64
1 changed files with 62 additions and 57 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

119
upnp/src/gena/gena_device.c
View File

@ -178,71 +178,76 @@ static UPNP_INLINE int notify_send_and_recv(
/*! [out] The response from the control point. */ /*! [out] The response from the control point. */
http_parser_t *response) http_parser_t *response)
{ {
uri_type url; uri_type url;
int conn_fd; int conn_fd;
membuffer start_msg; membuffer start_msg;
int ret_code; int ret_code;
int err_code; int err_code;
int timeout; int timeout;
SOCKINFO info; SOCKINFO info;
// connect /* connect */
UpnpPrintf( UPNP_ALL, GENA, __FILE__, __LINE__, UpnpPrintf(UPNP_ALL, GENA, __FILE__, __LINE__,
"gena notify to: %.*s\n", "gena notify to: %.*s\n",
(int)destination_url->hostport.text.size, (int)destination_url->hostport.text.size,
destination_url->hostport.text.buff ); destination_url->hostport.text.buff);
conn_fd = http_Connect( destination_url, &url ); conn_fd = http_Connect(destination_url, &url);
if( conn_fd < 0 ) { if (conn_fd < 0) {
return conn_fd; // return UPNP error /* return UPNP error */
}
if( ( ret_code = sock_init( &info, conn_fd ) ) != 0 ) { return conn_fd;
sock_destroy( &info, SD_BOTH ); }
return ret_code;
}
// make start line and HOST header
membuffer_init( &start_msg );
if (http_MakeMessage(
&start_msg, 1, 1,
"q" "s",
HTTPMETHOD_NOTIFY, &url,
mid_msg->buf ) != 0 ) {
membuffer_destroy( &start_msg );
sock_destroy( &info, SD_BOTH );
return UPNP_E_OUTOF_MEMORY;
}
timeout = HTTP_DEFAULT_TIMEOUT; ret_code = sock_init(&info, conn_fd);
if (ret_code) {
sock_destroy(&info, SD_BOTH);
// send msg (note: end of notification will contain "\r\n" twice) return ret_code;
if( ( ret_code = http_SendMessage( &info, &timeout, }
"bbb", /* make start line and HOST header */
start_msg.buf, start_msg.length, membuffer_init(&start_msg);
propertySet, if (http_MakeMessage(
strlen( propertySet ), &start_msg, 1, 1,
"\r\n", strlen( "\r\n" ) ) ) != "q" "s",
0 ) { HTTPMETHOD_NOTIFY, &url,
membuffer_destroy( &start_msg ); mid_msg->buf) != 0) {
sock_destroy( &info, SD_BOTH ); membuffer_destroy(&start_msg);
return ret_code; sock_destroy(&info, SD_BOTH);
}
if( ( ret_code = http_RecvMessage( &info, response, return UPNP_E_OUTOF_MEMORY;
HTTPMETHOD_NOTIFY, &timeout, }
&err_code ) ) != 0 ) {
membuffer_destroy( &start_msg );
sock_destroy( &info, SD_BOTH );
httpmsg_destroy( &response->msg );
return ret_code;
}
sock_destroy( &info, SD_BOTH ); //should shutdown completely timeout = HTTP_DEFAULT_TIMEOUT;
//when closing socket
// sock_destroy( &info,SD_RECEIVE);
membuffer_destroy( &start_msg );
return UPNP_E_SUCCESS; /* send msg (note: end of notification will contain "\r\n" twice) */
ret_code = http_SendMessage(&info, &timeout,
"bbb",
start_msg.buf, start_msg.length,
propertySet, strlen(propertySet),
"\r\n", 2);
if (ret_code) {
membuffer_destroy(&start_msg);
sock_destroy(&info, SD_BOTH);
return ret_code;
}
ret_code = http_RecvMessage(&info, response,
HTTPMETHOD_NOTIFY, &timeout, &err_code);
if (ret_code) {
membuffer_destroy(&start_msg);
sock_destroy(&info, SD_BOTH);
httpmsg_destroy(&response->msg);
return ret_code;
}
/* should shutdown completely when closing socket */
sock_destroy(&info, SD_BOTH);
membuffer_destroy(&start_msg);
return UPNP_E_SUCCESS;
} }