Hi,
The recv() was added because some clients wrote additional data to the
stream (in the interop) and if we close the socket without reading those
data the other end would experience a connection reset. Best thing we
could do was add a recv() before closing the socket.
To avoid the current problem I have set a recv timeout for 1ms before
recv() call. So the max. wait would be 1ms. The fixed code is available
in the current svn. If you want to do it yourself here's the code fragment:
.......
shutdown(socket, AXIS2_SHUT_WR);
axis2_network_handler_set_sock_option(env, socket, SO_RCVTIMEO, 1);
i = recv(socket, buf, 32, 0);
AXIS2_CLOSE_SOCKET(socket);
return AXIS2_SUCCESS;
}
- sahan
Ryzhov, Evgeny wrote:
>Hi,
>
>I investigated that following function blocks threads when I invoke
>service several times.
>Is it necessary to call recv function? (see below)
>
>-----axis2_network_handler.c-----
>AXIS2_EXTERN axis2_status_t AXIS2_CALL
>axis2_network_handler_close_socket (const axis2_env_t *env,
>axis2_socket_t socket)
>{
> int i = 0;
> char buf[32];
> AXIS2_ENV_CHECK(env, AXIS2_CRTICAL_FAILURE);
> if(socket < 0)
> {
> AXIS2_ERROR_SET(env->error, AXIS2_ERROR_INVALID_SOCKET,
> AXIS2_FAILURE);
> return AXIS2_FAILURE;
> }
> shutdown(socket, AXIS2_SHUT_WR);
> i = recv(socket, buf, 32, 0);<----------"If no incoming data is
>available at the socket, the recv call blocks and waits for data to
>arrive"
> AXIS2_CLOSE_SOCKET(socket);
> return AXIS2_SUCCESS;
>}
>-----axis2_network_handler.c-----
>
>---
>Best regards,
>Evgeniy
>
>
>
>>-----Original Message-----
>>From: Ryzhov, Evgeny [mailto:[EMAIL PROTECTED]
>>Sent: Saturday, June 24, 2006 1:38 PM
>>To: [email protected]
>>Subject: [Axis2] Client which can invoke service several times
>>
>>Hi,
>>
>>I have tried to realize client which can invoke service several times.
>>And I have determined that some resources(threads on service
>>side, tcp connections and memory on both side) stay in use
>>after service invocation have completed. I'm using
>>axis2_http_server.exe from version 0.92.
>>Could you explain me how I have to free resources correctly, please?
>>Examples which were modified in order to have multiple
>>invocation are applied below (mtom and echo).
>>
>>---
>>Best regards,
>>Evgeniy
>>
>>---mtom.c---http://localhost/axis2/services/mtomn---------
>>/*
>> * Copyright 2004,2005 The Apache Software Foundation.
>> *
>> * Licensed under the Apache License, Version 2.0 (the "License");
>> * you may not use this file except in compliance with the License.
>> * You may obtain a copy of the License at
>> *
>> * http://www.apache.org/licenses/LICENSE-2.0
>> *
>> * Unless required by applicable law or agreed to in writing, software
>> * distributed under the License is distributed on an "AS IS" BASIS,
>> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
>>express or implied.
>> * See the License for the specific language governing permissions and
>> * limitations under the License.
>> */
>>#include <stdio.h>
>>#include <axiom.h>
>>#include <axis2_util.h>
>>#include <axiom_soap.h>
>>#include <axis2_client.h>
>>axiom_node_t *
>>build_om_programatically(const axis2_env_t *env,
>> const axis2_char_t *image_name,
>> const axis2_char_t *to_save_name);
>>int main(int argc, char** argv)
>>{
>> const axis2_env_t *env = NULL;
>> const axis2_char_t *address = NULL;
>> axis2_endpoint_ref_t* endpoint_ref = NULL;
>> axis2_options_t *options = NULL;
>> const axis2_char_t *client_home = NULL;
>> axis2_svc_client_t* svc_client = NULL;
>> axiom_node_t *payload = NULL;
>> axiom_node_t *ret_node = NULL;
>> const axis2_char_t *image_name = "resources/axis2.jpg";
>>const axis2_char_t *to_save_name = "D:/tmp/test.jpg";
>>
>> /* Set up the environment */
>> env = axis2_env_create_all("mtom.log", AXIS2_LOG_LEVEL_TRACE);
>> /* Set end point reference of mtom service */
>> address = "http://localhost/axis2/services/mtomn";;
>> if (argc > 1 )
>> address = argv[1];
>> if (AXIS2_STRCMP(address, "-h") == 0)
>> {
>> printf("Usage : %s [endpoint_url] [image_name]
>>[to_save_name]\n", argv[0]);
>> printf("use -h for help\n");
>> return 0;
>> }
>> if (argc > 2)
>> image_name = argv[2];
>> if (argc > 3)
>> to_save_name = argv[3];
>> printf ("Using endpoint : %s\n", address);
>> /* Set up deploy folder. It is from the deploy folder,
>>the configuration is picked up
>> * using the axis2.xml file.
>> * In this sample client_home points to the Axis2/C
>>default deploy folder. The client_home can
>> * be different from this folder on your system. For
>>example, you may have a different folder
>> * (say, my_client_folder) with its own axis2.xml file.
>>my_client_folder/modules will have the
>> * modules that the client uses
>> */
>> client_home = AXIS2_GETENV("AXIS2C_HOME");
>> if (!client_home)
>> client_home = "../../deploy";
>> while(1)
>> {
>> /* Create EPR with given address */
>> endpoint_ref = axis2_endpoint_ref_create(env, address);
>> /* Setup options */
>> options = axis2_options_create(env);
>> AXIS2_OPTIONS_SET_TO(options, env, endpoint_ref);
>> AXIS2_OPTIONS_SET_SOAP_VERSION(options, env, AXIOM_SOAP11);
>> AXIS2_OPTIONS_SET_ENABLE_MTOM(options, env, AXIS2_TRUE);
>> /* Create service client */
>> svc_client = axis2_svc_client_create(env, client_home);
>> if (!svc_client)
>> {
>> printf("Error creating service client\n");
>> AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "Stub invoke
>>FAILED: Error code:"
>> " %d :: %s", env->error->error_number,
>> AXIS2_ERROR_GET_MESSAGE(env->error));
>> }
>> /* Set service client options */
>> AXIS2_SVC_CLIENT_SET_OPTIONS(svc_client, env, options);
>> /* Engage addressing module */
>> AXIS2_SVC_CLIENT_ENGAGE_MODULE(svc_client, env,
>>AXIS2_MODULE_ADDRESSING);
>> /* Build the SOAP request message payload using OM API.*/
>> payload = build_om_programatically(env, image_name, to_save_name);
>> /* Send request */
>> ret_node = AXIS2_SVC_CLIENT_SEND_RECEIVE(svc_client, env, payload);
>> if( payload )
>> {
>> AXIOM_NODE_FREE_TREE(payload, env);
>> payload = NULL;
>> }
>> if(ret_node)
>> {
>> axis2_char_t *om_str = NULL;
>> om_str = AXIOM_NODE_TO_STRING(ret_node, env);
>> if (om_str)
>> printf("\nReceived OM : %s\n", om_str);
>> printf("\nmtom client invoke SUCCESSFUL!\n");
>> AXIOM_NODE_FREE_TREE(ret_node, env);
>> ret_node = NULL;
>> }
>> else
>> {
>> AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "Stub invoke
>>FAILED: Error code:"
>> " %d :: %s", env->error->error_number,
>> AXIS2_ERROR_GET_MESSAGE(env->error));
>> printf("mtom client invoke FAILED!\n");
>> }
>> if (svc_client)
>> {
>> AXIS2_SVC_CLIENT_FREE(svc_client, env);
>> svc_client = NULL;
>> }
>> if (endpoint_ref)
>> {
>> AXIS2_ENDPOINT_REF_FREE(endpoint_ref, env);
>> endpoint_ref = NULL;
>> }
>> }
>> return 0;
>>}
>>/* build SOAP request message content using OM */
>>axiom_node_t * build_om_programatically(const axis2_env_t *env,
>> const axis2_char_t *image_name,
>> const axis2_char_t *to_save_name)
>>{
>> axiom_node_t *mtom_om_node = NULL;
>> axiom_element_t* mtom_om_ele = NULL;
>> axiom_node_t* image_om_node = NULL;
>> axiom_element_t * image_om_ele = NULL;
>> axiom_node_t* file_om_node = NULL;
>> axiom_element_t * file_om_ele = NULL;
>> axiom_node_t* data_om_node = NULL;
>> axiom_text_t * data_text = NULL;
>> axiom_namespace_t *ns1 = NULL;
>> axiom_data_handler_t *data_handler = NULL;
>>
>> ns1 = axiom_namespace_create (env,
>>"http://ws.apache.org/axis2/c/samples/mtom";, "ns1");
>> mtom_om_ele = axiom_element_create(env, NULL,
>>"mtomSample", ns1, &mtom_om_node);
>>
>> file_om_ele = axiom_element_create(env, mtom_om_node,
>>"fileName", ns1, &file_om_node);
>> AXIOM_ELEMENT_SET_TEXT(file_om_ele, env, to_save_name,
>>file_om_node);
>> image_om_ele = axiom_element_create(env, mtom_om_node,
>>"image", ns1, &image_om_node);
>> data_handler = axiom_data_handler_create(env, image_name,
>>"image/jpeg");
>> data_text = axiom_text_create_with_data_handler(env,
>>image_om_node, data_handler, &data_om_node);
>> return mtom_om_node;
>>}
>>
>>---echo.c---http://localhost/axis2/services/echon---------
>>/*
>> * Copyright 2004,2005 The Apache Software Foundation.
>> *
>> * Licensed under the Apache License, Version 2.0 (the "License");
>> * you may not use this file except in compliance with the License.
>> * You may obtain a copy of the License at
>> *
>> * http://www.apache.org/licenses/LICENSE-2.0
>> *
>> * Unless required by applicable law or agreed to in writing, software
>> * distributed under the License is distributed on an "AS IS" BASIS,
>> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
>>express or implied.
>> * See the License for the specific language governing permissions and
>> * limitations under the License.
>> */
>>#include <stdio.h>
>>#include <axiom.h>
>>#include <axis2_util.h>
>>#include <axiom_soap.h>
>>#include <axis2_client.h>
>>axiom_node_t *
>>build_om_payload_for_echo_svc(const axis2_env_t *env);
>>
>>int main(int argc, char** argv)
>>{
>> const axis2_env_t *env = NULL;
>> const axis2_char_t *address = NULL;
>> const axis2_char_t *client_home = NULL;
>> /* Set up the environment */
>> env = axis2_env_create_all("echon.log", AXIS2_LOG_LEVEL_TRACE);
>> /* Set up deploy folder. It is from the deploy folder, the
>>configuration is picked up
>> * using the axis2.xml file.
>> * In this sample client_home points to the Axis2/C default
>>deploy folder. The client_home can
>> * be different from this folder on your system. For example,
>>you may have a different folder
>> * (say, my_client_folder) with its own axis2.xml file.
>>my_client_folder/modules will have the
>> * modules that the client uses
>> */
>> client_home = AXIS2_GETENV("AXIS2C_HOME"); if (!client_home)
>> client_home = "../../deploy";
>> /* Set end point reference of echo service */ address =
>>"http://localhost/axis2/services/echon";;
>> if (argc > 1 )
>> address = argv[1];
>> if (AXIS2_STRCMP(address, "-h") == 0)
>> {
>> printf("Usage : %s [endpoint_url]\n", argv[0]);
>> printf("use -h for help\n");
>> return 0;
>> }
>> printf ("Using endpoint : %s\n", address);
>> while(1)
>> {
>> axis2_endpoint_ref_t* endpoint_ref = NULL;
>> axis2_options_t *options = NULL;
>> axis2_svc_client_t* svc_client = NULL;
>> axiom_node_t *payload = NULL;
>> axiom_node_t *ret_node = NULL;
>> /* Create EPR with given address */
>> endpoint_ref = axis2_endpoint_ref_create(env, address);
>> /* Setup options */
>> options = axis2_options_create(env);
>> AXIS2_OPTIONS_SET_TO(options, env, endpoint_ref);
>> AXIS2_OPTIONS_SET_ACTION(options, env,
>> "http://ws.apache.org/axis2/c/samples/echoString";);
>> /* Create service client */
>> svc_client = axis2_svc_client_create(env, client_home);
>> if (!svc_client)
>> {
>> printf("Error creating service client\n");
>> AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "Stub invoke
>>FAILED: Error code:"
>> " %d :: %s", env->error->error_number,
>> AXIS2_ERROR_GET_MESSAGE(env->error));
>> }
>> /* Set service client options */
>> AXIS2_SVC_CLIENT_SET_OPTIONS(svc_client, env, options);
>> /* Engage addressing module */
>> AXIS2_SVC_CLIENT_ENGAGE_MODULE(svc_client, env,
>>AXIS2_MODULE_ADDRESSING);
>> /* Build the SOAP request message payload using OM API.*/
>> payload = build_om_payload_for_echo_svc(env);
>>
>> /* Send request */
>> ret_node = AXIS2_SVC_CLIENT_SEND_RECEIVE(svc_client, env, payload);
>> if(ret_node)
>> {
>> axis2_char_t *om_str = NULL;
>> om_str = AXIOM_NODE_TO_STRING(ret_node, env);
>> if (om_str)
>> printf("-->[%s]\n", om_str);
>> //printf("\necho client invoke SUCCESSFUL!\n");
>> }
>> else
>> {
>> AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "Stub invoke
>>FAILED: Error code:"
>> " %d :: %s", env->error->error_number,
>> AXIS2_ERROR_GET_MESSAGE(env->error));
>> printf("echo client invoke FAILED!\n");
>> }
>> if (svc_client)
>> {
>> AXIS2_SVC_CLIENT_FREE(svc_client, env);
>> svc_client = NULL;
>> }
>> if (endpoint_ref)
>> {
>> AXIS2_ENDPOINT_REF_FREE(endpoint_ref, env);
>> endpoint_ref = NULL;
>> }
>> //break;
>> }
>> return 0;
>>}
>>int main1(int argc, char** argv)
>>{
>> const axis2_env_t *env = NULL;
>> const axis2_char_t *address = NULL;
>> axis2_endpoint_ref_t* endpoint_ref = NULL;
>> axis2_options_t *options = NULL;
>> const axis2_char_t *client_home = NULL;
>> axis2_svc_client_t* svc_client = NULL;
>> axiom_node_t *payload = NULL;
>> axiom_node_t *ret_node = NULL;
>>
>> /* Set up the environment */
>> env = axis2_env_create_all("echo.log", AXIS2_LOG_LEVEL_TRACE);
>> /* Set end point reference of echo service */
>> address = "http://localhost/axis2/services/echon";;
>> if (argc > 1 )
>> address = argv[1];
>> if (AXIS2_STRCMP(address, "-h") == 0)
>> {
>> printf("Usage : %s [endpoint_url]\n", argv[0]);
>> printf("use -h for help\n");
>> return 0;
>> }
>> printf ("Using endpoint : %s\n", address);
>>
>> /* Create EPR with given address */
>> endpoint_ref = axis2_endpoint_ref_create(env, address);
>> /* Setup options */
>> options = axis2_options_create(env);
>> AXIS2_OPTIONS_SET_TO(options, env, endpoint_ref);
>> AXIS2_OPTIONS_SET_ACTION(options, env,
>> "http://ws.apache.org/axis2/c/samples/echoString";);
>> /* Set up deploy folder. It is from the deploy folder,
>>the configuration is picked up
>> * using the axis2.xml file.
>> * In this sample client_home points to the Axis2/C
>>default deploy folder. The client_home can
>> * be different from this folder on your system. For
>>example, you may have a different folder
>> * (say, my_client_folder) with its own axis2.xml file.
>>my_client_folder/modules will have the
>> * modules that the client uses
>> */
>> client_home = AXIS2_GETENV("AXIS2C_HOME");
>> if (!client_home)
>> client_home = "../../deploy";
>> /* Create service client */
>> svc_client = axis2_svc_client_create(env, client_home);
>> if (!svc_client)
>> {
>> printf("Error creating service client\n");
>> AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "Stub invoke
>>FAILED: Error code:"
>> " %d :: %s", env->error->error_number,
>> AXIS2_ERROR_GET_MESSAGE(env->error));
>> }
>> /* Set service client options */
>> AXIS2_SVC_CLIENT_SET_OPTIONS(svc_client, env, options);
>>
>> /* Engage addressing module */
>> AXIS2_SVC_CLIENT_ENGAGE_MODULE(svc_client, env,
>>AXIS2_MODULE_ADDRESSING);
>>
>> /* Build the SOAP request message payload using OM API.*/
>> payload = build_om_payload_for_echo_svc(env);
>>
>> /* Send request */
>> ret_node = AXIS2_SVC_CLIENT_SEND_RECEIVE(svc_client, env,
>>payload);
>>
>> if(ret_node)
>> {
>> axis2_char_t *om_str = NULL;
>> om_str = AXIOM_NODE_TO_STRING(ret_node, env);
>> if (om_str)
>> printf("-->[%s]\n", om_str);
>> //printf("\necho client invoke SUCCESSFUL!\n");
>> }
>> else
>> {
>> AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "Stub invoke
>>FAILED: Error code:"
>> " %d :: %s", env->error->error_number,
>> AXIS2_ERROR_GET_MESSAGE(env->error));
>> printf("echo client invoke FAILED!\n");
>> }
>>
>> if (svc_client)
>> {
>> AXIS2_SVC_CLIENT_FREE(svc_client, env);
>> svc_client = NULL;
>> }
>> if (endpoint_ref)
>> {
>> AXIS2_ENDPOINT_REF_FREE(endpoint_ref, env);
>> endpoint_ref = NULL;
>> }
>> return 0;
>>}
>>/* build SOAP request message content using OM */
>>axiom_node_t * build_om_payload_for_echo_svc(const axis2_env_t *env) {
>> axiom_node_t *echo_om_node = NULL;
>> axiom_element_t* echo_om_ele = NULL;
>> axiom_node_t* text_om_node = NULL;
>> axiom_element_t * text_om_ele = NULL;
>> axiom_namespace_t *ns1 = NULL;
>> axis2_char_t *om_str = NULL;
>>
>> ns1 = axiom_namespace_create (env,
>>"http://ws.apache.org/axis2/c/samples";, "ns1");
>> echo_om_ele = axiom_element_create(env, NULL,
>>"echoString", ns1, &echo_om_node);
>> text_om_ele = axiom_element_create(env, echo_om_node,
>>"text", NULL, &text_om_node);
>> AXIOM_ELEMENT_SET_TEXT(text_om_ele, env, "echo5", text_om_node);
>>
>> om_str = AXIOM_NODE_TO_STRING(echo_om_node, env);
>> if (om_str)
>> printf("<--[%s]\n", om_str);
>> return echo_om_node;
>>}
>>---------------------------------------------
>>
>>
>>---------------------------------------------------------------------
>>To unsubscribe, e-mail: [EMAIL PROTECTED]
>>For additional commands, e-mail: [EMAIL PROTECTED]
>>
>>
>>
>>
>
>---------------------------------------------------------------------
>To unsubscribe, e-mail: [EMAIL PROTECTED]
>For additional commands, e-mail: [EMAIL PROTECTED]
>
>
>
>
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
