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 2006/09/06 13:23:48 UTC
svn commit: r440689 - in /webservices/sandesha/trunk/c/src: core/Makefile.am
core/msg_ctx.c msgprocessors/app_msg_processor.c
msgprocessors/terminate_seq_msg_processor.c util/terminate_mgr.c
Author: damitha
Date: Wed Sep 6 04:23:47 2006
New Revision: 440689
URL: http://svn.apache.org/viewvc?view=rev&rev=440689
Log:
More bug fixes
Modified:
webservices/sandesha/trunk/c/src/core/Makefile.am
webservices/sandesha/trunk/c/src/core/msg_ctx.c
webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c
webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c
webservices/sandesha/trunk/c/src/util/terminate_mgr.c
Modified: webservices/sandesha/trunk/c/src/core/Makefile.am
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/core/Makefile.am?view=diff&rev=440689&r1=440688&r2=440689
==============================================================================
--- webservices/sandesha/trunk/c/src/core/Makefile.am (original)
+++ webservices/sandesha/trunk/c/src/core/Makefile.am Wed Sep 6 04:23:47 2006
@@ -1,7 +1,7 @@
prglibdir=$(prefix)/sandesha2
prglib_LTLIBRARIES = libsandesha2.la
-libsandesha2_la_SOURCES = msg_ctx.c\
+libsandesha2_la_SOURCES = sandesha2_msg_ctx.c\
mod_sandesha2.c\
msg_validator.c
Modified: webservices/sandesha/trunk/c/src/core/msg_ctx.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/core/msg_ctx.c?view=diff&rev=440689&r1=440688&r2=440689
==============================================================================
--- webservices/sandesha/trunk/c/src/core/msg_ctx.c (original)
+++ webservices/sandesha/trunk/c/src/core/msg_ctx.c Wed Sep 6 04:23:47 2006
@@ -659,8 +659,10 @@
}
axis2_status_t AXIS2_CALL
-sandesha2_msg_ctx_set_paused(sandesha2_msg_ctx_t *rm_msg_ctx,
- const axis2_env_t *env, axis2_bool_t paused)
+sandesha2_msg_ctx_set_paused(
+ sandesha2_msg_ctx_t *rm_msg_ctx,
+ const axis2_env_t *env,
+ axis2_bool_t paused)
{
sandesha2_msg_ctx_impl_t *msg_ctx_impl = NULL;
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
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?view=diff&rev=440689&r1=440688&r2=440689
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c Wed Sep 6 04:23:47 2006
@@ -399,13 +399,13 @@
SANDESHA2_SEQ_PROP_SERVER_COMPLETED_MESSAGES);
SANDESHA2_SEQ_PROPERTY_BEAN_SET_VALUE(msgs_bean, env, msgs_str);
}
- if(AXIS2_TRUE == sandesha2_app_msg_processor_msg_num_is_in_list(
+ /*if(AXIS2_TRUE == sandesha2_app_msg_processor_msg_num_is_in_list(
msg_processor, env, msgs_str, msg_no) &&
0 == AXIS2_STRCMP(SANDESHA2_QOS_DEFAULT_INVOCATION_TYPE,
SANDESHA2_QOS_EXACTLY_ONCE))
{
SANDESHA2_MSG_CTX_SET_PAUSED(rm_msg_ctx, env, AXIS2_TRUE);
- }
+ }*/
if(NULL != msgs_str && 0 < AXIS2_STRLEN(msgs_str))
msgs_str = axis2_strcat(env, msgs_str, ",", msg_num_str, NULL);
else
Modified: webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c?view=diff&rev=440689&r1=440688&r2=440689
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c Wed Sep 6 04:23:47 2006
@@ -65,41 +65,43 @@
/***************************** Function headers *******************************/
axis2_status_t AXIS2_CALL
sandesha2_terminate_seq_msg_processor_process_in_msg (
- sandesha2_msg_processor_t *msg_processor,
- const axis2_env_t *env,
- sandesha2_msg_ctx_t *rm_msg_ctx);
-
+ sandesha2_msg_processor_t *msg_processor,
+ const axis2_env_t *env,
+ sandesha2_msg_ctx_t *rm_msg_ctx);
+
axis2_status_t AXIS2_CALL
sandesha2_terminate_seq_msg_processor_process_out_msg(
- sandesha2_msg_processor_t *msg_processor,
- const axis2_env_t *env,
- sandesha2_msg_ctx_t *rm_msg_ctx);
+ sandesha2_msg_processor_t *msg_processor,
+ const axis2_env_t *env,
+ sandesha2_msg_ctx_t *rm_msg_ctx);
axis2_status_t AXIS2_CALL
sandesha2_terminate_seq_msg_processor_setup_highest_msg_nums(
- sandesha2_msg_processor_t *msg_processor,
- const axis2_env_t *env,
- axis2_conf_ctx_t *conf_ctx,
- sandesha2_storage_mgr_t *storage_man,
- axis2_char_t *seq_id,
- sandesha2_msg_ctx_t *rm_msg_ctx);
+ sandesha2_msg_processor_t *msg_processor,
+ const axis2_env_t *env,
+ axis2_conf_ctx_t *conf_ctx,
+ sandesha2_storage_mgr_t *storage_man,
+ axis2_char_t *seq_id,
+ sandesha2_msg_ctx_t *rm_msg_ctx);
axis2_status_t AXIS2_CALL
sandesha2_terminate_seq_msg_processor_add_terminate_seq_res(
- sandesha2_msg_processor_t *msg_processor,
- const axis2_env_t *env,
- sandesha2_msg_ctx_t *rm_msg_ctx,
- axis2_char_t *seq_id,
- sandesha2_storage_mgr_t *storage_man);
-
+ sandesha2_msg_processor_t *msg_processor,
+ const axis2_env_t *env,
+ sandesha2_msg_ctx_t *rm_msg_ctx,
+ axis2_char_t *seq_id,
+ sandesha2_storage_mgr_t *storage_man);
+
axis2_status_t AXIS2_CALL
-sandesha2_terminate_seq_msg_processor_free (sandesha2_msg_processor_t *element,
- const axis2_env_t *env);
+sandesha2_terminate_seq_msg_processor_free (
+ sandesha2_msg_processor_t *element,
+ const axis2_env_t *env);
/***************************** End of function headers ************************/
AXIS2_EXTERN sandesha2_msg_processor_t* AXIS2_CALL
-sandesha2_terminate_seq_msg_processor_create(const axis2_env_t *env)
+sandesha2_terminate_seq_msg_processor_create(
+ const axis2_env_t *env)
{
sandesha2_terminate_seq_msg_processor_impl_t *msg_proc_impl = NULL;
AXIS2_ENV_CHECK(env, NULL);
@@ -136,8 +138,9 @@
axis2_status_t AXIS2_CALL
-sandesha2_terminate_seq_msg_processor_free (sandesha2_msg_processor_t *msg_processor,
- const axis2_env_t *env)
+sandesha2_terminate_seq_msg_processor_free (
+ sandesha2_msg_processor_t *msg_processor,
+ const axis2_env_t *env)
{
sandesha2_terminate_seq_msg_processor_impl_t *msg_proc_impl = NULL;
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
@@ -173,6 +176,7 @@
AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
AXIS2_PARAM_CHECK(env->error, rm_msg_ctx, AXIS2_FAILURE);
+ printf("In terminate_seq_msg_processor\n");
msg_ctx = SANDESHA2_MSG_CTX_GET_MSG_CTX(rm_msg_ctx, env);
seq_ack = (sandesha2_seq_ack_t*)SANDESHA2_MSG_CTX_GET_MSG_PART(
@@ -351,11 +355,11 @@
axis2_status_t AXIS2_CALL
sandesha2_terminate_seq_msg_processor_add_terminate_seq_res(
- sandesha2_msg_processor_t *msg_processor,
- const axis2_env_t *env,
- sandesha2_msg_ctx_t *rm_msg_ctx,
- axis2_char_t *seq_id,
- sandesha2_storage_mgr_t *storage_man)
+ sandesha2_msg_processor_t *msg_processor,
+ const axis2_env_t *env,
+ sandesha2_msg_ctx_t *rm_msg_ctx,
+ axis2_char_t *seq_id,
+ sandesha2_storage_mgr_t *storage_man)
{
axis2_msg_ctx_t *msg_ctx = NULL;
axis2_msg_ctx_t *out_msg_ctx = NULL;
@@ -423,9 +427,9 @@
axis2_status_t AXIS2_CALL
sandesha2_terminate_seq_msg_processor_process_out_msg(
- sandesha2_msg_processor_t *msg_processor,
- const axis2_env_t *env,
- sandesha2_msg_ctx_t *rm_msg_ctx)
+ sandesha2_msg_processor_t *msg_processor,
+ const axis2_env_t *env,
+ sandesha2_msg_ctx_t *rm_msg_ctx)
{
axis2_msg_ctx_t *msg_ctx = NULL;
axis2_conf_ctx_t *conf_ctx = NULL;
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?view=diff&rev=440689&r1=440688&r2=440689
==============================================================================
--- webservices/sandesha/trunk/c/src/util/terminate_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/util/terminate_mgr.c Wed Sep 6 04:23:47 2006
@@ -604,6 +604,6 @@
engine = axis2_engine_create(env, conf_ctx);
- printf("came100********************************************\n");
return AXIS2_ENGINE_SEND(engine, env, msg_ctx1);
}
+
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org