summaryrefslogtreecommitdiff
path: root/storage/ndb/src/ndbapi/ClusterMgr.cpp
diff options
context:
space:
mode:
authorunknown <jonas@perch.ndb.mysql.com>2006-06-09 08:22:50 +0200
committerunknown <jonas@perch.ndb.mysql.com>2006-06-09 08:22:50 +0200
commit6aa63d18199bd2d6b5a0a1de8c1f8a45e094c8b6 (patch)
tree6754e153ea3ebfd8d38b58cf6a375ce13218e1aa /storage/ndb/src/ndbapi/ClusterMgr.cpp
parent8b48a8e881483956a79a700d53e89e8fa5a0e162 (diff)
downloadmariadb-git-6aa63d18199bd2d6b5a0a1de8c1f8a45e094c8b6.tar.gz
ndb - testframework
impl. ugly flag to skip dict cache invalidation as it break all testSystemRestart testcases storage/ndb/src/ndbapi/ClusterMgr.cpp: impl. ugly flag to skip dict cache invalidation as it break all testSystemRestart testcases storage/ndb/test/src/NDBT_Test.cpp: impl. ugly flag to skip dict cache invalidation as it break all testSystemRestart testcases
Diffstat (limited to 'storage/ndb/src/ndbapi/ClusterMgr.cpp')
-rw-r--r--storage/ndb/src/ndbapi/ClusterMgr.cpp14
1 files changed, 9 insertions, 5 deletions
diff --git a/storage/ndb/src/ndbapi/ClusterMgr.cpp b/storage/ndb/src/ndbapi/ClusterMgr.cpp
index b108ed3fd41..63fdb73c49f 100644
--- a/storage/ndb/src/ndbapi/ClusterMgr.cpp
+++ b/storage/ndb/src/ndbapi/ClusterMgr.cpp
@@ -38,6 +38,7 @@
#include <mgmapi_config_parameters.h>
int global_flag_send_heartbeat_now= 0;
+int global_flag_skip_invalidate_cache = 0;
// Just a C wrapper for threadMain
extern "C"
@@ -458,11 +459,14 @@ ClusterMgr::reportNodeFailed(NodeId nodeId){
theNode.nfCompleteRep = false;
if(noOfAliveNodes == 0)
{
- theFacade.m_globalDictCache.lock();
- theFacade.m_globalDictCache.invalidate_all();
- theFacade.m_globalDictCache.unlock();
- m_connect_count ++;
- m_cluster_state = CS_waiting_for_clean_cache;
+ if (!global_flag_skip_invalidate_cache)
+ {
+ theFacade.m_globalDictCache.lock();
+ theFacade.m_globalDictCache.invalidate_all();
+ theFacade.m_globalDictCache.unlock();
+ m_connect_count ++;
+ m_cluster_state = CS_waiting_for_clean_cache;
+ }
NFCompleteRep rep;
for(Uint32 i = 1; i<MAX_NODES; i++){
if(theNodes[i].defined && theNodes[i].nfCompleteRep == false){