mirror/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-01-19 13:32:33 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

ndb - testframework

Browse source 
impl. ugly flag to skip dict cache invalidation as it break all testSystemRestart testcases
This commit is contained in:
jonas@perch.ndb.mysql.com 2006-06-09 08:22:50 +02:00
parent b7ce47b28e
commit e576b2460b
2 changed files with 13 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
storage/ndb/src/ndbapi/ClusterMgr.cpp
View file

@ -38,6 +38,7 @@
#include <mgmapi_config_parameters.h> #include <mgmapi_config_parameters.h>
int global_flag_send_heartbeat_now= 0; int global_flag_send_heartbeat_now= 0;
int global_flag_skip_invalidate_cache = 0;
// Just a C wrapper for threadMain // Just a C wrapper for threadMain
extern "C" extern "C"
@ -458,11 +459,14 @@ ClusterMgr::reportNodeFailed(NodeId nodeId){
theNode.nfCompleteRep = false; theNode.nfCompleteRep = false;
if(noOfAliveNodes == 0) if(noOfAliveNodes == 0)
{ {
theFacade.m_globalDictCache.lock(); if (!global_flag_skip_invalidate_cache)
theFacade.m_globalDictCache.invalidate_all(); {
theFacade.m_globalDictCache.unlock(); theFacade.m_globalDictCache.lock();
m_connect_count ++; theFacade.m_globalDictCache.invalidate_all();
m_cluster_state = CS_waiting_for_clean_cache; theFacade.m_globalDictCache.unlock();
m_connect_count ++;
m_cluster_state = CS_waiting_for_clean_cache;
}
NFCompleteRep rep; NFCompleteRep rep;
for(Uint32 i = 1; i<MAX_NODES; i++){ for(Uint32 i = 1; i<MAX_NODES; i++){
if(theNodes[i].defined && theNodes[i].nfCompleteRep == false){ if(theNodes[i].defined && theNodes[i].nfCompleteRep == false){

4
storage/ndb/test/src/NDBT_Test.cpp
View file

@ -1149,6 +1149,8 @@ static struct my_option my_long_options[] =
{ 0, 0, 0, 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0} { 0, 0, 0, 0, 0, 0, GET_NO_ARG, NO_ARG, 0, 0, 0, 0, 0, 0}
}; };
extern int global_flag_skip_invalidate_cache;
static void usage() static void usage()
{ {
ndb_std_print_version(); ndb_std_print_version();
@ -1236,6 +1238,8 @@ int NDBT_TestSuite::execute(int argc, const char** argv){
ndbout_c("random seed: %u", opt_seed); ndbout_c("random seed: %u", opt_seed);
srand(opt_seed); srand(opt_seed);
srandom(opt_seed); srandom(opt_seed);
global_flag_skip_invalidate_cache = 1;
{ {
Ndb ndb(&con, "TEST_DB"); Ndb ndb(&con, "TEST_DB");