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/04/30 08:33:22 UTC
svn commit: r533602 - in /webservices/sandesha/trunk/c/src/storage/mysql:
permanent_next_msg_mgr.c permanent_sender_mgr.c permanent_seq_property_mgr.c
Author: damitha
Date: Sun Apr 29 23:33:21 2007
New Revision: 533602
URL: http://svn.apache.org/viewvc?view=rev&rev=533602
Log:
Fixed minor bugs for windows
Modified:
webservices/sandesha/trunk/c/src/storage/mysql/permanent_next_msg_mgr.c
webservices/sandesha/trunk/c/src/storage/mysql/permanent_sender_mgr.c
webservices/sandesha/trunk/c/src/storage/mysql/permanent_seq_property_mgr.c
Modified: webservices/sandesha/trunk/c/src/storage/mysql/permanent_next_msg_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/mysql/permanent_next_msg_mgr.c?view=diff&rev=533602&r1=533601&r2=533602
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/mysql/permanent_next_msg_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/storage/mysql/permanent_next_msg_mgr.c Sun Apr 29 23:33:21 2007
@@ -265,9 +265,7 @@
seq_id = sandesha2_next_msg_bean_get_seq_id((sandesha2_rm_bean_t *) bean,
env);
- if(!seq_id) seq_id = "";
ref_msg_key = sandesha2_next_msg_bean_get_ref_msg_key(bean, env);
- if(!ref_msg_key) ref_msg_key = "";
polling_mode = sandesha2_next_msg_bean_is_polling_mode(bean, env);
msg_no = sandesha2_next_msg_bean_get_next_msg_no_to_process(bean, env);
@@ -275,6 +273,9 @@
AXIS2_PARAM_CHECK(env->error, bean, AXIS2_FALSE);
next_msg_mgr_impl = SANDESHA2_INTF_TO_IMPL(next_msg_mgr);
+ if(!seq_id) seq_id = "";
+ if(!ref_msg_key) ref_msg_key = "";
+
sprintf(sql_retrieve, "select seq_id, ref_msg_key, polling_mode, msg_no"\
" from next_msg where seq_id='%s';", seq_id);
sprintf(sql_update, "update next_msg set ref_msg_key='%s', polling_mode=%d"\
@@ -345,12 +346,12 @@
axis2_char_t *seq_id = sandesha2_next_msg_bean_get_seq_id((sandesha2_rm_bean_t *) bean,
env);
- if(!seq_id) seq_id = "";
ref_msg_key = sandesha2_next_msg_bean_get_ref_msg_key(bean, env);
- if(!ref_msg_key) ref_msg_key = "";
polling_mode = sandesha2_next_msg_bean_is_polling_mode(bean, env);
msg_no = sandesha2_next_msg_bean_get_next_msg_no_to_process(bean, env);
+ if(!seq_id) seq_id = "";
+ if(!ref_msg_key) ref_msg_key = "";
AXIS2_PARAM_CHECK(env->error, bean, AXIS2_FALSE);
next_msg_mgr_impl = SANDESHA2_INTF_TO_IMPL(next_msg_mgr);
Modified: webservices/sandesha/trunk/c/src/storage/mysql/permanent_sender_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/mysql/permanent_sender_mgr.c?view=diff&rev=533602&r1=533601&r2=533602
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/mysql/permanent_sender_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/storage/mysql/permanent_sender_mgr.c Sun Apr 29 23:33:21 2007
@@ -399,11 +399,8 @@
axis2_char_t *msg_id = sandesha2_sender_bean_get_msg_id((sandesha2_rm_bean_t *) bean,
env);
- if(!msg_id) msg_id = "";
axis2_char_t *msg_ctx_ref_key = sandesha2_sender_bean_get_msg_ctx_ref_key(bean, env);
- if(!msg_ctx_ref_key) msg_ctx_ref_key = "";
axis2_char_t *internal_seq_id = sandesha2_sender_bean_get_internal_seq_id(bean, env);
- if(!internal_seq_id) internal_seq_id = "";
int sent_count = sandesha2_sender_bean_get_sent_count(bean, env);
long msg_no = sandesha2_sender_bean_get_msg_no(bean, env);
axis2_bool_t send = sandesha2_sender_bean_is_send(bean, env);
@@ -411,15 +408,19 @@
long time_to_send = sandesha2_sender_bean_get_time_to_send(bean, env);
int msg_type = sandesha2_sender_bean_get_msg_type(bean, env);
axis2_char_t *seq_id = sandesha2_sender_bean_get_seq_id(bean, env);
- if(!seq_id) seq_id = "";
axis2_char_t *wsrm_anon_uri = sandesha2_sender_bean_get_wsrm_anon_uri(bean, env);
- if(!wsrm_anon_uri) wsrm_anon_uri = "";
axis2_char_t *to_address = sandesha2_sender_bean_get_to_address(bean, env);
- if(!to_address) to_address = "";
AXIS2_ENV_CHECK(env, AXIS2_FALSE);
AXIS2_PARAM_CHECK(env->error, bean, AXIS2_FALSE);
sender_mgr_impl = SANDESHA2_INTF_TO_IMPL(sender_mgr);
+
+ if(!msg_id) msg_id = "";
+ if(!msg_ctx_ref_key) msg_ctx_ref_key = "";
+ if(!internal_seq_id) internal_seq_id = "";
+ if(!seq_id) seq_id = "";
+ if(!wsrm_anon_uri) wsrm_anon_uri = "";
+ if(!to_address) to_address = "";
sprintf(sql_retrieve, "select msg_id, msg_ctx_ref_key, "\
"internal_seq_id, sent_count, msg_no, send, resend, time_to_send, "\
Modified: webservices/sandesha/trunk/c/src/storage/mysql/permanent_seq_property_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/mysql/permanent_seq_property_mgr.c?view=diff&rev=533602&r1=533601&r2=533602
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/mysql/permanent_seq_property_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/storage/mysql/permanent_seq_property_mgr.c Sun Apr 29 23:33:21 2007
@@ -269,18 +269,19 @@
sandesha2_permanent_seq_property_mgr_t *seq_prop_mgr_impl = NULL;
axis2_char_t *id = sandesha2_permanent_seq_property_mgr_get_id_with_bean(env, bean);
- if(!id) id = "";
axis2_char_t *seq_id = sandesha2_seq_property_bean_get_seq_id(bean, env);
- if(!seq_id) seq_id = "";
axis2_char_t *name = sandesha2_seq_property_bean_get_name(bean, env);
- if(!name) name = "";
axis2_char_t *value = sandesha2_seq_property_bean_get_value(bean, env);
- if(!value) value = "";
AXIS2_ENV_CHECK(env, AXIS2_FALSE);
AXIS2_PARAM_CHECK(env->error, bean, AXIS2_FALSE);
seq_prop_mgr_impl = SANDESHA2_INTF_TO_IMPL(seq_prop_mgr);
+ if(!id) id = "";
+ if(!seq_id) seq_id = "";
+ if(!name) name = "";
+ if(!value) value = "";
+
sprintf(sql_retrieve, "select seq_id, name, value from seq_property "\
"where id='%s'", id);
sprintf(sql_update, "update seq_property set seq_id='%s', name='%s',"\
@@ -360,17 +361,18 @@
sandesha2_permanent_seq_property_mgr_t *seq_prop_mgr_impl = NULL;
axis2_char_t *id = sandesha2_permanent_seq_property_mgr_get_id_with_bean(env, bean);
- if(!id) id = "";
axis2_char_t *seq_id = sandesha2_seq_property_bean_get_seq_id(bean, env);
- if(!seq_id) seq_id = "";
axis2_char_t *name = sandesha2_seq_property_bean_get_name(bean, env);
- if(!name) name = "";
axis2_char_t *value = sandesha2_seq_property_bean_get_value(bean, env);
- if(!value) value = "";
AXIS2_ENV_CHECK(env, AXIS2_FALSE);
AXIS2_PARAM_CHECK(env->error, bean, AXIS2_FALSE);
seq_prop_mgr_impl = SANDESHA2_INTF_TO_IMPL(seq_prop_mgr);
+
+ if(!id) id = "";
+ if(!seq_id) seq_id = "";
+ if(!name) name = "";
+ if(!value) value = "";
sprintf(sql_retrieve, "select seq_id, name, value from seq_property "\
"where id='%s'", id);
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org