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

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

MySQL数据库

开发平台：

Visual C++

DblqhInit.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. #include <pc.hpp>
  19. #define DBLQH_C
  20. #include "Dblqh.hpp"
  21. #include <ndb_limits.h>
  23. #define DEBUG(x) { ndbout << "LQH::" << x << endl; }
  25. void Dblqh::initData() 
  26. {
  27.   caddfragrecFileSize = ZADDFRAGREC_FILE_SIZE;
  28.   cattrinbufFileSize = ZATTRINBUF_FILE_SIZE;
  29.   c_no_attrinbuf_recs= ZATTRINBUF_FILE_SIZE;
  30.   cdatabufFileSize = ZDATABUF_FILE_SIZE;
  31.   cfragrecFileSize = 0;
  32.   cgcprecFileSize = ZGCPREC_FILE_SIZE;
  33.   chostFileSize = MAX_NDB_NODES;
  34.   clcpFileSize = ZNO_CONCURRENT_LCP;
  35.   clcpLocrecFileSize = ZLCP_LOCREC_FILE_SIZE;
  36.   clfoFileSize = ZLFO_FILE_SIZE;
  37.   clogFileFileSize = 0;
  38.   clogPartFileSize = ZLOG_PART_FILE_SIZE;
  39.   cpageRefFileSize = ZPAGE_REF_FILE_SIZE;
  40.   cscanrecFileSize = ZSCANREC_FILE_SIZE;
  41.   ctabrecFileSize = 0;
  42.   ctcConnectrecFileSize = 0;
  43.   ctcNodeFailrecFileSize = MAX_NDB_NODES;
  45.   addFragRecord = 0;
  46.   attrbuf = 0;
  47.   databuf = 0;
  48.   fragrecord = 0;
  49.   gcpRecord = 0;
  50.   hostRecord = 0;
  51.   lcpRecord = 0;
  52.   lcpLocRecord = 0;
  53.   logPartRecord = 0;
  54.   logFileRecord = 0;
  55.   logFileOperationRecord = 0;
  56.   logPageRecord = 0;
  57.   pageRefRecord = 0;
  58.   tablerec = 0;
  59.   tcConnectionrec = 0;
  60.   tcNodeFailRecord = 0;
  61.   
  62.   // Records with constant sizes
  64.   cLqhTimeOutCount = 0;
  65.   cLqhTimeOutCheckCount = 0;
  66.   cbookedAccOps = 0;
  67.   c_redo_log_complete_frags = RNIL;
  68. }//Dblqh::initData()
  70. void Dblqh::initRecords() 
  71. {
  72.   // Records with dynamic sizes
  73.   addFragRecord = (AddFragRecord*)allocRecord("AddFragRecord",
  74.       sizeof(AddFragRecord), 
  75.       caddfragrecFileSize);
  76.   attrbuf = (Attrbuf*)allocRecord("Attrbuf",
  77.   sizeof(Attrbuf), 
  78.   cattrinbufFileSize);
  80.   databuf = (Databuf*)allocRecord("Databuf",
  81.   sizeof(Databuf), 
  82.   cdatabufFileSize);
  84.   fragrecord = (Fragrecord*)allocRecord("Fragrecord",
  85. sizeof(Fragrecord), 
  86. cfragrecFileSize);
  88.   gcpRecord = (GcpRecord*)allocRecord("GcpRecord",
  89.       sizeof(GcpRecord), 
  90.       cgcprecFileSize);
  92.   hostRecord = (HostRecord*)allocRecord("HostRecord",
  93. sizeof(HostRecord), 
  94. chostFileSize);
  96.   lcpRecord = (LcpRecord*)allocRecord("LcpRecord",
  97.       sizeof(LcpRecord), 
  98.       clcpFileSize);
  100.   for(Uint32 i = 0; i<clcpFileSize; i++){
  101.     new (&lcpRecord[i])LcpRecord();
  102.   }
  104.   lcpLocRecord = (LcpLocRecord*)allocRecord("LcpLocRecord",
  105.     sizeof(LcpLocRecord), 
  106.     clcpLocrecFileSize);
  108.   logPartRecord = (LogPartRecord*)allocRecord("LogPartRecord",
  109.       sizeof(LogPartRecord), 
  110.       clogPartFileSize);
  112.   logFileRecord = (LogFileRecord*)allocRecord("LogFileRecord",
  113.       sizeof(LogFileRecord),
  114.       clogFileFileSize);
  116.   logFileOperationRecord = (LogFileOperationRecord*)
  117.     allocRecord("LogFileOperationRecord", 
  118. sizeof(LogFileOperationRecord), 
  119. clfoFileSize);
  121.   logPageRecord = (LogPageRecord*)allocRecord("LogPageRecord",
  122.       sizeof(LogPageRecord),
  123.       clogPageFileSize,
  124.       false);
  126.   pageRefRecord = (PageRefRecord*)allocRecord("PageRefRecord",
  127.       sizeof(PageRefRecord),
  128.       cpageRefFileSize);
  130.   cscanNoFreeRec = cscanrecFileSize;
  131.   c_scanRecordPool.setSize(cscanrecFileSize);
  132.   c_scanTakeOverHash.setSize(64);
  134.   tablerec = (Tablerec*)allocRecord("Tablerec",
  135.     sizeof(Tablerec), 
  136.     ctabrecFileSize);
  138.   tcConnectionrec = (TcConnectionrec*)allocRecord("TcConnectionrec",
  139.   sizeof(TcConnectionrec),
  140.   ctcConnectrecFileSize);
  141.   
  142.   m_commitAckMarkerPool.setSize(ctcConnectrecFileSize);
  143.   m_commitAckMarkerHash.setSize(1024);
  144.   
  145.   tcNodeFailRecord = (TcNodeFailRecord*)allocRecord("TcNodeFailRecord",
  146.     sizeof(TcNodeFailRecord),
  147.     ctcNodeFailrecFileSize);
  148.   
  149.   /*
  150.   ndbout << "FRAGREC SIZE = " << sizeof(Fragrecord) << endl;
  151.   ndbout << "TAB SIZE = " << sizeof(Tablerec) << endl;
  152.   ndbout << "GCP SIZE = " << sizeof(GcpRecord) << endl;
  153.   ndbout << "LCP SIZE = " << sizeof(LcpRecord) << endl;
  154.   ndbout << "LCPLOC SIZE = " << sizeof(LcpLocRecord) << endl;
  155.   ndbout << "LOGPART SIZE = " << sizeof(LogPartRecord) << endl;
  156.   ndbout << "LOGFILE SIZE = " << sizeof(LogFileRecord) << endl;
  157.   ndbout << "TC SIZE = " << sizeof(TcConnectionrec) << endl;
  158.   ndbout << "HOST SIZE = " << sizeof(HostRecord) << endl;
  159.   ndbout << "LFO SIZE = " << sizeof(LogFileOperationRecord) << endl;
  160.   ndbout << "PR SIZE = " << sizeof(PageRefRecord) << endl;
  161.   ndbout << "SCAN SIZE = " << sizeof(ScanRecord) << endl;
  162. */
  164.   // Initialize BAT for interface to file system
  165.   NewVARIABLE* bat = allocateBat(2);
  166.   bat[1].WA = &logPageRecord->logPageWord[0];
  167.   bat[1].nrr = clogPageFileSize;
  168.   bat[1].ClusterSize = sizeof(LogPageRecord);
  169.   bat[1].bits.q = ZTWOLOG_PAGE_SIZE;
  170.   bat[1].bits.v = 5;
  171. }//Dblqh::initRecords()
  173. Dblqh::Dblqh(const class Configuration & conf):
  174.   SimulatedBlock(DBLQH, conf),
  175.   m_commitAckMarkerHash(m_commitAckMarkerPool),
  176.   c_scanTakeOverHash(c_scanRecordPool)
  177. {
  178.   Uint32 log_page_size= 0;
  179.   BLOCK_CONSTRUCTOR(Dblqh);
  181.   const ndb_mgm_configuration_iterator * p = conf.getOwnConfigIterator();
  182.   ndbrequire(p != 0);
  184.   ndb_mgm_get_int_parameter(p, CFG_DB_REDO_BUFFER,  
  185.     &log_page_size);
  187.   /**
  188.    * Always set page size in half MBytes
  189.    */
  190.   clogPageFileSize= (log_page_size / sizeof(LogPageRecord));
  191.   Uint32 mega_byte_part= clogPageFileSize & 15;
  192.   if (mega_byte_part != 0) {
  193.     jam();
  194.     clogPageFileSize+= (16 - mega_byte_part);
  195.   }
  197.   addRecSignal(GSN_PACKED_SIGNAL, &Dblqh::execPACKED_SIGNAL);
  198.   addRecSignal(GSN_DEBUG_SIG, &Dblqh::execDEBUG_SIG);
  199.   addRecSignal(GSN_ATTRINFO, &Dblqh::execATTRINFO);
  200.   addRecSignal(GSN_KEYINFO, &Dblqh::execKEYINFO);
  201.   addRecSignal(GSN_LQHKEYREQ, &Dblqh::execLQHKEYREQ);
  202.   addRecSignal(GSN_LQHKEYREF, &Dblqh::execLQHKEYREF);
  203.   addRecSignal(GSN_COMMIT, &Dblqh::execCOMMIT);
  204.   addRecSignal(GSN_COMPLETE, &Dblqh::execCOMPLETE);
  205.   addRecSignal(GSN_LQHKEYCONF, &Dblqh::execLQHKEYCONF);
  206. #ifdef VM_TRACE
  207.   addRecSignal(GSN_TESTSIG, &Dblqh::execTESTSIG);
  208. #endif
  209.   addRecSignal(GSN_LQH_RESTART_OP, &Dblqh::execLQH_RESTART_OP);
  210.   addRecSignal(GSN_CONTINUEB, &Dblqh::execCONTINUEB);
  211.   addRecSignal(GSN_START_RECREQ, &Dblqh::execSTART_RECREQ);
  212.   addRecSignal(GSN_START_RECCONF, &Dblqh::execSTART_RECCONF);
  213.   addRecSignal(GSN_EXEC_FRAGREQ, &Dblqh::execEXEC_FRAGREQ);
  214.   addRecSignal(GSN_EXEC_FRAGCONF, &Dblqh::execEXEC_FRAGCONF);
  215.   addRecSignal(GSN_EXEC_FRAGREF, &Dblqh::execEXEC_FRAGREF);
  216.   addRecSignal(GSN_START_EXEC_SR, &Dblqh::execSTART_EXEC_SR);
  217.   addRecSignal(GSN_EXEC_SRREQ, &Dblqh::execEXEC_SRREQ);
  218.   addRecSignal(GSN_EXEC_SRCONF, &Dblqh::execEXEC_SRCONF);
  219.   addRecSignal(GSN_SCAN_HBREP, &Dblqh::execSCAN_HBREP);
  221.   addRecSignal(GSN_ALTER_TAB_REQ, &Dblqh::execALTER_TAB_REQ);
  223.   // Trigger signals, transit to from TUP
  224.   addRecSignal(GSN_CREATE_TRIG_REQ, &Dblqh::execCREATE_TRIG_REQ);
  225.   addRecSignal(GSN_CREATE_TRIG_CONF, &Dblqh::execCREATE_TRIG_CONF);
  226.   addRecSignal(GSN_CREATE_TRIG_REF, &Dblqh::execCREATE_TRIG_REF);
  228.   addRecSignal(GSN_DROP_TRIG_REQ, &Dblqh::execDROP_TRIG_REQ);
  229.   addRecSignal(GSN_DROP_TRIG_CONF, &Dblqh::execDROP_TRIG_CONF);
  230.   addRecSignal(GSN_DROP_TRIG_REF, &Dblqh::execDROP_TRIG_REF);
  232.   addRecSignal(GSN_DUMP_STATE_ORD, &Dblqh::execDUMP_STATE_ORD);
  233.   addRecSignal(GSN_ACC_COM_BLOCK, &Dblqh::execACC_COM_BLOCK);
  234.   addRecSignal(GSN_ACC_COM_UNBLOCK, &Dblqh::execACC_COM_UNBLOCK);
  235.   addRecSignal(GSN_TUP_COM_BLOCK, &Dblqh::execTUP_COM_BLOCK);
  236.   addRecSignal(GSN_TUP_COM_UNBLOCK, &Dblqh::execTUP_COM_UNBLOCK);
  237.   addRecSignal(GSN_NODE_FAILREP, &Dblqh::execNODE_FAILREP);
  238.   addRecSignal(GSN_CHECK_LCP_STOP, &Dblqh::execCHECK_LCP_STOP);
  239.   addRecSignal(GSN_SEND_PACKED, &Dblqh::execSEND_PACKED);
  240.   addRecSignal(GSN_TUP_ATTRINFO, &Dblqh::execTUP_ATTRINFO);
  241.   addRecSignal(GSN_READ_CONFIG_REQ, &Dblqh::execREAD_CONFIG_REQ, true);
  242.   addRecSignal(GSN_LQHFRAGREQ, &Dblqh::execLQHFRAGREQ);
  243.   addRecSignal(GSN_LQHADDATTREQ, &Dblqh::execLQHADDATTREQ);
  244.   addRecSignal(GSN_TUP_ADD_ATTCONF, &Dblqh::execTUP_ADD_ATTCONF);
  245.   addRecSignal(GSN_TUP_ADD_ATTRREF, &Dblqh::execTUP_ADD_ATTRREF);
  246.   addRecSignal(GSN_ACCFRAGCONF, &Dblqh::execACCFRAGCONF);
  247.   addRecSignal(GSN_ACCFRAGREF, &Dblqh::execACCFRAGREF);
  248.   addRecSignal(GSN_TUPFRAGCONF, &Dblqh::execTUPFRAGCONF);
  249.   addRecSignal(GSN_TUPFRAGREF, &Dblqh::execTUPFRAGREF);
  250.   addRecSignal(GSN_TAB_COMMITREQ, &Dblqh::execTAB_COMMITREQ);
  251.   addRecSignal(GSN_ACCSEIZECONF, &Dblqh::execACCSEIZECONF);
  252.   addRecSignal(GSN_ACCSEIZEREF, &Dblqh::execACCSEIZEREF);
  253.   addRecSignal(GSN_READ_NODESCONF, &Dblqh::execREAD_NODESCONF);
  254.   addRecSignal(GSN_READ_NODESREF, &Dblqh::execREAD_NODESREF);
  255.   addRecSignal(GSN_STTOR, &Dblqh::execSTTOR);
  256.   addRecSignal(GSN_NDB_STTOR, &Dblqh::execNDB_STTOR);
  257.   addRecSignal(GSN_TUPSEIZECONF, &Dblqh::execTUPSEIZECONF);
  258.   addRecSignal(GSN_TUPSEIZEREF, &Dblqh::execTUPSEIZEREF);
  259.   addRecSignal(GSN_ACCKEYCONF, &Dblqh::execACCKEYCONF);
  260.   addRecSignal(GSN_ACCKEYREF, &Dblqh::execACCKEYREF);
  261.   addRecSignal(GSN_TUPKEYCONF, &Dblqh::execTUPKEYCONF);
  262.   addRecSignal(GSN_TUPKEYREF, &Dblqh::execTUPKEYREF);
  263.   addRecSignal(GSN_ABORT, &Dblqh::execABORT);
  264.   addRecSignal(GSN_ABORTREQ, &Dblqh::execABORTREQ);
  265.   addRecSignal(GSN_COMMITREQ, &Dblqh::execCOMMITREQ);
  266.   addRecSignal(GSN_COMPLETEREQ, &Dblqh::execCOMPLETEREQ);
  267. #ifdef VM_TRACE
  268.   addRecSignal(GSN_MEMCHECKREQ, &Dblqh::execMEMCHECKREQ);
  269. #endif
  270.   addRecSignal(GSN_SCAN_FRAGREQ, &Dblqh::execSCAN_FRAGREQ);
  271.   addRecSignal(GSN_SCAN_NEXTREQ, &Dblqh::execSCAN_NEXTREQ);
  272.   addRecSignal(GSN_ACC_SCANCONF, &Dblqh::execACC_SCANCONF);
  273.   addRecSignal(GSN_ACC_SCANREF, &Dblqh::execACC_SCANREF);
  274.   addRecSignal(GSN_NEXT_SCANCONF, &Dblqh::execNEXT_SCANCONF);
  275.   addRecSignal(GSN_NEXT_SCANREF, &Dblqh::execNEXT_SCANREF);
  276.   addRecSignal(GSN_ACC_SCAN_INFO, &Dblqh::execACC_SCAN_INFO);
  277.   addRecSignal(GSN_ACC_SCAN_INFO24, &Dblqh::execACC_SCAN_INFO24);
  278.   addRecSignal(GSN_STORED_PROCCONF, &Dblqh::execSTORED_PROCCONF);
  279.   addRecSignal(GSN_STORED_PROCREF, &Dblqh::execSTORED_PROCREF);
  280.   addRecSignal(GSN_COPY_FRAGREQ, &Dblqh::execCOPY_FRAGREQ);
  281.   addRecSignal(GSN_COPY_ACTIVEREQ, &Dblqh::execCOPY_ACTIVEREQ);
  282.   addRecSignal(GSN_COPY_STATEREQ, &Dblqh::execCOPY_STATEREQ);
  283.   addRecSignal(GSN_LQH_TRANSREQ, &Dblqh::execLQH_TRANSREQ);
  284.   addRecSignal(GSN_TRANSID_AI, &Dblqh::execTRANSID_AI);
  285.   addRecSignal(GSN_INCL_NODEREQ, &Dblqh::execINCL_NODEREQ);
  286.   addRecSignal(GSN_ACC_LCPCONF, &Dblqh::execACC_LCPCONF);
  287.   addRecSignal(GSN_ACC_LCPREF, &Dblqh::execACC_LCPREF);
  288.   addRecSignal(GSN_ACC_LCPSTARTED, &Dblqh::execACC_LCPSTARTED);
  289.   addRecSignal(GSN_ACC_CONTOPCONF, &Dblqh::execACC_CONTOPCONF);
  290.   addRecSignal(GSN_LCP_FRAGIDCONF, &Dblqh::execLCP_FRAGIDCONF);
  291.   addRecSignal(GSN_LCP_FRAGIDREF, &Dblqh::execLCP_FRAGIDREF);
  292.   addRecSignal(GSN_LCP_HOLDOPCONF, &Dblqh::execLCP_HOLDOPCONF);
  293.   addRecSignal(GSN_LCP_HOLDOPREF, &Dblqh::execLCP_HOLDOPREF);
  294.   addRecSignal(GSN_TUP_PREPLCPCONF, &Dblqh::execTUP_PREPLCPCONF);
  295.   addRecSignal(GSN_TUP_PREPLCPREF, &Dblqh::execTUP_PREPLCPREF);
  296.   addRecSignal(GSN_TUP_LCPCONF, &Dblqh::execTUP_LCPCONF);
  297.   addRecSignal(GSN_TUP_LCPREF, &Dblqh::execTUP_LCPREF);
  298.   addRecSignal(GSN_TUP_LCPSTARTED, &Dblqh::execTUP_LCPSTARTED);
  299.   addRecSignal(GSN_END_LCPCONF, &Dblqh::execEND_LCPCONF);
  301.   addRecSignal(GSN_EMPTY_LCP_REQ, &Dblqh::execEMPTY_LCP_REQ);
  302.   addRecSignal(GSN_LCP_FRAG_ORD, &Dblqh::execLCP_FRAG_ORD);
  303.   
  304.   addRecSignal(GSN_START_FRAGREQ, &Dblqh::execSTART_FRAGREQ);
  305.   addRecSignal(GSN_START_RECREF, &Dblqh::execSTART_RECREF);
  306.   addRecSignal(GSN_SR_FRAGIDCONF, &Dblqh::execSR_FRAGIDCONF);
  307.   addRecSignal(GSN_SR_FRAGIDREF, &Dblqh::execSR_FRAGIDREF);
  308.   addRecSignal(GSN_ACC_SRCONF, &Dblqh::execACC_SRCONF);
  309.   addRecSignal(GSN_ACC_SRREF, &Dblqh::execACC_SRREF);
  310.   addRecSignal(GSN_TUP_SRCONF, &Dblqh::execTUP_SRCONF);
  311.   addRecSignal(GSN_TUP_SRREF, &Dblqh::execTUP_SRREF);
  312.   addRecSignal(GSN_GCP_SAVEREQ, &Dblqh::execGCP_SAVEREQ);
  313.   addRecSignal(GSN_FSOPENCONF, &Dblqh::execFSOPENCONF);
  314.   addRecSignal(GSN_FSCLOSECONF, &Dblqh::execFSCLOSECONF);
  315.   addRecSignal(GSN_FSWRITECONF, &Dblqh::execFSWRITECONF);
  316.   addRecSignal(GSN_FSWRITEREF, &Dblqh::execFSWRITEREF, true);
  317.   addRecSignal(GSN_FSREADCONF, &Dblqh::execFSREADCONF);
  318.   addRecSignal(GSN_FSREADREF, &Dblqh::execFSREADREF, true);
  319.   addRecSignal(GSN_ACC_ABORTCONF, &Dblqh::execACC_ABORTCONF);
  320.   addRecSignal(GSN_SET_VAR_REQ,  &Dblqh::execSET_VAR_REQ);
  321.   addRecSignal(GSN_TIME_SIGNAL,  &Dblqh::execTIME_SIGNAL);
  322.   addRecSignal(GSN_FSSYNCCONF,  &Dblqh::execFSSYNCCONF);
  323.   addRecSignal(GSN_REMOVE_MARKER_ORD, &Dblqh::execREMOVE_MARKER_ORD);
  325.   //addRecSignal(GSN_DROP_TAB_REQ, &Dblqh::execDROP_TAB_REQ);
  326.   addRecSignal(GSN_PREP_DROP_TAB_REQ, &Dblqh::execPREP_DROP_TAB_REQ);
  327.   addRecSignal(GSN_WAIT_DROP_TAB_REQ, &Dblqh::execWAIT_DROP_TAB_REQ);
  328.   addRecSignal(GSN_DROP_TAB_REQ, &Dblqh::execDROP_TAB_REQ);
  330.   addRecSignal(GSN_LQH_ALLOCREQ, &Dblqh::execLQH_ALLOCREQ);
  331.   addRecSignal(GSN_LQH_WRITELOG_REQ, &Dblqh::execLQH_WRITELOG_REQ);
  333.   // TUX
  334.   addRecSignal(GSN_TUXFRAGCONF, &Dblqh::execTUXFRAGCONF);
  335.   addRecSignal(GSN_TUXFRAGREF, &Dblqh::execTUXFRAGREF);
  336.   addRecSignal(GSN_TUX_ADD_ATTRCONF, &Dblqh::execTUX_ADD_ATTRCONF);
  337.   addRecSignal(GSN_TUX_ADD_ATTRREF, &Dblqh::execTUX_ADD_ATTRREF);
  339.   addRecSignal(GSN_READ_PSUEDO_REQ, &Dblqh::execREAD_PSUEDO_REQ);
  341.   initData();
  343. #ifdef VM_TRACE
  344.   {
  345.     void* tmp[] = { 
  346.       &addfragptr,
  347.       &attrinbufptr,
  348.       &databufptr,
  349.       &fragptr,
  350.       &gcpPtr,
  351.       &lcpPtr,
  352.       &lcpLocptr,
  353.       &logPartPtr,
  354.       &logFilePtr,
  355.       &lfoPtr,
  356.       &logPagePtr,
  357.       &pageRefPtr,
  358.       &scanptr,
  359.       &tabptr,
  360.       &tcConnectptr,
  361.       &tcNodeFailptr,
  362.     }; 
  363.     init_globals_list(tmp, sizeof(tmp)/sizeof(tmp[0]));
  364.   }
  365. #endif
  366.   
  367. }//Dblqh::Dblqh()
  369. Dblqh::~Dblqh() 
  370. {
  371.   // Records with dynamic sizes
  372.   deallocRecord((void **)&addFragRecord, "AddFragRecord",
  373. sizeof(AddFragRecord), 
  374. caddfragrecFileSize);
  376.   deallocRecord((void**)&attrbuf,
  377. "Attrbuf",
  378. sizeof(Attrbuf), 
  379. cattrinbufFileSize);
  381.   deallocRecord((void**)&databuf,
  382. "Databuf",
  383. sizeof(Databuf), 
  384. cdatabufFileSize);
  386.   deallocRecord((void**)&fragrecord,
  387. "Fragrecord",
  388. sizeof(Fragrecord), 
  389. cfragrecFileSize);
  390.   
  391.   deallocRecord((void**)&gcpRecord,
  392. "GcpRecord",
  393. sizeof(GcpRecord), 
  394. cgcprecFileSize);
  395.   
  396.   deallocRecord((void**)&hostRecord,
  397. "HostRecord",
  398. sizeof(HostRecord), 
  399. chostFileSize);
  400.   
  401.   deallocRecord((void**)&lcpRecord,
  402. "LcpRecord",
  403. sizeof(LcpRecord), 
  404. clcpFileSize);
  406.   deallocRecord((void**)&lcpLocRecord,
  407. "LcpLocRecord",
  408. sizeof(LcpLocRecord), 
  409. clcpLocrecFileSize);
  410.   
  411.   deallocRecord((void**)&logPartRecord,
  412. "LogPartRecord",
  413. sizeof(LogPartRecord), 
  414. clogPartFileSize);
  415.   
  416.   deallocRecord((void**)&logFileRecord,
  417. "LogFileRecord",
  418. sizeof(LogFileRecord),
  419. clogFileFileSize);
  421.   deallocRecord((void**)&logFileOperationRecord,
  422. "LogFileOperationRecord", 
  423. sizeof(LogFileOperationRecord), 
  424. clfoFileSize);
  425.   
  426.   deallocRecord((void**)&logPageRecord,
  427. "LogPageRecord",
  428. sizeof(LogPageRecord),
  429. clogPageFileSize);
  431.   deallocRecord((void**)&pageRefRecord,
  432. "PageRefRecord",
  433. sizeof(PageRefRecord),
  434. cpageRefFileSize);
  435.   
  437.   deallocRecord((void**)&tablerec,
  438. "Tablerec",
  439. sizeof(Tablerec), 
  440. ctabrecFileSize);
  441.   
  442.   deallocRecord((void**)&tcConnectionrec,
  443. "TcConnectionrec",
  444. sizeof(TcConnectionrec),
  445. ctcConnectrecFileSize);
  446.   
  447.   deallocRecord((void**)&tcNodeFailRecord,
  448. "TcNodeFailRecord",
  449. sizeof(TcNodeFailRecord),
  450. ctcNodeFailrecFileSize);
  451. }//Dblqh::~Dblqh()
  453. BLOCK_FUNCTIONS(Dblqh)