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 na...@apache.org on 2007/04/30 09:11:49 UTC

svn commit: r533616 - in /webservices/sandesha/trunk/c/src/storage/mysql: permanent_bean_mgr.c permanent_storage_mgr.c

Author: nandika
Date: Mon Apr 30 00:11:48 2007
New Revision: 533616

URL: http://svn.apache.org/viewvc?view=rev&rev=533616
Log:
mysql_close and mysql_free_result commented

Modified:
    webservices/sandesha/trunk/c/src/storage/mysql/permanent_bean_mgr.c
    webservices/sandesha/trunk/c/src/storage/mysql/permanent_storage_mgr.c

Modified: webservices/sandesha/trunk/c/src/storage/mysql/permanent_bean_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/mysql/permanent_bean_mgr.c?view=diff&rev=533616&r1=533615&r2=533616
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/mysql/permanent_bean_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/storage/mysql/permanent_bean_mgr.c Mon Apr 30 00:11:48 2007
@@ -221,7 +221,7 @@
             sql_stmt_insert, mysql_error(dbconn));
         printf("sql_stmt_insert:%s\n", sql_stmt_insert);
         printf("insert error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */ 
         return AXIS2_FALSE;
     }
     return AXIS2_TRUE;
@@ -254,7 +254,7 @@
             sql_stmt_remove, mysql_error(dbconn));
         printf("sql_stmt_remove:%s\n", sql_stmt_remove);
         printf("remove error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return AXIS2_FALSE;
     }
     return AXIS2_TRUE;
@@ -292,14 +292,14 @@
             sql_stmt_retrieve, mysql_error(dbconn));
         printf("sql_stmt_retrieve:%s\n", sql_stmt_retrieve);
         printf("retrieve error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return AXIS2_FALSE;
     }
     res = mysql_store_result(dbconn);
     if(res)
     {
         retrieve_func(res, args);
-        mysql_free_result(res);
+        /* mysql_free_result(res); */
     }
     else
     {
@@ -345,7 +345,7 @@
             mysql_error(dbconn));
         printf("sql_stmt_update:%s\n", sql_stmt_update);
         printf("update error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return AXIS2_FALSE;
     }
     return AXIS2_TRUE;
@@ -397,12 +397,12 @@
             mysql_error(dbconn));
         printf("sql_stmt_find:%s\n", sql_stmt_find);
         printf("retrieve error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return NULL;
     }
     res = mysql_store_result(dbconn);
     find_func(res, args);
-    mysql_free_result(res);
+    /* mysql_free_result(res); */
     if(args->data)
     {
         data_array = (axutil_array_list_t *) args->data;
@@ -445,12 +445,12 @@
                     mysql_error(dbconn));
                 printf("sql_stmt_count:%s\n", sql_stmt_count);
                 printf("retrieve error_msg:%s\n", mysql_error(dbconn));
-                mysql_close(dbconn);
+                /* mysql_close(dbconn); */
                 return NULL;
             }
             res = mysql_store_result(dbconn);
             count_func(res, &count);
-            mysql_free_result(res);
+            /* mysql_free_result(res); */
             if(count == 0)
             {
                 axutil_array_list_remove(beans, env, i);
@@ -530,12 +530,12 @@
             mysql_error(dbconn));
         printf("sql_stmt_retrieve:%s\n", sql_stmt_retrieve);
         printf("retrieve error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return AXIS2_FALSE;
     }
     res = mysql_store_result(dbconn);
     sandesha2_msg_store_bean_retrieve_callback(res, args);
-    mysql_free_result(res);
+    /* mysql_free_result(res); */
     if(args->data)
         msg_store_bean = (sandesha2_msg_store_bean_t *) args->data;
     if(args)
@@ -643,12 +643,12 @@
             mysql_error(dbconn));
         printf("sql_stmt_retrieve:%s\n", sql_stmt_retrieve);
         printf("retrieve error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return AXIS2_FALSE;
     }
     res = mysql_store_result(dbconn);
     num_rows = mysql_num_rows(res);
-    mysql_free_result(res);
+    /* mysql_free_result(res); */
     if(num_rows > 0)
     {
         sql_stmt_update = AXIS2_MALLOC(env->allocator, sql_size);
@@ -671,7 +671,7 @@
             printf("sql_stmt_update:%s\n", sql_stmt_update);
             printf("update error_msg:%s\n", mysql_error(dbconn));
             AXIS2_FREE(env->allocator, sql_stmt_update);
-            mysql_close(dbconn);
+            /* mysql_close(dbconn); */
             return AXIS2_FALSE;
         }
         AXIS2_FREE(env->allocator, sql_stmt_update);
@@ -695,7 +695,7 @@
         printf("sql_stmt_insert:%s\n", sql_stmt_insert);
         printf("insert error_msg:%s\n", mysql_error(dbconn));
         AXIS2_FREE(env->allocator, sql_stmt_insert);
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return AXIS2_FALSE;
     }
     AXIS2_FREE(env->allocator, sql_stmt_insert);
