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

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

MySQL数据库

开发平台：

Visual C++

DbaccInit.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 */
  19. #define DBACC_C
  20. #include "Dbacc.hpp"
  22. #define DEBUG(x) { ndbout << "ACC::" << x << endl; }
  24. void Dbacc::initData() 
  25. {
  26.   cdirarraysize = ZDIRARRAY;
  27.   coprecsize = ZOPRECSIZE;
  28.   cpagesize = ZPAGESIZE;
  29.   clcpConnectsize = ZLCP_CONNECTSIZE;
  30.   ctablesize = ZTABLESIZE;
  31.   cfragmentsize = ZFRAGMENTSIZE;
  32.   crootfragmentsize = ZROOTFRAGMENTSIZE;
  33.   cdirrangesize = ZDIRRANGESIZE;
  34.   coverflowrecsize = ZOVERFLOWRECSIZE;
  35.   cfsConnectsize = ZFS_CONNECTSIZE;
  36.   cfsOpsize = ZFS_OPSIZE;
  37.   cscanRecSize = ZSCAN_REC_SIZE;
  38.   csrVersionRecSize = ZSR_VERSION_REC_SIZE;
  40.   
  41.   dirRange = 0;
  42.   directoryarray = 0;
  43.   fragmentrec = 0;
  44.   fsConnectrec = 0;
  45.   fsOprec = 0;
  46.   lcpConnectrec = 0;
  47.   operationrec = 0;
  48.   overflowRecord = 0;
  49.   page8 = 0;
  50.   rootfragmentrec = 0;
  51.   scanRec = 0;
  52.   srVersionRec = 0;
  53.   tabrec = 0;
  54.   undopage = 0;
  56.   // Records with constant sizes
  57. }//Dbacc::initData()
  59. void Dbacc::initRecords() 
  60. {
  61.   // Records with dynamic sizes
  62.   dirRange = (DirRange*)allocRecord("DirRange",
  63.     sizeof(DirRange), 
  64.     cdirrangesize);
  66.   directoryarray = (Directoryarray*)allocRecord("Directoryarray",
  67. sizeof(Directoryarray), 
  68. cdirarraysize);
  70.   fragmentrec = (Fragmentrec*)allocRecord("Fragmentrec",
  71.   sizeof(Fragmentrec), 
  72.   cfragmentsize);
  74.   fsConnectrec = (FsConnectrec*)allocRecord("FsConnectrec",
  75.     sizeof(FsConnectrec), 
  76.     cfsConnectsize);
  78.   fsOprec = (FsOprec*)allocRecord("FsOprec",
  79.   sizeof(FsOprec), 
  80.   cfsOpsize);
  82.   lcpConnectrec = (LcpConnectrec*)allocRecord("LcpConnectrec",
  83.       sizeof(LcpConnectrec),
  84.       clcpConnectsize);
  86.   operationrec = (Operationrec*)allocRecord("Operationrec",
  87.     sizeof(Operationrec),
  88.     coprecsize);
  90.   overflowRecord = (OverflowRecord*)allocRecord("OverflowRecord",
  91. sizeof(OverflowRecord),
  92. coverflowrecsize);
  94.   page8 = (Page8*)allocRecord("Page8",
  95.       sizeof(Page8), 
  96.       cpagesize,
  97.       false);
  99.   rootfragmentrec = (Rootfragmentrec*)allocRecord("Rootfragmentrec",
  100.   sizeof(Rootfragmentrec), 
  101.   crootfragmentsize);
  103.   scanRec = (ScanRec*)allocRecord("ScanRec",
  104.   sizeof(ScanRec), 
  105.   cscanRecSize);
  107.   srVersionRec = (SrVersionRec*)allocRecord("SrVersionRec",
  108.     sizeof(SrVersionRec), 
  109.     csrVersionRecSize);
  111.   tabrec = (Tabrec*)allocRecord("Tabrec",
  112. sizeof(Tabrec),
  113. ctablesize);
  115.   undopage = (Undopage*)allocRecord("Undopage",
  116.     sizeof(Undopage), 
  117.     cundopagesize,
  118.     false);
  119.   
  120.   // Initialize BAT for interface to file system
  122.   NewVARIABLE* bat = allocateBat(3);
  123.   bat[1].WA = &page8->word32[0];
  124.   bat[1].nrr = cpagesize;
  125.   bat[1].ClusterSize = sizeof(Page8);
  126.   bat[1].bits.q = 11;
  127.   bat[1].bits.v = 5;
  128.   bat[2].WA = &undopage->undoword[0];
  129.   bat[2].nrr = cundopagesize;
  130.   bat[2].ClusterSize = sizeof(Undopage);
  131.   bat[2].bits.q = 13;
  132.   bat[2].bits.v = 5;
  133. }//Dbacc::initRecords()
  135. Dbacc::Dbacc(const class Configuration & conf):
  136.   SimulatedBlock(DBACC, conf)
  137. {
  138.   Uint32 log_page_size= 0;
  139.   BLOCK_CONSTRUCTOR(Dbacc);
  141.   const ndb_mgm_configuration_iterator * p = conf.getOwnConfigIterator();
  142.   ndbrequire(p != 0);
  144.   ndb_mgm_get_int_parameter(p, CFG_DB_UNDO_INDEX_BUFFER,  
  145.     &log_page_size);
  147.   /**
  148.    * Always set page size in half MBytes
  149.    */
  150.   cundopagesize= (log_page_size / sizeof(Undopage));
  151.   Uint32 mega_byte_part= cundopagesize & 15;
  152.   if (mega_byte_part != 0) {
  153.     jam();
  154.     cundopagesize+= (16 - mega_byte_part);
  155.   }
  157.   // Transit signals
  158.   addRecSignal(GSN_DUMP_STATE_ORD, &Dbacc::execDUMP_STATE_ORD);
  159.   addRecSignal(GSN_DEBUG_SIG, &Dbacc::execDEBUG_SIG);
  160.   addRecSignal(GSN_CONTINUEB, &Dbacc::execCONTINUEB);
  161.   addRecSignal(GSN_ACC_CHECK_SCAN, &Dbacc::execACC_CHECK_SCAN);
  162.   addRecSignal(GSN_EXPANDCHECK2, &Dbacc::execEXPANDCHECK2);
  163.   addRecSignal(GSN_SHRINKCHECK2, &Dbacc::execSHRINKCHECK2);
  164.   addRecSignal(GSN_ACC_OVER_REC, &Dbacc::execACC_OVER_REC);
  165.   addRecSignal(GSN_ACC_SAVE_PAGES, &Dbacc::execACC_SAVE_PAGES);
  166.   addRecSignal(GSN_NEXTOPERATION, &Dbacc::execNEXTOPERATION);
  167.   addRecSignal(GSN_READ_PSUEDO_REQ, &Dbacc::execREAD_PSUEDO_REQ);
  169.   // Received signals
  170.   addRecSignal(GSN_STTOR, &Dbacc::execSTTOR);
  171.   addRecSignal(GSN_SR_FRAGIDREQ, &Dbacc::execSR_FRAGIDREQ);
  172.   addRecSignal(GSN_LCP_FRAGIDREQ, &Dbacc::execLCP_FRAGIDREQ);
  173.   addRecSignal(GSN_LCP_HOLDOPREQ, &Dbacc::execLCP_HOLDOPREQ);
  174.   addRecSignal(GSN_END_LCPREQ, &Dbacc::execEND_LCPREQ);
  175.   addRecSignal(GSN_ACC_LCPREQ, &Dbacc::execACC_LCPREQ);
  176.   addRecSignal(GSN_START_RECREQ, &Dbacc::execSTART_RECREQ);
  177.   addRecSignal(GSN_ACC_CONTOPREQ, &Dbacc::execACC_CONTOPREQ);
  178.   addRecSignal(GSN_ACCKEYREQ, &Dbacc::execACCKEYREQ);
  179.   addRecSignal(GSN_ACCSEIZEREQ, &Dbacc::execACCSEIZEREQ);
  180.   addRecSignal(GSN_ACCFRAGREQ, &Dbacc::execACCFRAGREQ);
  181.   addRecSignal(GSN_ACC_SRREQ, &Dbacc::execACC_SRREQ);
  182.   addRecSignal(GSN_NEXT_SCANREQ, &Dbacc::execNEXT_SCANREQ);
  183.   addRecSignal(GSN_ACC_ABORTREQ, &Dbacc::execACC_ABORTREQ);
  184.   addRecSignal(GSN_ACC_SCANREQ, &Dbacc::execACC_SCANREQ);
  185.   addRecSignal(GSN_ACCMINUPDATE, &Dbacc::execACCMINUPDATE);
  186.   addRecSignal(GSN_ACC_COMMITREQ, &Dbacc::execACC_COMMITREQ);
  187.   addRecSignal(GSN_ACC_TO_REQ, &Dbacc::execACC_TO_REQ);
  188.   addRecSignal(GSN_ACC_LOCKREQ, &Dbacc::execACC_LOCKREQ);
  189.   addRecSignal(GSN_FSOPENCONF, &Dbacc::execFSOPENCONF);
  190.   addRecSignal(GSN_FSCLOSECONF, &Dbacc::execFSCLOSECONF);
  191.   addRecSignal(GSN_FSWRITECONF, &Dbacc::execFSWRITECONF);
  192.   addRecSignal(GSN_FSREADCONF, &Dbacc::execFSREADCONF);
  193.   addRecSignal(GSN_NDB_STTOR, &Dbacc::execNDB_STTOR);
  194.   addRecSignal(GSN_DROP_TAB_REQ, &Dbacc::execDROP_TAB_REQ);
  195.   addRecSignal(GSN_FSREMOVECONF, &Dbacc::execFSREMOVECONF);
  196.   addRecSignal(GSN_READ_CONFIG_REQ, &Dbacc::execREAD_CONFIG_REQ, true);
  197.   addRecSignal(GSN_SET_VAR_REQ,  &Dbacc::execSET_VAR_REQ);
  199.   initData();
  200. }//Dbacc::Dbacc()
  202. Dbacc::~Dbacc() 
  203. {
  204.   deallocRecord((void **)&dirRange, "DirRange",
  205. sizeof(DirRange), 
  206. cdirrangesize);
  207.   
  208.   deallocRecord((void **)&directoryarray, "Directoryarray",
  209. sizeof(Directoryarray), 
  210. cdirarraysize);
  211.   
  212.   deallocRecord((void **)&fragmentrec, "Fragmentrec",
  213. sizeof(Fragmentrec), 
  214. cfragmentsize);
  215.   
  216.   deallocRecord((void **)&fsConnectrec, "FsConnectrec",
  217. sizeof(FsConnectrec), 
  218. cfsConnectsize);
  219.   
  220.   deallocRecord((void **)&fsOprec, "FsOprec",
  221. sizeof(FsOprec), 
  222. cfsOpsize);
  223.   
  224.   deallocRecord((void **)&lcpConnectrec, "LcpConnectrec",
  225. sizeof(LcpConnectrec),
  226. clcpConnectsize);
  227.   
  228.   deallocRecord((void **)&operationrec, "Operationrec",
  229. sizeof(Operationrec),
  230. coprecsize);
  231.   
  232.   deallocRecord((void **)&overflowRecord, "OverflowRecord",
  233. sizeof(OverflowRecord),
  234. coverflowrecsize);
  236.   deallocRecord((void **)&page8, "Page8",
  237. sizeof(Page8), 
  238. cpagesize);
  239.   
  240.   deallocRecord((void **)&rootfragmentrec, "Rootfragmentrec",
  241. sizeof(Rootfragmentrec), 
  242. crootfragmentsize);
  243.   
  244.   deallocRecord((void **)&scanRec, "ScanRec",
  245. sizeof(ScanRec), 
  246. cscanRecSize);
  247.   
  248.   deallocRecord((void **)&srVersionRec, "SrVersionRec",
  249. sizeof(SrVersionRec), 
  250. csrVersionRecSize);
  251.   
  252.   deallocRecord((void **)&tabrec, "Tabrec",
  253. sizeof(Tabrec),
  254. ctablesize);
  255.   
  256.   deallocRecord((void **)&undopage, "Undopage",
  257. sizeof(Undopage), 
  258. cundopagesize);
  260. }//Dbacc::~Dbacc()
  262. BLOCK_FUNCTIONS(Dbacc)