开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
DbdihInit.cpp
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：12k
源码类别：

MySQL数据库

开发平台：

Visual C++

DbdihInit.cpp：源码内容
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  18. #define DBDIH_C
  19. #include "Dbdih.hpp"
  20. #include <ndb_limits.h>
  22. #define DEBUG(x) { ndbout << "DIH::" << x << endl; }
  24. void Dbdih::initData() 
  25. {
  26.   cpageFileSize = ZPAGEREC;
  28.   apiConnectRecord = 0;
  29.   connectRecord = 0;
  30.   fileRecord = 0;
  31.   fragmentstore = 0;
  32.   pageRecord = 0;
  33.   replicaRecord = 0;
  34.   tabRecord = 0;
  35.   takeOverRecord = 0;
  36.   createReplicaRecord = 0;
  37.   nodeGroupRecord = 0;
  38.   nodeRecord = 0;
  39.   c_nextNodeGroup = 0;
  41.   // Records with constant sizes
  42.   createReplicaRecord = (CreateReplicaRecord*)
  43.     allocRecord("CreateReplicaRecord", sizeof(CreateReplicaRecord),
  44.                  ZCREATE_REPLICA_FILE_SIZE);
  46.   nodeGroupRecord = (NodeGroupRecord*)
  47.     allocRecord("NodeGroupRecord", sizeof(NodeGroupRecord), MAX_NDB_NODES);
  49.   nodeRecord = (NodeRecord*)
  50.     allocRecord("NodeRecord", sizeof(NodeRecord), MAX_NDB_NODES);
  52.   Uint32 i;
  53.   for(i = 0; i<MAX_NDB_NODES; i++){
  54.     new (&nodeRecord[i]) NodeRecord();
  55.   }
  56.   
  57.   takeOverRecord = (TakeOverRecord*)allocRecord("TakeOverRecord",
  58.                                                 sizeof(TakeOverRecord), 
  59.                                                 MAX_NDB_NODES);
  60.   for(i = 0; i<MAX_NDB_NODES; i++)
  61.     new (&takeOverRecord[i]) TakeOverRecord();
  63.   for(i = 0; i<MAX_NDB_NODES; i++)
  64.     new (&takeOverRecord[i]) TakeOverRecord();
  65.   
  66.   waitGCPProxyPool.setSize(ZPROXY_FILE_SIZE);
  67.   waitGCPMasterPool.setSize(ZPROXY_MASTER_FILE_SIZE);
  69.   cgcpOrderBlocked = 0;
  70.   c_lcpState.ctcCounter = 0;
  71.   cwaitLcpSr       = false;
  72.   c_blockCommit    = false;
  73.   c_blockCommitNo  = 1;
  74. }//Dbdih::initData()
  76. void Dbdih::initRecords() 
  77. {
  78.   // Records with dynamic sizes
  79.   apiConnectRecord = (ApiConnectRecord*)
  80.     allocRecord("ApiConnectRecord", 
  81.                 sizeof(ApiConnectRecord),
  82.                 capiConnectFileSize);
  84.   connectRecord = (ConnectRecord*)allocRecord("ConnectRecord",
  85.                                               sizeof(ConnectRecord), 
  86.                                               cconnectFileSize);
  88.   fileRecord = (FileRecord*)allocRecord("FileRecord",
  89.                                         sizeof(FileRecord),
  90.                                         cfileFileSize);
  92.   fragmentstore = (Fragmentstore*)allocRecord("Fragmentstore",
  93.                                               sizeof(Fragmentstore),
  94.                                               cfragstoreFileSize);
  96.   pageRecord = (PageRecord*)allocRecord("PageRecord",
  97.                                   sizeof(PageRecord), 
  98.                                   cpageFileSize);
  100.   replicaRecord = (ReplicaRecord*)allocRecord("ReplicaRecord",
  101.                                               sizeof(ReplicaRecord), 
  102.                                               creplicaFileSize);
  104.   tabRecord = (TabRecord*)allocRecord("TabRecord",
  105.                                               sizeof(TabRecord), 
  106.                                               ctabFileSize);
  108.   // Initialize BAT for interface to file system
  109.   NewVARIABLE* bat = allocateBat(22);
  110.   bat[1].WA = &pageRecord->word[0];
  111.   bat[1].nrr = cpageFileSize;
  112.   bat[1].ClusterSize = sizeof(PageRecord);
  113.   bat[1].bits.q = 11;
  114.   bat[1].bits.v = 5;
  115.   bat[20].WA = &sysfileData[0];
  116.   bat[20].nrr = 1;
  117.   bat[20].ClusterSize = sizeof(sysfileData);
  118.   bat[20].bits.q = 7;
  119.   bat[20].bits.v = 5;
  120.   bat[21].WA = &sysfileDataToFile[0];
  121.   bat[21].nrr = 1;
  122.   bat[21].ClusterSize = sizeof(sysfileDataToFile);
  123.   bat[21].bits.q = 7;
  124.   bat[21].bits.v = 5;
  125. }//Dbdih::initRecords()
  127. Dbdih::Dbdih(const class Configuration & config):
  128.   SimulatedBlock(DBDIH, config),
  129.   c_waitGCPProxyList(waitGCPProxyPool),
  130.   c_waitGCPMasterList(waitGCPMasterPool)
  131. {
  132.   BLOCK_CONSTRUCTOR(Dbdih);
  134.   addRecSignal(GSN_DUMP_STATE_ORD, &Dbdih::execDUMP_STATE_ORD);
  135.   addRecSignal(GSN_NDB_TAMPER, &Dbdih::execNDB_TAMPER, true);
  136.   addRecSignal(GSN_DEBUG_SIG, &Dbdih::execDEBUG_SIG);
  137.   addRecSignal(GSN_MASTER_GCPREQ, &Dbdih::execMASTER_GCPREQ);
  138.   addRecSignal(GSN_MASTER_GCPREF, &Dbdih::execMASTER_GCPREF);
  139.   addRecSignal(GSN_MASTER_GCPCONF, &Dbdih::execMASTER_GCPCONF);
  140.   addRecSignal(GSN_EMPTY_LCP_CONF, &Dbdih::execEMPTY_LCP_CONF);
  141.   addRecSignal(GSN_MASTER_LCPREQ, &Dbdih::execMASTER_LCPREQ);
  142.   addRecSignal(GSN_MASTER_LCPREF, &Dbdih::execMASTER_LCPREF);
  143.   addRecSignal(GSN_MASTER_LCPCONF, &Dbdih::execMASTER_LCPCONF);
  144.   addRecSignal(GSN_NF_COMPLETEREP, &Dbdih::execNF_COMPLETEREP);
  145.   addRecSignal(GSN_START_PERMREQ, &Dbdih::execSTART_PERMREQ);
  146.   addRecSignal(GSN_START_PERMCONF, &Dbdih::execSTART_PERMCONF);
  147.   addRecSignal(GSN_START_PERMREF, &Dbdih::execSTART_PERMREF);
  148.   addRecSignal(GSN_INCL_NODEREQ, &Dbdih::execINCL_NODEREQ);
  149.   addRecSignal(GSN_INCL_NODECONF, &Dbdih::execINCL_NODECONF);
  150.   addRecSignal(GSN_END_TOREQ, &Dbdih::execEND_TOREQ);
  151.   addRecSignal(GSN_END_TOCONF, &Dbdih::execEND_TOCONF);
  152.   addRecSignal(GSN_START_TOREQ, &Dbdih::execSTART_TOREQ);
  153.   addRecSignal(GSN_START_TOCONF, &Dbdih::execSTART_TOCONF);
  154.   addRecSignal(GSN_START_MEREQ, &Dbdih::execSTART_MEREQ);
  155.   addRecSignal(GSN_START_MECONF, &Dbdih::execSTART_MECONF);
  156.   addRecSignal(GSN_START_MEREF, &Dbdih::execSTART_MEREF);
  157.   addRecSignal(GSN_START_COPYREQ, &Dbdih::execSTART_COPYREQ);
  158.   addRecSignal(GSN_START_COPYCONF, &Dbdih::execSTART_COPYCONF);
  159.   addRecSignal(GSN_START_COPYREF, &Dbdih::execSTART_COPYREF);
  160.   addRecSignal(GSN_CREATE_FRAGREQ, &Dbdih::execCREATE_FRAGREQ);
  161.   addRecSignal(GSN_CREATE_FRAGCONF, &Dbdih::execCREATE_FRAGCONF);
  162.   addRecSignal(GSN_DIVERIFYREQ, &Dbdih::execDIVERIFYREQ);
  163.   addRecSignal(GSN_GCP_SAVECONF, &Dbdih::execGCP_SAVECONF);
  164.   addRecSignal(GSN_GCP_PREPARECONF, &Dbdih::execGCP_PREPARECONF);
  165.   addRecSignal(GSN_GCP_PREPARE, &Dbdih::execGCP_PREPARE);
  166.   addRecSignal(GSN_GCP_NODEFINISH, &Dbdih::execGCP_NODEFINISH);
  167.   addRecSignal(GSN_GCP_COMMIT, &Dbdih::execGCP_COMMIT);
  168.   addRecSignal(GSN_DIHNDBTAMPER, &Dbdih::execDIHNDBTAMPER);
  169.   addRecSignal(GSN_CONTINUEB, &Dbdih::execCONTINUEB);
  170.   addRecSignal(GSN_COPY_GCIREQ, &Dbdih::execCOPY_GCIREQ);
  171.   addRecSignal(GSN_COPY_GCICONF, &Dbdih::execCOPY_GCICONF);
  172.   addRecSignal(GSN_COPY_TABREQ, &Dbdih::execCOPY_TABREQ);
  173.   addRecSignal(GSN_COPY_TABCONF, &Dbdih::execCOPY_TABCONF);
  174.   addRecSignal(GSN_TCGETOPSIZECONF, &Dbdih::execTCGETOPSIZECONF);
  175.   addRecSignal(GSN_TC_CLOPSIZECONF, &Dbdih::execTC_CLOPSIZECONF);
  177.   addRecSignal(GSN_LCP_COMPLETE_REP, &Dbdih::execLCP_COMPLETE_REP);
  178.   addRecSignal(GSN_LCP_FRAG_REP, &Dbdih::execLCP_FRAG_REP);
  179.   addRecSignal(GSN_START_LCP_REQ, &Dbdih::execSTART_LCP_REQ);
  180.   addRecSignal(GSN_START_LCP_CONF, &Dbdih::execSTART_LCP_CONF);
  181.   
  182.   addRecSignal(GSN_READ_CONFIG_REQ, &Dbdih::execREAD_CONFIG_REQ, true);
  183.   addRecSignal(GSN_UNBLO_DICTCONF, &Dbdih::execUNBLO_DICTCONF);
  184.   addRecSignal(GSN_COPY_ACTIVECONF, &Dbdih::execCOPY_ACTIVECONF);
  185.   addRecSignal(GSN_TAB_COMMITREQ, &Dbdih::execTAB_COMMITREQ);
  186.   addRecSignal(GSN_NODE_FAILREP, &Dbdih::execNODE_FAILREP);
  187.   addRecSignal(GSN_COPY_FRAGCONF, &Dbdih::execCOPY_FRAGCONF);
  188.   addRecSignal(GSN_COPY_FRAGREF, &Dbdih::execCOPY_FRAGREF);
  189.   addRecSignal(GSN_DIADDTABREQ, &Dbdih::execDIADDTABREQ);
  190.   addRecSignal(GSN_DIGETNODESREQ, &Dbdih::execDIGETNODESREQ);
  191.   addRecSignal(GSN_DIRELEASEREQ, &Dbdih::execDIRELEASEREQ);
  192.   addRecSignal(GSN_DISEIZEREQ, &Dbdih::execDISEIZEREQ);
  193.   addRecSignal(GSN_STTOR, &Dbdih::execSTTOR);
  194.   addRecSignal(GSN_DI_FCOUNTREQ, &Dbdih::execDI_FCOUNTREQ);
  195.   addRecSignal(GSN_DIGETPRIMREQ, &Dbdih::execDIGETPRIMREQ);
  196.   addRecSignal(GSN_GCP_SAVEREF, &Dbdih::execGCP_SAVEREF);
  197.   addRecSignal(GSN_GCP_TCFINISHED, &Dbdih::execGCP_TCFINISHED);
  198.   addRecSignal(GSN_READ_NODESCONF, &Dbdih::execREAD_NODESCONF);
  199.   addRecSignal(GSN_NDB_STTOR, &Dbdih::execNDB_STTOR);
  200.   addRecSignal(GSN_DICTSTARTCONF, &Dbdih::execDICTSTARTCONF);
  201.   addRecSignal(GSN_NDB_STARTREQ, &Dbdih::execNDB_STARTREQ);
  202.   addRecSignal(GSN_GETGCIREQ, &Dbdih::execGETGCIREQ);
  203.   addRecSignal(GSN_DIH_RESTARTREQ, &Dbdih::execDIH_RESTARTREQ);
  204.   addRecSignal(GSN_START_RECCONF, &Dbdih::execSTART_RECCONF);
  205.   addRecSignal(GSN_START_FRAGCONF, &Dbdih::execSTART_FRAGCONF);
  206.   addRecSignal(GSN_ADD_FRAGCONF, &Dbdih::execADD_FRAGCONF);
  207.   addRecSignal(GSN_ADD_FRAGREF, &Dbdih::execADD_FRAGREF);
  208.   addRecSignal(GSN_FSOPENCONF, &Dbdih::execFSOPENCONF);
  209.   addRecSignal(GSN_FSOPENREF, &Dbdih::execFSOPENREF, true);
  210.   addRecSignal(GSN_FSCLOSECONF, &Dbdih::execFSCLOSECONF);
  211.   addRecSignal(GSN_FSCLOSEREF, &Dbdih::execFSCLOSEREF, true);
  212.   addRecSignal(GSN_FSREADCONF, &Dbdih::execFSREADCONF);
  213.   addRecSignal(GSN_FSREADREF, &Dbdih::execFSREADREF, true);
  214.   addRecSignal(GSN_FSWRITECONF, &Dbdih::execFSWRITECONF);
  215.   addRecSignal(GSN_FSWRITEREF, &Dbdih::execFSWRITEREF, true);
  216.   addRecSignal(GSN_SET_VAR_REQ, &Dbdih::execSET_VAR_REQ);
  218.   addRecSignal(GSN_START_INFOREQ, 
  219.                &Dbdih::execSTART_INFOREQ);
  220.   addRecSignal(GSN_START_INFOREF, 
  221.                &Dbdih::execSTART_INFOREF);
  222.   addRecSignal(GSN_START_INFOCONF, 
  223.                &Dbdih::execSTART_INFOCONF);
  225.   addRecSignal(GSN_CHECKNODEGROUPSREQ, &Dbdih::execCHECKNODEGROUPSREQ);
  227.   addRecSignal(GSN_BLOCK_COMMIT_ORD,
  228.        &Dbdih::execBLOCK_COMMIT_ORD);
  229.   addRecSignal(GSN_UNBLOCK_COMMIT_ORD,
  230.        &Dbdih::execUNBLOCK_COMMIT_ORD);
  231.   
  232.   addRecSignal(GSN_DIH_SWITCH_REPLICA_REQ,
  233.        &Dbdih::execDIH_SWITCH_REPLICA_REQ);
  234.   
  235.   addRecSignal(GSN_DIH_SWITCH_REPLICA_REF,
  236.        &Dbdih::execDIH_SWITCH_REPLICA_REF);
  237.   
  238.   addRecSignal(GSN_DIH_SWITCH_REPLICA_CONF,
  239.        &Dbdih::execDIH_SWITCH_REPLICA_CONF);
  241.   addRecSignal(GSN_STOP_PERM_REQ, &Dbdih::execSTOP_PERM_REQ);
  242.   addRecSignal(GSN_STOP_PERM_REF, &Dbdih::execSTOP_PERM_REF);
  243.   addRecSignal(GSN_STOP_PERM_CONF, &Dbdih::execSTOP_PERM_CONF);
  245.   addRecSignal(GSN_STOP_ME_REQ, &Dbdih::execSTOP_ME_REQ);
  246.   addRecSignal(GSN_STOP_ME_REF, &Dbdih::execSTOP_ME_REF);
  247.   addRecSignal(GSN_STOP_ME_CONF, &Dbdih::execSTOP_ME_CONF);
  249.   addRecSignal(GSN_WAIT_GCP_REQ, &Dbdih::execWAIT_GCP_REQ);
  250.   addRecSignal(GSN_WAIT_GCP_REF, &Dbdih::execWAIT_GCP_REF);
  251.   addRecSignal(GSN_WAIT_GCP_CONF, &Dbdih::execWAIT_GCP_CONF);
  253.   addRecSignal(GSN_UPDATE_TOREQ, &Dbdih::execUPDATE_TOREQ);
  254.   addRecSignal(GSN_UPDATE_TOCONF, &Dbdih::execUPDATE_TOCONF);
  256.   addRecSignal(GSN_PREP_DROP_TAB_REQ, &Dbdih::execPREP_DROP_TAB_REQ);
  257.   addRecSignal(GSN_WAIT_DROP_TAB_REF, &Dbdih::execWAIT_DROP_TAB_REF);
  258.   addRecSignal(GSN_WAIT_DROP_TAB_CONF, &Dbdih::execWAIT_DROP_TAB_CONF);
  259.   addRecSignal(GSN_DROP_TAB_REQ, &Dbdih::execDROP_TAB_REQ);
  261.   addRecSignal(GSN_ALTER_TAB_REQ, &Dbdih::execALTER_TAB_REQ);
  263.   addRecSignal(GSN_CREATE_FRAGMENTATION_REQ, 
  264.        &Dbdih::execCREATE_FRAGMENTATION_REQ);
  265.   
  266.   initData();
  267. }//Dbdih::Dbdih()
  269. Dbdih::~Dbdih() 
  270. {
  271.   deallocRecord((void **)&apiConnectRecord, "ApiConnectRecord", 
  272.                 sizeof(ApiConnectRecord),
  273.                 capiConnectFileSize);
  274.   
  275.   deallocRecord((void **)&connectRecord, "ConnectRecord",
  276.                 sizeof(ConnectRecord), 
  277.                 cconnectFileSize);
  278.   
  279.   deallocRecord((void **)&fileRecord, "FileRecord",
  280.                 sizeof(FileRecord),
  281.                 cfileFileSize);
  282.   
  283.   deallocRecord((void **)&fragmentstore, "Fragmentstore",
  284.                 sizeof(Fragmentstore),
  285.                 cfragstoreFileSize);
  287.   deallocRecord((void **)&pageRecord, "PageRecord",
  288.                 sizeof(PageRecord), 
  289.                 cpageFileSize);
  290.   
  291.   deallocRecord((void **)&replicaRecord, "ReplicaRecord",
  292.                 sizeof(ReplicaRecord), 
  293.                 creplicaFileSize);
  294.   
  295.   deallocRecord((void **)&tabRecord, "TabRecord",
  296.                 sizeof(TabRecord), 
  297.                 ctabFileSize);
  299.   // Records with constant sizes
  300.   deallocRecord((void **)&createReplicaRecord, 
  301.                 "CreateReplicaRecord", sizeof(CreateReplicaRecord),
  302.                 ZCREATE_REPLICA_FILE_SIZE);
  303.   
  304.   deallocRecord((void **)&nodeGroupRecord, "NodeGroupRecord", 
  305.                 sizeof(NodeGroupRecord), MAX_NDB_NODES);
  306.   
  307.   deallocRecord((void **)&nodeRecord, "NodeRecord", 
  308.                 sizeof(NodeRecord), MAX_NDB_NODES);
  310.   deallocRecord((void **)&takeOverRecord, "TakeOverRecord",
  311.                 sizeof(TakeOverRecord), 
  312.                 MAX_NDB_NODES);
  314. }//Dbdih::~Dbdih()
  316. BLOCK_FUNCTIONS(Dbdih)