You are viewing a plain text version of this content. The canonical link for it is here.
Posted to axis-cvs@ws.apache.org by sh...@apache.org on 2009/08/18 12:15:53 UTC
svn commit: r805347 [1/31] - in /webservices/axis2/trunk/c/src: core/addr/
core/clientapi/ core/context/ core/deployment/ core/description/
core/engine/ core/phaseresolver/ core/receivers/
core/transport/amqp/receiver/ core/transport/amqp/receiver/qpid...
Author: shankar
Date: Tue Aug 18 10:15:49 2009
New Revision: 805347
URL: http://svn.apache.org/viewvc?rev=805347&view=rev
Log:
formatting the code
Modified:
webservices/axis2/trunk/c/src/core/addr/any_content_type.c
webservices/axis2/trunk/c/src/core/addr/endpoint_ref.c
webservices/axis2/trunk/c/src/core/addr/msg_info_headers.c
webservices/axis2/trunk/c/src/core/addr/relates_to.c
webservices/axis2/trunk/c/src/core/addr/svc_name.c
webservices/axis2/trunk/c/src/core/clientapi/async_result.c
webservices/axis2/trunk/c/src/core/clientapi/callback.c
webservices/axis2/trunk/c/src/core/clientapi/callback_recv.c
webservices/axis2/trunk/c/src/core/clientapi/listener_manager.c
webservices/axis2/trunk/c/src/core/clientapi/op_client.c
webservices/axis2/trunk/c/src/core/clientapi/options.c
webservices/axis2/trunk/c/src/core/clientapi/stub.c
webservices/axis2/trunk/c/src/core/clientapi/svc_client.c
webservices/axis2/trunk/c/src/core/context/conf_ctx.c
webservices/axis2/trunk/c/src/core/context/ctx.c
webservices/axis2/trunk/c/src/core/context/msg_ctx.c
webservices/axis2/trunk/c/src/core/context/op_ctx.c
webservices/axis2/trunk/c/src/core/context/svc_ctx.c
webservices/axis2/trunk/c/src/core/context/svc_grp_ctx.c
webservices/axis2/trunk/c/src/core/deployment/arch_file_data.c
webservices/axis2/trunk/c/src/core/deployment/arch_reader.c
webservices/axis2/trunk/c/src/core/deployment/conf_builder.c
webservices/axis2/trunk/c/src/core/deployment/conf_init.c
webservices/axis2/trunk/c/src/core/deployment/dep_engine.c
webservices/axis2/trunk/c/src/core/deployment/desc_builder.c
webservices/axis2/trunk/c/src/core/deployment/module_builder.c
webservices/axis2/trunk/c/src/core/deployment/phases_info.c
webservices/axis2/trunk/c/src/core/deployment/repos_listener.c
webservices/axis2/trunk/c/src/core/deployment/svc_builder.c
webservices/axis2/trunk/c/src/core/deployment/svc_grp_builder.c
webservices/axis2/trunk/c/src/core/deployment/ws_info.c
webservices/axis2/trunk/c/src/core/deployment/ws_info_list.c
webservices/axis2/trunk/c/src/core/description/desc.c
webservices/axis2/trunk/c/src/core/description/flow.c
webservices/axis2/trunk/c/src/core/description/flow_container.c
webservices/axis2/trunk/c/src/core/description/handler_desc.c
webservices/axis2/trunk/c/src/core/description/module_desc.c
webservices/axis2/trunk/c/src/core/description/msg.c
webservices/axis2/trunk/c/src/core/description/op.c
webservices/axis2/trunk/c/src/core/description/phase_rule.c
webservices/axis2/trunk/c/src/core/description/policy_include.c
webservices/axis2/trunk/c/src/core/description/svc.c
webservices/axis2/trunk/c/src/core/description/svc_grp.c
webservices/axis2/trunk/c/src/core/description/transport_in_desc.c
webservices/axis2/trunk/c/src/core/description/transport_out_desc.c
webservices/axis2/trunk/c/src/core/engine/addr_disp.c
webservices/axis2/trunk/c/src/core/engine/conf.c
webservices/axis2/trunk/c/src/core/engine/ctx_handler.c
webservices/axis2/trunk/c/src/core/engine/disp.c
webservices/axis2/trunk/c/src/core/engine/disp_checker.c
webservices/axis2/trunk/c/src/core/engine/engine.c
webservices/axis2/trunk/c/src/core/engine/handler.c
webservices/axis2/trunk/c/src/core/engine/phase.c
webservices/axis2/trunk/c/src/core/engine/req_uri_disp.c
webservices/axis2/trunk/c/src/core/engine/rest_disp.c
webservices/axis2/trunk/c/src/core/engine/soap_action_disp.c
webservices/axis2/trunk/c/src/core/engine/soap_body_disp.c
webservices/axis2/trunk/c/src/core/phaseresolver/phase_holder.c
webservices/axis2/trunk/c/src/core/phaseresolver/phase_resolver.c
webservices/axis2/trunk/c/src/core/receivers/msg_recv.c
webservices/axis2/trunk/c/src/core/receivers/raw_xml_in_out_msg_recv.c
webservices/axis2/trunk/c/src/core/receivers/svr_callback.c
webservices/axis2/trunk/c/src/core/transport/amqp/receiver/axis2_amqp_receiver.c
webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/axis2_qpid_receiver.cpp
webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/axis2_qpid_receiver_listener.cpp
webservices/axis2/trunk/c/src/core/transport/amqp/receiver/qpid_receiver/request_processor/axis2_amqp_request_processor.c
webservices/axis2/trunk/c/src/core/transport/amqp/sender/axis2_amqp_sender.c
webservices/axis2/trunk/c/src/core/transport/amqp/sender/qpid_sender/axis2_qpid_sender.cpp
webservices/axis2/trunk/c/src/core/transport/amqp/server/axis2_amqp_server/axis2_amqp_server.c
webservices/axis2/trunk/c/src/core/transport/amqp/util/axis2_amqp_util.c
webservices/axis2/trunk/c/src/core/transport/http/common/http_accept_record.c
webservices/axis2/trunk/c/src/core/transport/http/common/http_header.c
webservices/axis2/trunk/c/src/core/transport/http/common/http_out_transport_info.c
webservices/axis2/trunk/c/src/core/transport/http/common/http_request_line.c
webservices/axis2/trunk/c/src/core/transport/http/common/http_response_writer.c
webservices/axis2/trunk/c/src/core/transport/http/common/http_simple_request.c
webservices/axis2/trunk/c/src/core/transport/http/common/http_simple_response.c
webservices/axis2/trunk/c/src/core/transport/http/common/http_status_line.c
webservices/axis2/trunk/c/src/core/transport/http/common/http_worker.c
webservices/axis2/trunk/c/src/core/transport/http/common/simple_http_svr_conn.c
webservices/axis2/trunk/c/src/core/transport/http/receiver/http_receiver.c
webservices/axis2/trunk/c/src/core/transport/http/sender/http_client.c
webservices/axis2/trunk/c/src/core/transport/http/sender/http_sender.c
webservices/axis2/trunk/c/src/core/transport/http/sender/http_transport_sender.c
webservices/axis2/trunk/c/src/core/transport/http/sender/libcurl/axis2_libcurl.c
webservices/axis2/trunk/c/src/core/transport/http/sender/libcurl/libcurl_stream.c
webservices/axis2/trunk/c/src/core/transport/http/sender/ssl/ssl_stream.c
webservices/axis2/trunk/c/src/core/transport/http/sender/ssl/ssl_utils.c
webservices/axis2/trunk/c/src/core/transport/http/server/CGI/axis2_cgi_main.c
webservices/axis2/trunk/c/src/core/transport/http/server/CGI/axis2_cgi_out_transport_info.c
webservices/axis2/trunk/c/src/core/transport/http/server/CGI/axis2_cgi_stream.c
webservices/axis2/trunk/c/src/core/transport/http/server/IIS/axis2_iis_out_transport_info.c
webservices/axis2/trunk/c/src/core/transport/http/server/IIS/axis2_iis_stream.c
webservices/axis2/trunk/c/src/core/transport/http/server/IIS/axis2_iis_worker.c
webservices/axis2/trunk/c/src/core/transport/http/server/IIS/iis_iaspi_plugin_51/axis2_isapi_51.c
webservices/axis2/trunk/c/src/core/transport/http/server/apache2/apache2_out_transport_info.c
webservices/axis2/trunk/c/src/core/transport/http/server/apache2/apache2_stream.c
webservices/axis2/trunk/c/src/core/transport/http/server/apache2/apache2_worker.c
webservices/axis2/trunk/c/src/core/transport/http/server/apache2/mod_axis2.c
webservices/axis2/trunk/c/src/core/transport/http/server/simple_axis2_server/http_server_main.c
webservices/axis2/trunk/c/src/core/transport/http/util/http_transport_utils.c
webservices/axis2/trunk/c/src/core/transport/tcp/receiver/simple_tcp_svr_conn.c
webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_receiver.c
webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_svr_thread.c
webservices/axis2/trunk/c/src/core/transport/tcp/receiver/tcp_worker.c
webservices/axis2/trunk/c/src/core/transport/tcp/sender/tcp_transport_sender.c
webservices/axis2/trunk/c/src/core/transport/tcp/server/simple_tcp_server/tcp_server_main.c
webservices/axis2/trunk/c/src/core/util/core_utils.c
webservices/axis2/trunk/c/src/modules/mod_addr/addr_in_handler.c
webservices/axis2/trunk/c/src/modules/mod_addr/addr_out_handler.c
webservices/axis2/trunk/c/src/modules/mod_addr/mod_addr.c
webservices/axis2/trunk/c/src/modules/mod_log/log_in_handler.c
webservices/axis2/trunk/c/src/modules/mod_log/log_out_handler.c
webservices/axis2/trunk/c/src/modules/mod_log/mod_log.c
Modified: webservices/axis2/trunk/c/src/core/addr/any_content_type.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/addr/any_content_type.c?rev=805347&r1=805346&r2=805347&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/addr/any_content_type.c (original)
+++ webservices/axis2/trunk/c/src/core/addr/any_content_type.c Tue Aug 18 10:15:49 2009
@@ -1,4 +1,3 @@
-
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
@@ -34,9 +33,8 @@
AXIS2_ENV_CHECK(env, NULL);
- any_content_type = AXIS2_MALLOC(env->allocator,
- sizeof(axis2_any_content_type_t));
- if (!any_content_type)
+ any_content_type = AXIS2_MALLOC(env->allocator, sizeof(axis2_any_content_type_t));
+ if(!any_content_type)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
@@ -46,7 +44,7 @@
any_content_type->value_map = axutil_hash_make(env);
- if (!(any_content_type->value_map))
+ if(!(any_content_type->value_map))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
axis2_any_content_type_free(any_content_type, env);
@@ -63,21 +61,19 @@
const axutil_qname_t * qname,
const axis2_char_t * value)
{
- axis2_char_t *temp = NULL;
+ axis2_char_t *temp = NULL;
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- if (any_content_type->value_map)
+ if(any_content_type->value_map)
{
axis2_char_t *name = NULL;
- name = axutil_qname_to_string((axutil_qname_t *) qname, env);
- axutil_hash_set(any_content_type->value_map, name,
- AXIS2_HASH_KEY_STRING, value);
-
- temp = axutil_hash_get(any_content_type->value_map, name,
- AXIS2_HASH_KEY_STRING);
- if (temp)
- return AXIS2_SUCCESS;
+ name = axutil_qname_to_string((axutil_qname_t *)qname, env);
+ axutil_hash_set(any_content_type->value_map, name, AXIS2_HASH_KEY_STRING, value);
+
+ temp = axutil_hash_get(any_content_type->value_map, name, AXIS2_HASH_KEY_STRING);
+ if(temp)
+ return AXIS2_SUCCESS;
}
return AXIS2_FAILURE;
}
@@ -88,13 +84,12 @@
const axutil_env_t * env,
const axutil_qname_t * qname)
{
- if (any_content_type->value_map)
+ if(any_content_type->value_map)
{
axis2_char_t *name = NULL;
- name = axutil_qname_to_string((axutil_qname_t *) qname, env);
- return axutil_hash_get(any_content_type->value_map, name,
- AXIS2_HASH_KEY_STRING);
+ name = axutil_qname_to_string((axutil_qname_t *)qname, env);
+ return axutil_hash_get(any_content_type->value_map, name, AXIS2_HASH_KEY_STRING);
}
return NULL;
}
@@ -114,7 +109,7 @@
{
AXIS2_ENV_CHECK(env, void);
- if (any_content_type->value_map)
+ if(any_content_type->value_map)
{
axutil_hash_free(any_content_type->value_map, env);
}
Modified: webservices/axis2/trunk/c/src/core/addr/endpoint_ref.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/addr/endpoint_ref.c?rev=805347&r1=805346&r2=805347&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/addr/endpoint_ref.c (original)
+++ webservices/axis2/trunk/c/src/core/addr/endpoint_ref.c Tue Aug 18 10:15:49 2009
@@ -1,4 +1,3 @@
-
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
@@ -58,7 +57,7 @@
AXIS2_ENV_CHECK(env, NULL);
endpoint_ref = AXIS2_MALLOC(env->allocator, sizeof(axis2_endpoint_ref_t));
- if (!endpoint_ref)
+ if(!endpoint_ref)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
@@ -73,10 +72,10 @@
endpoint_ref->extension_list = NULL;
endpoint_ref->svc_name = NULL;
- if (address)
+ if(address)
{
endpoint_ref->address = axutil_strdup(env, address);
- if (!(endpoint_ref->address))
+ if(!(endpoint_ref->address))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
axis2_endpoint_ref_free(endpoint_ref, env);
@@ -102,7 +101,7 @@
const axis2_char_t * address)
{
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- if (endpoint_ref->address)
+ if(endpoint_ref->address)
{
AXIS2_FREE(env->allocator, endpoint_ref->address);
}
@@ -126,8 +125,7 @@
const axutil_qname_t * interface_qname)
{
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- endpoint_ref->interface_qname =
- axutil_qname_clone((axutil_qname_t *) interface_qname, env);
+ endpoint_ref->interface_qname = axutil_qname_clone((axutil_qname_t *)interface_qname, env);
return AXIS2_SUCCESS;
}
@@ -159,7 +157,7 @@
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- endpoint_ref_l = (axis2_endpoint_ref_t *) endpoint_ref;
+ endpoint_ref_l = (axis2_endpoint_ref_t *)endpoint_ref;
axis2_endpoint_ref_free(endpoint_ref_l, env);
return;
}
@@ -171,32 +169,32 @@
{
AXIS2_ENV_CHECK(env, void);
- if (endpoint_ref->address)
+ if(endpoint_ref->address)
{
AXIS2_FREE(env->allocator, endpoint_ref->address);
}
- if (endpoint_ref->ref_param_list)
+ if(endpoint_ref->ref_param_list)
{
axutil_array_list_free(endpoint_ref->ref_param_list, env);
}
- if (endpoint_ref->metadata_list)
+ if(endpoint_ref->metadata_list)
{
axutil_array_list_free(endpoint_ref->metadata_list, env);
}
- if (endpoint_ref->ref_attribute_list)
+ if(endpoint_ref->ref_attribute_list)
{
axutil_array_list_free(endpoint_ref->ref_attribute_list, env);
}
- if (endpoint_ref->meta_attribute_list)
+ if(endpoint_ref->meta_attribute_list)
{
axutil_array_list_free(endpoint_ref->meta_attribute_list, env);
}
- if (endpoint_ref->extension_list)
+ if(endpoint_ref->extension_list)
{
axutil_array_list_free(endpoint_ref->extension_list, env);
}
@@ -230,20 +228,19 @@
{
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- if (!(endpoint_ref->ref_param_list))
+ if(!(endpoint_ref->ref_param_list))
{
endpoint_ref->ref_param_list = axutil_array_list_create(env, 0);
- if (!(endpoint_ref->ref_param_list))
+ if(!(endpoint_ref->ref_param_list))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return AXIS2_FAILURE;
}
}
- if (endpoint_ref->ref_param_list && ref_param_node)
+ if(endpoint_ref->ref_param_list && ref_param_node)
{
- return axutil_array_list_add(endpoint_ref->ref_param_list, env,
- ref_param_node);
+ return axutil_array_list_add(endpoint_ref->ref_param_list, env, ref_param_node);
}
return AXIS2_FAILURE;
@@ -257,20 +254,19 @@
{
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- if (!(endpoint_ref->metadata_list))
+ if(!(endpoint_ref->metadata_list))
{
endpoint_ref->metadata_list = axutil_array_list_create(env, 0);
- if (!(endpoint_ref->metadata_list))
+ if(!(endpoint_ref->metadata_list))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return AXIS2_FAILURE;
}
}
- if (endpoint_ref->metadata_list && meta_data_node)
+ if(endpoint_ref->metadata_list && meta_data_node)
{
- return axutil_array_list_add(endpoint_ref->metadata_list, env,
- meta_data_node);
+ return axutil_array_list_add(endpoint_ref->metadata_list, env, meta_data_node);
}
return AXIS2_FAILURE;
@@ -308,20 +304,19 @@
{
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- if (!(endpoint_ref->ref_attribute_list))
+ if(!(endpoint_ref->ref_attribute_list))
{
endpoint_ref->ref_attribute_list = axutil_array_list_create(env, 0);
- if (!(endpoint_ref->ref_attribute_list))
+ if(!(endpoint_ref->ref_attribute_list))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return AXIS2_FAILURE;
}
}
- if (endpoint_ref->ref_attribute_list && attr)
+ if(endpoint_ref->ref_attribute_list && attr)
{
- return axutil_array_list_add(endpoint_ref->ref_attribute_list, env,
- attr);
+ return axutil_array_list_add(endpoint_ref->ref_attribute_list, env, attr);
}
return AXIS2_FAILURE;
@@ -335,20 +330,19 @@
{
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- if (!(endpoint_ref->meta_attribute_list))
+ if(!(endpoint_ref->meta_attribute_list))
{
endpoint_ref->meta_attribute_list = axutil_array_list_create(env, 0);
- if (!(endpoint_ref->meta_attribute_list))
+ if(!(endpoint_ref->meta_attribute_list))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return AXIS2_FAILURE;
}
}
- if (endpoint_ref->meta_attribute_list && attr)
+ if(endpoint_ref->meta_attribute_list && attr)
{
- return axutil_array_list_add(endpoint_ref->meta_attribute_list, env,
- attr);
+ return axutil_array_list_add(endpoint_ref->meta_attribute_list, env, attr);
}
return AXIS2_FAILURE;
@@ -362,20 +356,19 @@
{
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- if (!(endpoint_ref->extension_list))
+ if(!(endpoint_ref->extension_list))
{
endpoint_ref->extension_list = axutil_array_list_create(env, 0);
- if (!(endpoint_ref->extension_list))
+ if(!(endpoint_ref->extension_list))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return AXIS2_FAILURE;
}
}
- if (endpoint_ref->extension_list && extension_node)
+ if(endpoint_ref->extension_list && extension_node)
{
- return axutil_array_list_add(endpoint_ref->extension_list, env,
- extension_node);
+ return axutil_array_list_add(endpoint_ref->extension_list, env, extension_node);
}
return AXIS2_FAILURE;
Modified: webservices/axis2/trunk/c/src/core/addr/msg_info_headers.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/addr/msg_info_headers.c?rev=805347&r1=805346&r2=805347&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/addr/msg_info_headers.c (original)
+++ webservices/axis2/trunk/c/src/core/addr/msg_info_headers.c Tue Aug 18 10:15:49 2009
@@ -1,4 +1,3 @@
-
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
@@ -32,7 +31,7 @@
axis2_relates_to_t *relates_to;
/** Identifies the intended receiver for replies to the message,
- if this is set, none and anonymous settings are ignored */
+ if this is set, none and anonymous settings are ignored */
axis2_endpoint_ref_t *reply_to;
/** reply to should be none */
@@ -42,7 +41,7 @@
axis2_bool_t reply_to_anonymous;
/** identifies the intended receiver for faults related to the message
- if this is set, none and anonymous settings are ignored */
+ if this is set, none and anonymous settings are ignored */
axis2_endpoint_ref_t *fault_to;
/** fault to should be none */
@@ -69,10 +68,9 @@
{
axis2_msg_info_headers_t *msg_info_headers = NULL;
- msg_info_headers =
- AXIS2_MALLOC(env->allocator, sizeof(axis2_msg_info_headers_t));
+ msg_info_headers = AXIS2_MALLOC(env->allocator, sizeof(axis2_msg_info_headers_t));
- if (!msg_info_headers)
+ if(!msg_info_headers)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
@@ -91,15 +89,15 @@
msg_info_headers->message_id = NULL;
msg_info_headers->ref_params = NULL;
- if (to)
+ if(to)
{
msg_info_headers->to = to;
}
- if (action)
+ if(action)
{
msg_info_headers->action = axutil_strdup(env, action);
- if (!(msg_info_headers->action))
+ if(!(msg_info_headers->action))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
axis2_msg_info_headers_free(msg_info_headers, env);
@@ -129,9 +127,9 @@
const axutil_env_t * env,
axis2_endpoint_ref_t * to)
{
- if (msg_info_headers->to && to) /* if the incoming to is NULL,
- we consider that to be a reset,
- so don't free */
+ if(msg_info_headers->to && to) /* if the incoming to is NULL,
+ we consider that to be a reset,
+ so don't free */
{
axis2_endpoint_ref_free(msg_info_headers->to, env);
msg_info_headers->to = NULL;
@@ -208,12 +206,12 @@
const axutil_env_t * env,
const axis2_char_t * action)
{
- if (msg_info_headers->action)
+ if(msg_info_headers->action)
{
AXIS2_FREE(env->allocator, msg_info_headers->action);
msg_info_headers->action = NULL;
}
- if (action)
+ if(action)
{
msg_info_headers->action = axutil_strdup(env, action);
}
@@ -234,16 +232,16 @@
const axutil_env_t * env,
const axis2_char_t * message_id)
{
- if (msg_info_headers->message_id)
+ if(msg_info_headers->message_id)
{
AXIS2_FREE(env->allocator, msg_info_headers->message_id);
msg_info_headers->message_id = NULL;
}
- if (message_id)
+ if(message_id)
{
msg_info_headers->message_id = axutil_stracat(env, AXIS2_MESSAGE_ID_PREFIX, message_id);
- if (!(msg_info_headers->message_id))
+ if(!(msg_info_headers->message_id))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return AXIS2_FAILURE;
@@ -259,17 +257,17 @@
const axutil_env_t * env,
const axis2_char_t * message_id)
{
- if (msg_info_headers->message_id)
+ if(msg_info_headers->message_id)
{
AXIS2_FREE(env->allocator, msg_info_headers->message_id);
msg_info_headers->message_id = NULL;
}
- if (message_id)
+ if(message_id)
{
msg_info_headers->message_id = axutil_strdup(env, message_id);
-
- if (!(msg_info_headers->message_id))
+
+ if(!(msg_info_headers->message_id))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return AXIS2_FAILURE;
@@ -293,9 +291,9 @@
const axutil_env_t * env,
axis2_relates_to_t * relates_to)
{
- if (msg_info_headers->relates_to)
+ if(msg_info_headers->relates_to)
{
- axis2_relates_to_free (msg_info_headers->relates_to, env);
+ axis2_relates_to_free(msg_info_headers->relates_to, env);
}
msg_info_headers->relates_to = relates_to;
return AXIS2_SUCCESS;
@@ -315,17 +313,16 @@
const axutil_env_t * env,
axiom_node_t * ref_param)
{
- if (!(msg_info_headers->ref_params))
+ if(!(msg_info_headers->ref_params))
{
msg_info_headers->ref_params = axutil_array_list_create(env, 10);
- if (!(msg_info_headers->ref_params))
+ if(!(msg_info_headers->ref_params))
return AXIS2_FAILURE;
}
- if (ref_param)
+ if(ref_param)
{
- return axutil_array_list_add(msg_info_headers->ref_params, env,
- ref_param);
+ return axutil_array_list_add(msg_info_headers->ref_params, env, ref_param);
}
return AXIS2_SUCCESS;
@@ -336,37 +333,37 @@
struct axis2_msg_info_headers *msg_info_headers,
const axutil_env_t * env)
{
- if (msg_info_headers->to)
+ if(msg_info_headers->to)
{
axis2_endpoint_ref_free(msg_info_headers->to, env);
}
- if (msg_info_headers->from)
+ if(msg_info_headers->from)
{
axis2_endpoint_ref_free(msg_info_headers->from, env);
}
- if (msg_info_headers->reply_to)
+ if(msg_info_headers->reply_to)
{
axis2_endpoint_ref_free(msg_info_headers->reply_to, env);
}
- if (msg_info_headers->relates_to)
+ if(msg_info_headers->relates_to)
{
axis2_relates_to_free(msg_info_headers->relates_to, env);
}
- if (msg_info_headers->fault_to)
+ if(msg_info_headers->fault_to)
{
axis2_endpoint_ref_free(msg_info_headers->fault_to, env);
}
- if (msg_info_headers->ref_params)
+ if(msg_info_headers->ref_params)
{
axutil_array_list_free(msg_info_headers->ref_params, env);
}
- if (msg_info_headers->action)
+ if(msg_info_headers->action)
{
AXIS2_FREE(env->allocator, msg_info_headers->action);
}
- if (msg_info_headers->message_id)
+ if(msg_info_headers->message_id)
{
AXIS2_FREE(env->allocator, msg_info_headers->message_id);
}
Modified: webservices/axis2/trunk/c/src/core/addr/relates_to.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/addr/relates_to.c?rev=805347&r1=805346&r2=805347&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/addr/relates_to.c (original)
+++ webservices/axis2/trunk/c/src/core/addr/relates_to.c Tue Aug 18 10:15:49 2009
@@ -1,4 +1,3 @@
-
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
@@ -40,7 +39,7 @@
AXIS2_ENV_CHECK(env, NULL);
relates_to = AXIS2_MALLOC(env->allocator, sizeof(axis2_relates_to_t));
- if (!relates_to)
+ if(!relates_to)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
@@ -49,10 +48,10 @@
relates_to->value = NULL;
relates_to->relationship_type = NULL;
- if (value)
+ if(value)
{
relates_to->value = axutil_strdup(env, value);
- if (!(relates_to->value))
+ if(!(relates_to->value))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
axis2_relates_to_free(relates_to, env);
@@ -60,10 +59,10 @@
}
}
- if (relationship_type)
+ if(relationship_type)
{
relates_to->relationship_type = axutil_strdup(env, relationship_type);
- if (!(relates_to->relationship_type))
+ if(!(relates_to->relationship_type))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
axis2_relates_to_free(relates_to, env);
@@ -90,15 +89,15 @@
{
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- if (relates_to->value)
+ if(relates_to->value)
{
AXIS2_FREE(env->allocator, relates_to->value);
}
- if (value)
+ if(value)
{
- relates_to->value = (axis2_char_t *) axutil_strdup(env, value);
- if (!(relates_to->value))
+ relates_to->value = (axis2_char_t *)axutil_strdup(env, value);
+ if(!(relates_to->value))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return AXIS2_FAILURE;
@@ -124,16 +123,15 @@
{
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
- if (relates_to->relationship_type)
+ if(relates_to->relationship_type)
{
AXIS2_FREE(env->allocator, relates_to->relationship_type);
}
- if (relationship_type)
+ if(relationship_type)
{
- relates_to->relationship_type =
- (axis2_char_t *) axutil_strdup(env, relationship_type);
- if (!(relates_to->relationship_type))
+ relates_to->relationship_type = (axis2_char_t *)axutil_strdup(env, relationship_type);
+ if(!(relates_to->relationship_type))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return AXIS2_FAILURE;
@@ -150,12 +148,12 @@
{
AXIS2_ENV_CHECK(env, void);
- if (relates_to->value)
+ if(relates_to->value)
{
AXIS2_FREE(env->allocator, relates_to->value);
}
- if (relates_to->relationship_type)
+ if(relates_to->relationship_type)
{
AXIS2_FREE(env->allocator, relates_to->relationship_type);
}
Modified: webservices/axis2/trunk/c/src/core/addr/svc_name.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/addr/svc_name.c?rev=805347&r1=805346&r2=805347&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/addr/svc_name.c (original)
+++ webservices/axis2/trunk/c/src/core/addr/svc_name.c Tue Aug 18 10:15:49 2009
@@ -1,4 +1,3 @@
-
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
@@ -38,7 +37,7 @@
axis2_svc_name_t *svc_name = NULL;
svc_name = AXIS2_MALLOC(env->allocator, sizeof(axis2_svc_name_t));
- if (!svc_name)
+ if(!svc_name)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
return NULL;
@@ -47,10 +46,10 @@
svc_name->qname = NULL;
svc_name->endpoint_name = NULL;
- if (qname)
+ if(qname)
{
- svc_name->qname = axutil_qname_clone((axutil_qname_t *) qname, env);
- if (!(svc_name->qname))
+ svc_name->qname = axutil_qname_clone((axutil_qname_t *)qname, env);
+ if(!(svc_name->qname))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
axis2_svc_name_free(svc_name, env);
@@ -58,10 +57,10 @@
}
}
- if (endpoint_name)
+ if(endpoint_name)
{
svc_name->endpoint_name = axutil_strdup(env, endpoint_name);
- if (!(svc_name->endpoint_name))
+ if(!(svc_name->endpoint_name))
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
axis2_svc_name_free(svc_name, env);
@@ -86,15 +85,15 @@
const axutil_env_t * env,
const axutil_qname_t * qname)
{
- if (svc_name->qname)
+ if(svc_name->qname)
{
axutil_qname_free(svc_name->qname, env);
}
- if (qname)
+ if(qname)
{
- svc_name->qname = axutil_qname_clone((axutil_qname_t *) qname, env);
- if (!(svc_name->qname))
+ svc_name->qname = axutil_qname_clone((axutil_qname_t *)qname, env);
+ if(!(svc_name->qname))
return AXIS2_FAILURE;
}
@@ -115,15 +114,15 @@
const axutil_env_t * env,
const axis2_char_t * endpoint_name)
{
- if (svc_name->endpoint_name)
+ if(svc_name->endpoint_name)
{
AXIS2_FREE(env->allocator, svc_name->endpoint_name);
}
- if (endpoint_name)
+ if(endpoint_name)
{
svc_name->endpoint_name = axutil_strdup(env, endpoint_name);
- if (!(svc_name->endpoint_name))
+ if(!(svc_name->endpoint_name))
return AXIS2_FAILURE;
}
@@ -135,12 +134,12 @@
struct axis2_svc_name *svc_name,
const axutil_env_t * env)
{
- if (svc_name->qname)
+ if(svc_name->qname)
{
axutil_qname_free(svc_name->qname, env);
}
- if (svc_name->endpoint_name)
+ if(svc_name->endpoint_name)
{
AXIS2_FREE(env->allocator, svc_name->endpoint_name);
}
Modified: webservices/axis2/trunk/c/src/core/clientapi/async_result.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/clientapi/async_result.c?rev=805347&r1=805346&r2=805347&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/clientapi/async_result.c (original)
+++ webservices/axis2/trunk/c/src/core/clientapi/async_result.c Tue Aug 18 10:15:49 2009
@@ -1,4 +1,3 @@
-
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
@@ -37,7 +36,7 @@
AXIS2_ENV_CHECK(env, NULL);
async_result = AXIS2_MALLOC(env->allocator, sizeof(axis2_async_result_t));
- if (!async_result)
+ if(!async_result)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "No memory. Cannot create asynchronous result.");
@@ -46,9 +45,9 @@
async_result->result = NULL;
- if (result)
+ if(result)
{
- async_result->result = result; /* shallow copy */
+ async_result->result = result; /* shallow copy */
}
return async_result;
@@ -59,7 +58,7 @@
axis2_async_result_t * async_result,
const axutil_env_t * env)
{
- if (async_result->result)
+ if(async_result->result)
{
return axis2_msg_ctx_get_soap_envelope(async_result->result, env);
}
Modified: webservices/axis2/trunk/c/src/core/clientapi/callback.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/clientapi/callback.c?rev=805347&r1=805346&r2=805347&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/clientapi/callback.c (original)
+++ webservices/axis2/trunk/c/src/core/clientapi/callback.c Tue Aug 18 10:15:49 2009
@@ -1,4 +1,3 @@
-
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
@@ -44,10 +43,12 @@
* @param env pointer to environment struct
* @return AXIS2_SUCCESS on success, else AXIS2_FAILURE
*/
- axis2_status_t(
- AXIS2_CALL * on_complete) (
- axis2_callback_t * callback,
- const axutil_env_t * env);
+ axis2_status_t
+ (
+ AXIS2_CALL * on_complete)
+ (
+ axis2_callback_t * callback,
+ const axutil_env_t * env);
/**
* This function is called by report_error.
@@ -58,11 +59,12 @@
* @param exception error code representing the error
* @return AXIS2_SUCCESS on success, else AXIS2_FAILURE
*/
- axis2_status_t(
- AXIS2_CALL * on_error) (
- axis2_callback_t * callback,
- const axutil_env_t * env,
- const int exception);
+ axis2_status_t
+ (
+ AXIS2_CALL * on_error)
+( axis2_callback_t * callback,
+const axutil_env_t * env,
+const int exception);
};
static axis2_status_t AXIS2_CALL axis2_callback_on_complete(
@@ -83,7 +85,7 @@
AXIS2_ENV_CHECK(env, NULL);
callback = AXIS2_MALLOC(env->allocator, sizeof(axis2_callback_t));
- if (!callback)
+ if(!callback)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "No memory. Cannot create callback.");
@@ -98,8 +100,7 @@
callback->on_complete = axis2_callback_on_complete;
callback->on_error = axis2_callback_on_error;
- callback->mutex = axutil_thread_mutex_create(env->allocator,
- AXIS2_THREAD_MUTEX_DEFAULT);
+ callback->mutex = axutil_thread_mutex_create(env->allocator, AXIS2_THREAD_MUTEX_DEFAULT);
return callback;
}
@@ -111,8 +112,7 @@
{
axis2_status_t status = AXIS2_FAILURE;
- axis2_callback_set_envelope(callback, env,
- axis2_async_result_get_envelope(result, env));
+ axis2_callback_set_envelope(callback, env, axis2_async_result_get_envelope(result, env));
status = callback->on_complete(callback, env);
return status;
@@ -187,7 +187,7 @@
axis2_callback_t * callback,
const axutil_env_t * env)
{
- if (callback->mutex)
+ if(callback->mutex)
{
axutil_thread_mutex_destroy(callback->mutex);
}
@@ -200,7 +200,7 @@
axis2_callback_t * callback,
void *data)
{
- callback->data = (void *) data;
+ callback->data = (void *)data;
return AXIS2_SUCCESS;
}
Modified: webservices/axis2/trunk/c/src/core/clientapi/callback_recv.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/clientapi/callback_recv.c?rev=805347&r1=805346&r2=805347&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/clientapi/callback_recv.c (original)
+++ webservices/axis2/trunk/c/src/core/clientapi/callback_recv.c Tue Aug 18 10:15:49 2009
@@ -1,4 +1,3 @@
-
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
@@ -47,7 +46,7 @@
callback_recv = AXIS2_MALLOC(env->allocator, sizeof(axis2_callback_recv_t));
- if (!callback_recv)
+ if(!callback_recv)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "No memory. Cannot create callback receive.");
@@ -60,24 +59,22 @@
callback_recv->mutex = NULL;
callback_recv->base = axis2_msg_recv_create(env);
- if (!callback_recv->base)
+ if(!callback_recv->base)
{
axis2_callback_recv_free(callback_recv, env);
return NULL;
}
axis2_msg_recv_set_derived(callback_recv->base, env, callback_recv);
- axis2_msg_recv_set_receive(callback_recv->base, env,
- axis2_callback_recv_receive);
+ axis2_msg_recv_set_receive(callback_recv->base, env, axis2_callback_recv_receive);
callback_recv->callback_map = axutil_hash_make(env);
- if (!callback_recv->callback_map)
+ if(!callback_recv->callback_map)
{
axis2_callback_recv_free(callback_recv, env);
return NULL;
}
- callback_recv->mutex = axutil_thread_mutex_create(env->allocator,
- AXIS2_THREAD_MUTEX_DEFAULT);
+ callback_recv->mutex = axutil_thread_mutex_create(env->allocator, AXIS2_THREAD_MUTEX_DEFAULT);
return callback_recv;
}
@@ -95,34 +92,34 @@
axis2_callback_recv_t * callback_recv,
const axutil_env_t * env)
{
- if (callback_recv->mutex)
+ if(callback_recv->mutex)
{
axutil_thread_mutex_destroy(callback_recv->mutex);
}
- if (callback_recv->callback_map)
+ if(callback_recv->callback_map)
{
axutil_hash_index_t *hi = NULL;
const void *key = NULL;
void *val = NULL;
- for (hi = axutil_hash_first(callback_recv->callback_map, env); hi;
- hi = axutil_hash_next(env, hi))
+ for(hi = axutil_hash_first(callback_recv->callback_map, env); hi; hi = axutil_hash_next(
+ env, hi))
{
axutil_hash_this(hi, &key, NULL, &val);
- if (key)
- AXIS2_FREE(env->allocator, (char *) key);
+ if(key)
+ AXIS2_FREE(env->allocator, (char *)key);
}
axutil_hash_free(callback_recv->callback_map, env);
}
- if (callback_recv->base && callback_recv->base_deep_copy)
+ if(callback_recv->base && callback_recv->base_deep_copy)
{
axis2_msg_recv_free(callback_recv->base, env);
}
- if (callback_recv)
+ if(callback_recv)
{
AXIS2_FREE(env->allocator, callback_recv);
}
@@ -135,11 +132,10 @@
const axis2_char_t * msg_id,
axis2_callback_t * callback)
{
- if (msg_id)
+ if(msg_id)
{
axis2_char_t *mid = axutil_strdup(env, msg_id);
- axutil_hash_set(callback_recv->callback_map,
- mid, AXIS2_HASH_KEY_STRING, callback);
+ axutil_hash_set(callback_recv->callback_map, mid, AXIS2_HASH_KEY_STRING, callback);
}
return AXIS2_SUCCESS;
}
@@ -164,23 +160,20 @@
callback_recv = axis2_msg_recv_get_derived(msg_recv, env);
msg_info_headers = axis2_msg_ctx_get_msg_info_headers(msg_ctx, env);
- if (msg_info_headers)
+ if(msg_info_headers)
{
- relates_to =
- axis2_msg_info_headers_get_relates_to(msg_info_headers, env);
- if (relates_to)
+ relates_to = axis2_msg_info_headers_get_relates_to(msg_info_headers, env);
+ if(relates_to)
{
- const axis2_char_t *msg_id =
- axis2_relates_to_get_value(relates_to, env);
- if (msg_id)
+ const axis2_char_t *msg_id = axis2_relates_to_get_value(relates_to, env);
+ if(msg_id)
{
axis2_async_result_t *result = NULL;
- axis2_callback_t *callback = (axis2_callback_t *)
- axutil_hash_get(callback_recv->callback_map, msg_id,
- AXIS2_HASH_KEY_STRING);
+ axis2_callback_t *callback = (axis2_callback_t *)axutil_hash_get(
+ callback_recv->callback_map, msg_id, AXIS2_HASH_KEY_STRING);
result = axis2_async_result_create(env, msg_ctx);
- if (callback && result)
+ if(callback && result)
{
axis2_callback_invoke_on_complete(callback, env, result);
axis2_callback_set_complete(callback, env, AXIS2_TRUE);
@@ -188,7 +181,7 @@
}
axis2_async_result_free(result, env);
- if (callback && result)
+ if(callback && result)
return AXIS2_SUCCESS;
}
}
Modified: webservices/axis2/trunk/c/src/core/clientapi/listener_manager.c
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/c/src/core/clientapi/listener_manager.c?rev=805347&r1=805346&r2=805347&view=diff
==============================================================================
--- webservices/axis2/trunk/c/src/core/clientapi/listener_manager.c (original)
+++ webservices/axis2/trunk/c/src/core/clientapi/listener_manager.c Tue Aug 18 10:15:49 2009
@@ -1,4 +1,3 @@
-
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
@@ -62,10 +61,9 @@
AXIS2_ENV_CHECK(env, NULL);
- listener_manager =
- AXIS2_MALLOC(env->allocator, sizeof(axis2_listener_manager_t));
+ listener_manager = AXIS2_MALLOC(env->allocator, sizeof(axis2_listener_manager_t));
- if (!listener_manager)
+ if(!listener_manager)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "No memory. Cannot create listener manager.");
@@ -74,7 +72,7 @@
listener_manager->conf_ctx = NULL;
- for (i = 0; i < AXIS2_TRANSPORT_ENUM_MAX; i++)
+ for(i = 0; i < AXIS2_TRANSPORT_ENUM_MAX; i++)
{
listener_manager->listener_map[i] = NULL;
}
@@ -93,14 +91,14 @@
AXIS2_PARAM_CHECK(env->error, conf_ctx, AXIS2_FAILURE);
- if (listener_manager->conf_ctx)
+ if(listener_manager->conf_ctx)
{
- if (conf_ctx != listener_manager->conf_ctx)
+ if(conf_ctx != listener_manager->conf_ctx)
{
- AXIS2_ERROR_SET(env->error,
- AXIS2_ERROR_CLIENT_SIDE_SUPPORT_ONLY_ONE_CONF_CTX,
- AXIS2_FAILURE);
- AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "Only one configuration context is supported at client side.");
+ AXIS2_ERROR_SET(env->error, AXIS2_ERROR_CLIENT_SIDE_SUPPORT_ONLY_ONE_CONF_CTX,
+ AXIS2_FAILURE);
+ AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI,
+ "Only one configuration context is supported at client side.");
return AXIS2_FAILURE;
}
}
@@ -111,7 +109,7 @@
tl_state = listener_manager->listener_map[transport];
- if (!tl_state)
+ if(!tl_state)
{
/*means this transport not yet started, start the transport */
axis2_transport_in_desc_t *transport_in = NULL;
@@ -119,23 +117,23 @@
axis2_transport_receiver_t *listener = NULL;
conf = axis2_conf_ctx_get_conf(conf_ctx, env);
- if (conf)
+ if(conf)
{
transport_in = axis2_conf_get_transport_in(conf, env, transport);
- if (transport_in)
+ if(transport_in)
{
listener = axis2_transport_in_desc_get_recv(transport_in, env);
- if (listener)
+ if(listener)
{
axutil_thread_t *worker_thread = NULL;
axis2_listener_manager_worker_func_args_t *arg_list = NULL;
arg_list = AXIS2_MALLOC(env->allocator,
- sizeof
- (axis2_listener_manager_worker_func_args_t));
- if (!arg_list)
+ sizeof(axis2_listener_manager_worker_func_args_t));
+ if(!arg_list)
{
AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
- AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "No memory. Cannot create listener manager worker function arguments.");
+ AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI,
+ "No memory. Cannot create listener manager worker function arguments.");
return AXIS2_FAILURE;
}
arg_list->env = env;
@@ -145,43 +143,41 @@
if (env->thread_pool)
{
worker_thread =
- axutil_thread_pool_get_thread(env->thread_pool,
- axis2_listener_manager_worker_func,
- (void *) arg_list);
+ axutil_thread_pool_get_thread(env->thread_pool,
+ axis2_listener_manager_worker_func,
+ (void *) arg_list);
if (!worker_thread)
{
AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI,
- "Thread creation failed"
- "Invoke non blocking failed");
+ "Thread creation failed"
+ "Invoke non blocking failed");
}
else
{
axutil_thread_pool_thread_detach(env->thread_pool,
- worker_thread);
+ worker_thread);
}
}
else
{
AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI,
- "Thread pool not set in environment."
- " Cannot invoke call non blocking");
+ "Thread pool not set in environment."
+ " Cannot invoke call non blocking");
}
#else
- AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI,
- "Threading not enabled."
- " Cannot start separate listener");
+ AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "Threading not enabled."
+ " Cannot start separate listener");
return AXIS2_FAILURE;
#endif
tl_state = AXIS2_MALLOC(env->allocator,
- sizeof
- (axis2_transport_listener_state_t));
+ sizeof(axis2_transport_listener_state_t));
- if (!tl_state)
+ if(!tl_state)
{
- AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY,
- AXIS2_FAILURE);
- AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "No memory. Cannot create transport listener state.");
+ AXIS2_ERROR_SET(env->error, AXIS2_ERROR_NO_MEMORY, AXIS2_FAILURE);
+ AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI,
+ "No memory. Cannot create transport listener state.");
}
else
{
@@ -194,7 +190,7 @@
}
}
- if (tl_state)
+ if(tl_state)
{
tl_state->waiting_calls++;
return AXIS2_SUCCESS;
@@ -214,13 +210,13 @@
tl_state = listener_manager->listener_map[transport];
- if (tl_state)
+ if(tl_state)
{
tl_state->waiting_calls--;
- if (tl_state->waiting_calls == 0)
+ if(tl_state->waiting_calls == 0)
{
status = axis2_transport_receiver_stop(tl_state->listener, env);
- if (status == AXIS2_SUCCESS)
+ if(status == AXIS2_SUCCESS)
listener_manager->listener_map[transport] = NULL;
}
}
@@ -238,10 +234,9 @@
axis2_transport_listener_state_t *tl_state = NULL;
tl_state = listener_manager->listener_map[transport];
- if (tl_state)
+ if(tl_state)
{
- return axis2_transport_receiver_get_reply_to_epr(tl_state->listener,
- env, svc_name);
+ return axis2_transport_receiver_get_reply_to_epr(tl_state->listener, env, svc_name);
}
return NULL;
}
@@ -253,9 +248,9 @@
{
int i = 0;
- for (i = 0; i < AXIS2_TRANSPORT_ENUM_MAX; i++)
+ for(i = 0; i < AXIS2_TRANSPORT_ENUM_MAX; i++)
{
- if (listener_manager->listener_map[i])
+ if(listener_manager->listener_map[i])
AXIS2_FREE(env->allocator, listener_manager->listener_map[i]);
}
@@ -278,15 +273,15 @@
axis2_listener_manager_worker_func_args_t *args_list = NULL;
const axutil_env_t *th_env = NULL;
- args_list = (axis2_listener_manager_worker_func_args_t *) data;
- if (!args_list)
+ args_list = (axis2_listener_manager_worker_func_args_t *)data;
+ if(!args_list)
return NULL;
th_env = axutil_init_thread_env(args_list->env);
/* Start the protocol server. For examlle if protocol is http axis2_http_server_start function
* of the axis2_http_receiver is called.
*/
- if (args_list->listener)
+ if(args_list->listener)
{
axis2_transport_receiver_start(args_list->listener, th_env);
}