Author: damitha
Date: Sat May 24 18:50:22 2008
New Revision: 659889
URL: http://svn.apache.org/viewvc?rev=659889&view=rev
Log:
Sending CS in the same thread as client thread.
Modified:
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/create_seq_res_msg_processor.c
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/workers/sender_worker.c
Modified:
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c?rev=659889&r1=659888&r2=659889&view=diff
==============================================================================
---
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c
(original)
+++
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c
Sat May 24 18:50:22 2008
@@ -1794,13 +1794,12 @@
sandesha2_msg_ctx_free(create_seq_rm_msg, env);
}
- /*if(!axis2_engine_resume_send(engine, env, create_seq_msg))*/
if(axis2_engine_send(engine, env, create_seq_msg))
{
if(sandesha2_app_msg_processor_check_for_create_seq_response(env,
create_seq_msg))
{
- /*status =
sandesha2_app_msg_processor_process_create_seq_response(env, create_seq_msg,
- storage_mgr);*/
+ status =
sandesha2_app_msg_processor_process_create_seq_response(env, create_seq_msg,
+ storage_mgr);
}
}
else
@@ -1837,7 +1836,6 @@
out_seq_bean = sandesha2_seq_property_mgr_retrieve(seq_prop_mgr, env,
internal_seq_id,
SANDESHA2_SEQ_PROP_OUT_SEQ_ID);
- AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI,
"came3*********************************");
}
Modified:
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/create_seq_res_msg_processor.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/create_seq_res_msg_processor.c?rev=659889&r1=659888&r2=659889&view=diff
==============================================================================
---
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/create_seq_res_msg_processor.c
(original)
+++
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/create_seq_res_msg_processor.c
Sat May 24 18:50:22 2008
@@ -318,8 +318,6 @@
sandesha2_seq_property_mgr_insert(seq_prop_mgr, env, int_seq_bean);
accept = sandesha2_create_seq_res_get_accept(csr_part, env);
- AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI,
"came1*********************************");
-
if(accept)
{
sandesha2_seq_property_bean_t *special_int_seq_bean = NULL;
@@ -342,8 +340,6 @@
axis2_msg_ctx_t *create_seq_msg = NULL;
axis2_char_t *acks_to = NULL;
- AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI,
"came2*********************************");
-
next_msg_mgr = sandesha2_permanent_next_msg_mgr_create(env, dbname);
offerd_seq_bean = sandesha2_seq_property_mgr_retrieve(seq_prop_mgr,
env,
internal_seq_id, SANDESHA2_SEQ_PROP_OFFERED_SEQ);
Modified:
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/workers/sender_worker.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/workers/sender_worker.c?rev=659889&r1=659888&r2=659889&view=diff
==============================================================================
---
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/workers/sender_worker.c
(original)
+++
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/workers/sender_worker.c
Sat May 24 18:50:22 2008
@@ -487,9 +487,7 @@
soap_ns_uri);
if(!res_envelope)
{
- if(msg_type == SANDESHA2_MSG_TYPE_CREATE_SEQ || msg_type ==
- SANDESHA2_MSG_TYPE_TERMINATE_SEQ || msg_type ==
- SANDESHA2_MSG_TYPE_ACK)
+ if(msg_type == SANDESHA2_MSG_TYPE_TERMINATE_SEQ || msg_type ==
SANDESHA2_MSG_TYPE_ACK)
{
/* These are Sandesha2/C created messages. Also because there
is
* no response for these messages we can deduce that they are
@@ -634,15 +632,13 @@
axis2_engine_free(engine, env);
}
}
- if(msg_type == SANDESHA2_MSG_TYPE_CREATE_SEQ || msg_type ==
- SANDESHA2_MSG_TYPE_TERMINATE_SEQ || msg_type == SANDESHA2_MSG_TYPE_ACK)
+ if(msg_type == SANDESHA2_MSG_TYPE_TERMINATE_SEQ || msg_type ==
SANDESHA2_MSG_TYPE_ACK)
{
axis2_op_ctx_t *op_ctx = axis2_msg_ctx_get_op_ctx(msg_ctx,
env);
axis2_op_ctx_free(op_ctx, env);
}
- if(msg_type == SANDESHA2_MSG_TYPE_CREATE_SEQ || msg_type ==
- SANDESHA2_MSG_TYPE_APPLICATION)
+ if(msg_type == SANDESHA2_MSG_TYPE_APPLICATION)
{
axis2_op_ctx_t *op_ctx = axis2_msg_ctx_get_op_ctx(res_msg_ctx, env);
axis2_op_ctx_free(op_ctx, env);
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
