diff options
author | unknown <joreland@mysql.com> | 2004-05-04 11:19:19 +0200 |
---|---|---|
committer | unknown <joreland@mysql.com> | 2004-05-04 11:19:19 +0200 |
commit | e2eb40331606aa7e842d60e0bd2b8bda1ca10cfb (patch) | |
tree | f59c19e8bd7bce4bd4668619571afd3f4a12d23e /ndb/src/kernel/blocks/cmvmi/Cmvmi.cpp | |
parent | 7a241510b5431b4e7c3e9b5fd75b091143f37bdd (diff) | |
download | mariadb-git-e2eb40331606aa7e842d60e0bd2b8bda1ca10cfb.tar.gz |
Merge NDB patches into 4.1-clone, below is list of changesets
# --------------------------------------------
# 04/04/13 joreland@mysql.com 1.1858.1.1
# Removal of NDBT_Table
# --------------------------------------------
# 04/04/13 joreland@mysql.com 1.1858.1.2
# Removal of NDBT_Table
# --------------------------------------------
# 04/04/13 joreland@mysql.com 1.1858.1.3
# Fix for crashing AT
# --------------------------------------------
# 04/04/13 joreland@mysql.com 1.1858.1.4
# Bug fixes in testIndex
# --------------------------------------------
# 04/04/13 joreland@mysql.com 1.1866.1.5
# Merge joreland@bk-internal.mysql.com:/home/bk/mysql-4.1-ndb
# into mysql.com:/home/jonas/src/tmp
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1858.1.5
# Fix for takeover when accessing indexes.
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1866.1.6
# Merge joreland@bk-internal.mysql.com:/home/bk/mysql-4.1-ndb
# into mysql.com:/home/jonas/src/tmp
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1858.2.1
# Fixed error handling of fire_trigger_ord + lqhkeyref w.r.t indexes
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1858.2.2
# Simple retry mechanism in UTIL
# Helps testIndex -n BuildDuring _a lot_
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1858.2.3
# Misc fixes to test prg.
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1858.2.4
# Allow more retires on application errors
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1858.2.5
# Pass no of rows fetched in SUB_SYNC_CONTINUE_REQ
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1869
# wl1714
# Improve parallellism
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1870
# Merge joreland@bk-internal.mysql.com:/home/bk/mysql-4.1-ndb
# into mysql.com:/home/jonas/src/wl1714
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1866.1.7
# Merge
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1871
# Merge mysql.com:/home/jonas/src/wl1714
# into mysql.com:/home/jonas/src/mysql-4.1-ndb
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1872
# Fix for testScan -n ScanReadError5030
# --------------------------------------------
# 04/04/14 joreland@mysql.com 1.1873
# fix testDict -n FragmentType*
# --------------------------------------------
# 04/04/14 johan@stingray.(none) 1.1866.2.1
# small fixes
# --------------------------------------------
# 04/04/14 johan@stingray.(none) 1.1874
# Merge jandersson@bk-internal.mysql.com:/home/bk/mysql-4.1-ndb
# into stingray.(none):/space/bk/rep/mysql-4.1-ndb
# --------------------------------------------
# 04/04/14 johan@stingray.(none) 1.1875
# handle rep node as an api node
# --------------------------------------------
# 04/04/14 pekka@mysql.com 1.1873.1.1
# Fix for NDBT_Table removal
# --------------------------------------------
# 04/04/15 joreland@mysql.com 1.1873.1.2
# Uninitialized var.
# --------------------------------------------
# 04/04/15 johan@stingray.(none) 1.1876
# Merge jandersson@bk-internal.mysql.com:/home/bk/mysql-4.1-ndb
# into stingray.(none):/space/bk/rep/mysql-4.1-ndb
# --------------------------------------------
# 04/04/15 joreland@mysql.com 1.1873.1.3
# Write pid before changing user
# (as runas user probably doesn't have permissions on pid-dir)
# --------------------------------------------
# --------------------------------------------
# 04/04/15 ndb@mc03.ndb.mysql.com 1.1862.1.3
# Fix printout of varchars
# --------------------------------------------
# 04/04/15 ndb@mc03.ndb.mysql.com 1.1877
# Merge joreland@bk-internal.mysql.com:/home/bk/mysql-4.1-ndb
# into mc03.ndb.mysql.com:/space/ndb/tmp
# --------------------------------------------
# 04/04/15 ndb@mc03.ndb.mysql.com 1.1862.1.4
# Hmm.. don't print attr as many times as length of array
# --------------------------------------------
# 04/04/15 ndb@mc03.ndb.mysql.com 1.1878
# Merge mc03.ndb.mysql.com:/space/ndb/mysql-4.1-ndb
# into mc03.ndb.mysql.com:/space/ndb/tmp
# --------------------------------------------
# 04/04/15 joreland@mysql.com 1.1876.1.1
# Merge joreland@bk-internal.mysql.com:/home/bk/mysql-4.1-ndb
# into mysql.com:/home/jonas/src/mysql-4.1-ndb
# --------------------------------------------
# 04/04/15 joreland@mysql.com 1.1877.1.1
# Merge joreland@bk-internal.mysql.com:/home/bk/mysql-4.1-ndb
# into mysql.com:/home/jonas/src/mysql-4.1-ndb
# --------------------------------------------
# 04/04/15 ndb@mc03.ndb.mysql.com 1.1879
# Merge joreland@bk-internal.mysql.com:/home/bk/mysql-4.1-ndb
# into mc03.ndb.mysql.com:/space/ndb/tmp
# --------------------------------------------
# 04/04/17 joreland@mysql.com 1.1880
# LCP bug when restarting ops take's longer than DIH sending a new lcp ord
# Solution:
# Send LCP_FRAG_REP after restarting all ops
# --------------------------------------------
# 04/04/18 joreland@mysql.com 1.1881
# Missspelled ERROR_INSERT
# --------------------------------------------
# 04/04/18 joreland@mysql.com 1.1882
# Added possibility to log only distributed signals
# --------------------------------------------
# 04/04/22 joreland@mysql.com 1.1883
# Removed dependancy to libstdc++
# * pure virtual functions "__cxa_pure_virtual" is defined in libstd++ ->
# remove all pure virtual functions
# --------------------------------------------
# 04/04/23 joreland@mysql.com 1.1884
# Various minor bug fixes for problems found while compiling
# with icc
# --------------------------------------------
# --------------------------------------------
# 04/04/25 joreland@mysql.com 1.1885
# Removed debug code (joreland:1.1875)
# --------------------------------------------
# 04/04/26 ejonore@mc03.ndb.mysql.com 1.1862.1.5
# Lock pages in memory _after_ daemon-mode (exec/fork)
# --------------------------------------------
# 04/04/27 ejonore@mc03.ndb.mysql.com 1.1862.1.6
# 1) Trap abort()
# 2) StopStart/StopAborted events
# 3) warning if memlock fails
# 4) use g_logger more often (instead of ndbout)
#
# --------------------------------------------
# 04/04/27 joreland@mysql.com 1.1886
# bug fix for a bug in wl1714 + software upgrade
# --------------------------------------------
# 04/04/27 joreland@mysql.com 1.1887
# Cset exclude: joreland@mysql.com|ChangeSet|20040422160720|05374
# --------------------------------------------
# 04/04/27 joreland@mysql.com 1.1888
# removed libstc++ second try...
# --------------------------------------------
# 04/04/28 ejonore@mc03.ndb.mysql.com 1.1862.1.7
# 1) Don't lock FUTURE pages but only current
# 2) Do this when SIZEALT has completed
# --------------------------------------------
# 04/04/30 joreland@mysql.com 1.1889
# Merge jonas@orca:/home/ndb/releases/mysql-4.1-ndb-3.4.x
# into mysql.com:/home/jonas/src/mysql-4.1-ndb
# --------------------------------------------
# 04/05/03 ndb@mc03.ndb.mysql.com 1.1862.1.8
# Version update
# --------------------------------------------
# 04/05/03 joreland@mysql.com 1.1862.3.1
# Changed restart behavior.
# Use "angel" process which monitor "real" process
# --------------------------------------------
# 04/05/03 joreland@mysql.com 1.1862.1.9
# Merge jonas@orca:/home/ndb/releases/mysql-4.1-ndb-3.4.x
# into mysql.com:/home/jonas/src/mysql-4.1-ndb-3.4.x
# --------------------------------------------
# 04/05/03 joreland@mysql.com 1.1890
# Merge B2 fixes
# --------------------------------------------
# --------------------------------------------
# 04/05/03 joreland@mysql.com 1.1862.1.10
# Better handling of children terminations
# --------------------------------------------
# 04/05/03 joreland@mysql.com 1.1862.1.11
# Fixes for angel-restarting
# --------------------------------------------
# 04/05/03 joreland@mysql.com 1.1891
# Merge mysql.com:/home/jonas/src/mysql-4.1-ndb-3.4.x
# into mysql.com:/home/jonas/src/mysql-4.1-ndb
# --------------------------------------------
#
ndb/config/Defs.LINUX.x86.GCC.mk:
Merge ndb fixes
ndb/examples/ndbapi_async_example/Makefile:
Merge ndb fixes
ndb/examples/ndbapi_async_example/ndbapi_async.cpp:
Merge ndb fixes
ndb/examples/ndbapi_scan_example/Makefile:
Merge ndb fixes
ndb/include/debugger/SignalLoggerManager.hpp:
Merge ndb fixes
ndb/include/kernel/signaldata/ScanFrag.hpp:
Merge ndb fixes
ndb/include/ndb_version.h:
Merge ndb fixes
ndb/include/ndbapi/NdbScanOperation.hpp:
Merge ndb fixes
ndb/include/util/SocketServer.hpp:
Merge ndb fixes
ndb/src/common/debugger/SignalLoggerManager.cpp:
Merge ndb fixes
ndb/src/common/logger/ConsoleLogHandler.cpp:
Merge ndb fixes
ndb/src/common/portlib/unix/NdbMem.c:
Merge ndb fixes
ndb/src/common/util/Makefile:
Merge ndb fixes
ndb/src/common/util/version.c:
Merge ndb fixes
ndb/src/cw/cpcd/Process.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/ERROR_codes.txt:
Merge ndb fixes
ndb/src/kernel/blocks/backup/restore/Restore.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/backup/restore/Restore.hpp:
Merge ndb fixes
ndb/src/kernel/blocks/backup/restore/main.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/cmvmi/Cmvmi.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/dbdict/Dbdict.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/dblqh/Dblqh.hpp:
Merge ndb fixes
ndb/src/kernel/blocks/dblqh/DblqhInit.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/dblqh/DblqhMain.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/dbtc/Dbtc.hpp:
Merge ndb fixes
ndb/src/kernel/blocks/dbtc/DbtcInit.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/dbtc/DbtcMain.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/dbutil/DbUtil.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/dbutil/DbUtil.hpp:
Merge ndb fixes
ndb/src/kernel/blocks/ndbcntr/NdbcntrMain.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/ndbfs/Filename.cpp:
Merge ndb fixes
ndb/src/kernel/blocks/suma/Suma.cpp:
Merge ndb fixes
ndb/src/kernel/error/Error.hpp:
Merge ndb fixes
ndb/src/kernel/ndb-main/Main.cpp:
Merge ndb fixes
ndb/src/kernel/vm/Configuration.cpp:
Merge ndb fixes
ndb/src/kernel/vm/Configuration.hpp:
Merge ndb fixes
ndb/src/kernel/vm/DLFifoList.hpp:
Merge ndb fixes
ndb/src/kernel/vm/Emulator.cpp:
Merge ndb fixes
ndb/src/kernel/vm/SignalCounter.hpp:
Merge ndb fixes
ndb/src/kernel/vm/SimulatedBlock.cpp:
Merge ndb fixes
ndb/src/mgmsrv/MgmtSrvr.cpp:
Merge ndb fixes
ndb/src/mgmsrv/NodeLogLevel.cpp:
Merge ndb fixes
ndb/src/ndbapi/ClusterMgr.cpp:
Merge ndb fixes
ndb/src/ndbapi/Ndberror.cpp:
Merge ndb fixes
ndb/src/rep/rep_version.hpp:
Merge ndb fixes
ndb/test/ndbapi/testDict/testDict.cpp:
Merge ndb fixes
ndb/test/ndbapi/testIndex/testIndex.cpp:
Merge ndb fixes
ndb/test/ndbapi/testMgm/testMgm.cpp:
Merge ndb fixes
ndb/test/ndbapi/testScan/testScan.cpp:
Merge ndb fixes
ndb/test/src/HugoTransactions.cpp:
Merge ndb fixes
ndb/test/src/NDBT_Tables.cpp:
Merge ndb fixes
ndb/test/src/NDBT_Test.cpp:
Merge ndb fixes
ndb/test/src/UtilTransactions.cpp:
Merge ndb fixes
BitKeeper/etc/logging_ok:
Logging to logging@openlogging.org accepted
Diffstat (limited to 'ndb/src/kernel/blocks/cmvmi/Cmvmi.cpp')
-rw-r--r-- | ndb/src/kernel/blocks/cmvmi/Cmvmi.cpp | 56 |
1 files changed, 47 insertions, 9 deletions
diff --git a/ndb/src/kernel/blocks/cmvmi/Cmvmi.cpp b/ndb/src/kernel/blocks/cmvmi/Cmvmi.cpp index 2735cac0c8e..cd6198eff23 100644 --- a/ndb/src/kernel/blocks/cmvmi/Cmvmi.cpp +++ b/ndb/src/kernel/blocks/cmvmi/Cmvmi.cpp @@ -46,10 +46,11 @@ #include <TimeQueue.hpp> #include <new> +#include <NdbSleep.h> #include <SafeCounter.hpp> // Used here only to print event reports on stdout/console. -static EventLogger eventLogger; +EventLogger g_eventLogger; Cmvmi::Cmvmi(const Configuration & conf) : SimulatedBlock(CMVMI, conf) @@ -92,11 +93,6 @@ Cmvmi::Cmvmi(const Configuration & conf) : subscriberPool.setSize(5); - // Print to stdout/console - eventLogger.createConsoleHandler(); - eventLogger.setCategory("NDB"); - eventLogger.enable(Logger::LL_INFO, Logger::LL_ALERT); // Log INFO to ALERT - const ClusterConfiguration::ClusterData & clData = theConfig.clusterConfigurationData() ; @@ -130,6 +126,10 @@ void Cmvmi::execNDB_TAMPER(Signal* signal) if(ERROR_INSERTED(9999)){ CRASH_INSERTION(9999); } + + if(ERROR_INSERTED(9998)){ + while(true) NdbSleep_SecSleep(1); + } }//execNDB_TAMPER() void Cmvmi::execSET_LOGLEVELORD(Signal* signal) @@ -194,7 +194,7 @@ void Cmvmi::execEVENT_REP(Signal* signal) } // Print the event info - eventLogger.log(eventReport->getEventType(), signal->theData); + g_eventLogger.log(eventReport->getEventType(), signal->theData); }//execEVENT_REP() @@ -395,6 +395,15 @@ void Cmvmi::execSIZEALT_ACK(Signal* signal) sendSignal(numberToRef(blockNo, 0), GSN_SIZEALT_REP, signal,21, JBB); } else { jam(); + + if(theConfig.lockPagesInMainMemory()){ + int res = NdbMem_MemLockAll(); + if(res != 0){ + g_eventLogger.warning("Failed to memlock pages"); + warningEvent("Failed to memlock pages"); + } + } + sendSTTORRY(signal); } } @@ -404,7 +413,7 @@ void Cmvmi::execCM_INFOREQ(Signal* signal) int id = signal->theData[1]; const BlockReference userRef = signal->theData[0]; const ClusterConfiguration::ClusterData & clusterConf = - theConfig.clusterConfigurationData(); + theConfig.clusterConfigurationData(); const int myNodeId = globalData.ownId; jamEntry(); @@ -1116,6 +1125,24 @@ public: }; #endif + +static int iii; + +static +int +recurse(char * buf, int loops, int arg){ + char * tmp = (char*)alloca(arg); + printf("tmp = %p\n", tmp); + for(iii = 0; iii<arg; iii += 1024){ + tmp[iii] = (iii % 23 + (arg & iii)); + } + + if(loops == 0) + return tmp[345]; + else + return tmp[arg/loops] + recurse(tmp, loops - 1, arg); +} + void Cmvmi::execDUMP_STATE_ORD(Signal* signal) { @@ -1141,7 +1168,18 @@ Cmvmi::execDUMP_STATE_ORD(Signal* signal) * Here I can dump CMVMI state if needed */ if(signal->theData[0] == 13){ - infoEvent("Cmvmi: signalCount = %d", signalCount); +#if 0 + int loop = 100; + int len = (10*1024*1024); + if(signal->getLength() > 1) + loop = signal->theData[1]; + if(signal->getLength() > 2) + len = signal->theData[2]; + + ndbout_c("recurse(%d loop, %dkb per recurse)", loop, len/1024); + int a = recurse(0, loop, len); + ndbout_c("after...%d", a); +#endif } DumpStateOrd * const & dumpState = (DumpStateOrd *)&signal->theData[0]; |