@@ -729,7 +729,7 @@
             mysql_error(dbconn));
         printf("sql_stmt_remove:%s\n", sql_stmt_remove);
         printf("remove error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return AXIS2_FALSE;
     }
     return AXIS2_TRUE;
@@ -774,12 +774,12 @@
             mysql_error(dbconn));
         printf("sql_stmt_count:%s\n", sql_stmt_count);
         printf("retrieve error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return AXIS2_FALSE;
     }
     res = mysql_store_result(dbconn);
     sandesha2_permanent_bean_mgr_count_callback(res, &count);
-    mysql_free_result(res);
+    /* mysql_free_result(res); */
     if(count > 0)
     {
         sql_stmt_update = AXIS2_MALLOC(env->allocator, sql_size);
@@ -796,7 +796,7 @@
             printf("sql_stmt_update:%s\n", sql_stmt_update);
             printf("update error_msg:%s\n", mysql_error(dbconn));
             AXIS2_FREE(env->allocator, sql_stmt_update);
-            mysql_close(dbconn);
+            /* mysql_close(dbconn); */
             return AXIS2_FALSE;
         }
         AXIS2_FREE(env->allocator, sql_stmt_update);
@@ -816,7 +816,7 @@
             printf("sql_stmt_insert:%s\n", sql_stmt_insert);
             printf("insert error_msg:%s\n", mysql_error(dbconn));
             AXIS2_FREE(env->allocator, sql_stmt_insert);
-            mysql_close(dbconn);
+            /* mysql_close(dbconn); */
             return AXIS2_FALSE;
         }
         AXIS2_FREE(env->allocator, sql_stmt_insert);
@@ -853,7 +853,7 @@
             mysql_error(dbconn));
         printf("sql_stmt_remove:%s\n", sql_stmt_remove);
         printf("remove error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return AXIS2_FALSE;
     }
     return AXIS2_TRUE;
@@ -893,12 +893,12 @@
             mysql_error(dbconn));
         printf("sql_stmt_retrieve:%s\n", sql_stmt_retrieve);
         printf("retrieve error_msg:%s\n", mysql_error(dbconn));
-        mysql_close(dbconn);
+        /* mysql_close(dbconn); */
         return AXIS2_FALSE;
     }
     res = mysql_store_result(dbconn);
     sandesha2_permanent_bean_mgr_response_retrieve_callback(res, args);
-    mysql_free_result(res);
+    /* mysql_free_result(res); */
     return (sandesha2_response_t *) args->data;
 }
 

Modified: webservices/sandesha/trunk/c/src/storage/mysql/permanent_storage_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/mysql/permanent_storage_mgr.c?view=diff&rev=533616&r1=533615&r2=533616
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/mysql/permanent_storage_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/storage/mysql/permanent_storage_mgr.c Mon Apr 30 00:11:48 2007
@@ -24,14 +24,14 @@
 #include <sandesha2_invoker_mgr.h>
 #include "sandesha2_permanent_invoker_mgr.h"
 #include <sandesha2_next_msg_mgr.h>
-#include <sandesha2_permanent_next_msg_mgr.h>
+#include "sandesha2_permanent_next_msg_mgr.h"
 #include <sandesha2_sender_mgr.h>
-#include <sandesha2_permanent_sender_mgr.h>
+#include "sandesha2_permanent_sender_mgr.h"
 #include <sandesha2_seq_property_mgr.h>
-#include <sandesha2_permanent_seq_property_mgr.h>
+#include "sandesha2_permanent_seq_property_mgr.h"
 #include <sandesha2_transaction.h>
 #include <sandesha2_property_bean.h>
-#include <sandesha2_permanent_transaction.h>
+#include "sandesha2_permanent_transaction.h"
 #include <sandesha2_constants.h>
 #include <sandesha2_error.h>
 #include <sandesha2_utils.h>
@@ -639,6 +639,7 @@
     axis2_char_t *prop_str = NULL;
     axis2_op_ctx_t *op_ctx = NULL;
     sandesha2_msg_store_bean_t *bean = NULL;
+	axis2_char_t *transport_to = NULL;
         
     envelope = axis2_msg_ctx_get_soap_envelope(msg_ctx, env);
     if (!envelope)
@@ -725,7 +726,7 @@
         address = (axis2_char_t *) axis2_endpoint_ref_get_address(reply_to, env);
         sandesha2_msg_store_bean_set_reply_to(bean, env, address);
     }
-    axis2_char_t *transport_to = NULL;
+    
     transport_to = axis2_msg_ctx_get_transport_url(msg_ctx, env);
     if(transport_to)
         sandesha2_msg_store_bean_set_transport_to(bean, env, transport_to);



---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org