ndb - added extra valgrind memleak checks to try to track leak

parent 3f2a9eeb
...@@ -19,6 +19,10 @@ ...@@ -19,6 +19,10 @@
#ifdef WITH_NDBCLUSTER_STORAGE_ENGINE #ifdef WITH_NDBCLUSTER_STORAGE_ENGINE
#include "ha_ndbcluster.h" #include "ha_ndbcluster.h"
#ifdef HAVE_purify
#include <valgrind/memcheck.h>
#endif
#ifdef HAVE_NDB_BINLOG #ifdef HAVE_NDB_BINLOG
#include "rpl_injector.h" #include "rpl_injector.h"
#include "rpl_filter.h" #include "rpl_filter.h"
...@@ -3488,6 +3492,9 @@ pthread_handler_t ndb_binlog_thread_func(void *arg) ...@@ -3488,6 +3492,9 @@ pthread_handler_t ndb_binlog_thread_func(void *arg)
pthread_cond_signal(&injector_cond); pthread_cond_signal(&injector_cond);
restart: restart:
#ifdef HAVE_purify
VALGRIND_DO_LEAK_CHECK;
#endif
/* /*
Main NDB Injector loop Main NDB Injector loop
*/ */
...@@ -3580,6 +3587,9 @@ restart: ...@@ -3580,6 +3587,9 @@ restart:
} }
} }
} }
#ifdef HAVE_purify
VALGRIND_DO_LEAK_CHECK;
#endif
{ {
static char db[]= ""; static char db[]= "";
thd->db= db; thd->db= db;
...@@ -3946,6 +3956,9 @@ restart: ...@@ -3946,6 +3956,9 @@ restart:
goto restart; goto restart;
} }
err: err:
#ifdef HAVE_purify
VALGRIND_DO_LEAK_CHECK;
#endif
sql_print_information("Stopping Cluster Binlog"); sql_print_information("Stopping Cluster Binlog");
DBUG_PRINT("info",("Shutting down cluster binlog thread")); DBUG_PRINT("info",("Shutting down cluster binlog thread"));
thd->proc_info= "Shutting down"; thd->proc_info= "Shutting down";
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment