You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by da...@apache.org on 2007/11/23 06:10:46 UTC
svn commit: r597548 - in /webservices/sandesha/trunk/c:
include/sandesha2_terminate_mgr.h src/msgprocessors/app_msg_processor.c
src/util/seq_mgr.c src/util/terminate_mgr.c
Author: damitha
Date: Thu Nov 22 21:10:45 2007
New Revision: 597548
URL: http://svn.apache.org/viewvc?rev=597548&view=rev
Log:
Adding more log messages
Modified:
webservices/sandesha/trunk/c/include/sandesha2_terminate_mgr.h
webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c
webservices/sandesha/trunk/c/src/util/seq_mgr.c
webservices/sandesha/trunk/c/src/util/terminate_mgr.c
Modified: webservices/sandesha/trunk/c/include/sandesha2_terminate_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_terminate_mgr.h?rev=597548&r1=597547&r2=597548&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_terminate_mgr.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_terminate_mgr.h Thu Nov 22 21:10:45 2007
@@ -69,7 +69,7 @@
sandesha2_terminate_mgr_terminate_sending_side(
const axutil_env_t *env,
axis2_conf_ctx_t *conf_ctx,
- axis2_char_t *internal_seq_id,
+ axis2_char_t *seq_id,
axis2_bool_t svr_side,
sandesha2_storage_mgr_t *storage_man);
Modified: webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c?rev=597548&r1=597547&r2=597548&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c Thu Nov 22 21:10:45 2007
@@ -553,7 +553,7 @@
axis2_char_t *str_seq_list = NULL;
axutil_array_list_add(incoming_seq_list, env, str_seq_id);
str_seq_list = sandesha2_utils_array_list_to_string(env,
- incoming_seq_list, SANDESHA2_ARRAY_LIST_STRING);
+ incoming_seq_list, SANDESHA2_ARRAY_LIST_STRING);
/* saving the property. */
sandesha2_seq_property_bean_set_value(incoming_seq_list_bean,
env, str_seq_list);
Modified: webservices/sandesha/trunk/c/src/util/seq_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/util/seq_mgr.c?rev=597548&r1=597547&r2=597548&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/util/seq_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/util/seq_mgr.c Thu Nov 22 21:10:45 2007
@@ -87,6 +87,8 @@
axis2_char_t *address = NULL;
axis2_char_t *reply_to_addr = NULL;
+ AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI,
+ "[sandesha2]Entry:sandesha2_seq_mgr_setup_new_seq");
seq_id = axutil_uuid_gen(env);
to = sandesha2_msg_ctx_get_to(create_seq_msg, env);
if(!to)
@@ -141,10 +143,10 @@
}
address = (axis2_char_t*)axis2_endpoint_ref_get_address(to, env);
reply_to_bean = sandesha2_seq_property_bean_create_with_data(env, seq_id,
- SANDESHA2_SEQ_PROP_REPLY_TO_EPR, address);
+ SANDESHA2_SEQ_PROP_REPLY_TO_EPR, address);
address = (axis2_char_t*)axis2_endpoint_ref_get_address(acks_to, env);
acks_to_bean = sandesha2_seq_property_bean_create_with_data(env, seq_id,
- SANDESHA2_SEQ_PROP_ACKS_TO_EPR, address);
+ SANDESHA2_SEQ_PROP_ACKS_TO_EPR, address);
sandesha2_seq_property_mgr_insert(seq_prop_mgr, env, received_msg_bean);
sandesha2_seq_property_mgr_insert(seq_prop_mgr, env, reply_to_bean);
sandesha2_seq_property_mgr_insert(seq_prop_mgr, env, acks_to_bean);
@@ -167,8 +169,8 @@
if(create_seq_msg_action == NULL)
{
AXIS2_ERROR_SET(env->error,
- SANDESHA2_ERROR_CREATE_SEQ_MSG_DOES_NOT_HAVE_WSA_ACTION_VALUE,
- AXIS2_FAILURE);
+ SANDESHA2_ERROR_CREATE_SEQ_MSG_DOES_NOT_HAVE_WSA_ACTION_VALUE,
+ AXIS2_FAILURE);
return NULL;
}
msg_rm_ns = sandesha2_iom_rm_element_get_namespace_value(
@@ -184,8 +186,8 @@
else
{
AXIS2_ERROR_SET(env->error,
- SANDESHA2_ERROR_CREATE_SEQ_MSG_DOES_NOT_HAVE_VALID_RM_NS_VALUE,
- AXIS2_FAILURE);
+ SANDESHA2_ERROR_CREATE_SEQ_MSG_DOES_NOT_HAVE_VALID_RM_NS_VALUE,
+ AXIS2_FAILURE);
return NULL;
}
spec_version_bean = sandesha2_seq_property_bean_create(env);
@@ -196,6 +198,8 @@
sandesha2_seq_property_mgr_insert(seq_prop_mgr,env, spec_version_bean);
/* TODO Get the SOAP version from the creaet sequence message */
+ AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI,
+ "[sandesha2]Entry:sandesha2_seq_mgr_setup_new_seq");
return seq_id;
}
Modified: webservices/sandesha/trunk/c/src/util/terminate_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/util/terminate_mgr.c?rev=597548&r1=597547&r2=597548&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/util/terminate_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/util/terminate_mgr.c Thu Nov 22 21:10:45 2007
@@ -297,6 +297,9 @@
axis2_char_t *value = axutil_array_list_get(all_seq_list, env, i);
if(0 == axutil_strcmp(value, seq_id))
{
+ AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI,
+ "[sandesha2]Removing seq id:%s from the all incoming "\
+ "sequence list", value);
axutil_array_list_remove(all_seq_list, env, i);
break;
}
@@ -334,9 +337,15 @@
{
highest_in_msg_key_str =
sandesha2_seq_property_bean_get_value(seq_prop_bean, env);
+ AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "[sandesha2] "\
+ "Removing the message context for the highest in "\
+ "message number");
sandesha2_storage_mgr_remove_msg_ctx(storage_mgr, env,
highest_in_msg_key_str);
}
+ AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "[sandesha2] Removing "\
+ "the sequence property named %s in the sequence %s", name,
+ seq_id);
sandesha2_seq_property_mgr_remove(seq_prop_mgr, env, seq_id, name);
}
}
@@ -350,7 +359,7 @@
sandesha2_terminate_mgr_terminate_sending_side(
const axutil_env_t *env,
axis2_conf_ctx_t *conf_ctx,
- axis2_char_t *internal_seq_id,
+ axis2_char_t *seq_id,
axis2_bool_t svr_side,
sandesha2_storage_mgr_t *storage_mgr)
{
@@ -359,16 +368,16 @@
AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI,
"[sandesha2]Entry:sandesha2_terminate_mgr_terminate_sending_side");
AXIS2_PARAM_CHECK(env->error, conf_ctx, AXIS2_FAILURE);
- AXIS2_PARAM_CHECK(env->error, internal_seq_id, AXIS2_FAILURE);
+ AXIS2_PARAM_CHECK(env->error, seq_id, AXIS2_FAILURE);
AXIS2_PARAM_CHECK(env->error, storage_mgr, AXIS2_FAILURE);
seq_prop_mgr = sandesha2_storage_mgr_get_seq_property_mgr(storage_mgr, env);
seq_term_bean = sandesha2_seq_property_bean_create_with_data(env,
- internal_seq_id, SANDESHA2_SEQ_PROP_SEQ_TERMINATED, AXIS2_VALUE_TRUE);
+ seq_id, SANDESHA2_SEQ_PROP_SEQ_TERMINATED, AXIS2_VALUE_TRUE);
sandesha2_seq_property_mgr_insert(seq_prop_mgr, env, seq_term_bean);
sandesha2_terminate_mgr_clean_sending_side_data(env, conf_ctx,
- internal_seq_id, svr_side, storage_mgr);
+ seq_id, svr_side, storage_mgr);
AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI,
"[sandesha2]Exit:sandesha2_terminate_mgr_terminate_sending_side");
return AXIS2_SUCCESS;
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org