1 files changed, 126 insertions, 0 deletions
diff --git a/storage/ndb/src/kernel/SimBlockList.cpp b/storage/ndb/src/kernel/SimBlockList.cpp
new file mode 100644
index 00000000000..75a52ae0c4b
--- /dev/null
+++ b/storage/ndb/src/kernel/SimBlockList.cpp
@@ -0,0 +1,126 @@
+/* Copyright (C) 2003 MySQL AB
+
+   This program is free software; you can redistribute it and/or modify
+   it under the terms of the GNU General Public License as published by
+   the Free Software Foundation; either version 2 of the License, or
+   (at your option) any later version.
+
+   This program is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+   GNU General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program; if not, write to the Free Software
+   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
+
+#include "SimBlockList.hpp"
+#include <SimulatedBlock.hpp>
+#include <Cmvmi.hpp>
+#include <Ndbfs.hpp>
+#include <Dbacc.hpp>
+#include <Dbdict.hpp>
+#include <Dbdih.hpp>
+#include <Dblqh.hpp>
+#include <Dbtc.hpp>
+#include <Dbtup.hpp>
+#include <Ndbcntr.hpp>
+#include <Qmgr.hpp>
+#include <Trix.hpp>
+#include <Backup.hpp>
+#include <DbUtil.hpp>
+#include <Suma.hpp>
+#include <Grep.hpp>
+#include <Dbtux.hpp>
+#include <NdbEnv.h>
+
+#ifndef VM_TRACE
+#define NEW_BLOCK(B) new B
+#else
+enum SIMBLOCKLIST_DUMMY { A_VALUE = 0 };
+
+static
+void * operator new (size_t sz, SIMBLOCKLIST_DUMMY dummy){
+  char * tmp = (char *)malloc(sz);
+
+#ifndef NDB_PURIFY
+#ifdef VM_TRACE
+  const int initValue = 0xf3;
+#else
+  const int initValue = 0x0;
+#endif
+  
+  const int p = (sz / 4096);
+  const int r = (sz % 4096);
+  
+  for(int i = 0; i<p; i++)
+    memset(tmp+(i*4096), initValue, 4096);
+  
+  if(r > 0)
+    memset(tmp+p*4096, initValue, r);
+
+#endif
+  
+  return tmp;
+}
+#define NEW_BLOCK(B) new(A_VALUE) B
+#endif
+
+void 
+SimBlockList::load(const Configuration & conf){
+  noOfBlocks = 16;
+  theList = new SimulatedBlock * [noOfBlocks];
+  Dbdict* dbdict = 0;
+  Dbdih* dbdih = 0;
+
+  SimulatedBlock * fs = 0;
+  {
+    Uint32 dl;
+    const ndb_mgm_configuration_iterator * p = conf.getOwnConfigIterator();
+    if(p && !ndb_mgm_get_int_parameter(p, CFG_DB_DISCLESS, &dl) && dl){
+      fs = NEW_BLOCK(VoidFs)(conf);
+    } else { 
+      fs = NEW_BLOCK(Ndbfs)(conf);
+    }
+  }
+  
+  theList[0]  = NEW_BLOCK(Dbacc)(conf);
+  theList[1]  = NEW_BLOCK(Cmvmi)(conf);
+  theList[2]  = fs;
+  theList[3]  = dbdict = NEW_BLOCK(Dbdict)(conf);
+  theList[4]  = dbdih = NEW_BLOCK(Dbdih)(conf);
+  theList[5]  = NEW_BLOCK(Dblqh)(conf);
+  theList[6]  = NEW_BLOCK(Dbtc)(conf);
+  theList[7]  = NEW_BLOCK(Dbtup)(conf);
+  theList[8]  = NEW_BLOCK(Ndbcntr)(conf);
+  theList[9]  = NEW_BLOCK(Qmgr)(conf);
+  theList[10] = NEW_BLOCK(Trix)(conf);
+  theList[11] = NEW_BLOCK(Backup)(conf);
+  theList[12] = NEW_BLOCK(DbUtil)(conf);
+  theList[13] = NEW_BLOCK(Suma)(conf);
+  theList[14] = NEW_BLOCK(Grep)(conf);
+  theList[15] = NEW_BLOCK(Dbtux)(conf);
+
+  // Metadata common part shared by block instances
+  ptrMetaDataCommon = new MetaData::Common(*dbdict, *dbdih);
+  for (int i = 0; i < noOfBlocks; i++)
+    theList[i]->setMetaDataCommon(ptrMetaDataCommon);
+}
+
+void
+SimBlockList::unload(){
+  if(theList != 0){
+    for(int i = 0; i<noOfBlocks; i++){
+      if(theList[i] != 0){
+	theList[i]->~SimulatedBlock();
+	free(theList[i]);
+	theList[i] = 0;
+      }
+    }
+    delete [] theList;
+    delete ptrMetaDataCommon;
+    theList    = 0;
+    noOfBlocks = 0;
+    ptrMetaDataCommon = 0;
+  }
+}