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

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

MySQL数据库

开发平台：

Visual C++

DbtcInit.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 */
  17. #define DBTC_C
  18. #include "Dbtc.hpp"
  19. #include <pc.hpp>
  20. #include <ndb_limits.h>
  21. #include <Properties.hpp>
  22. #include <Configuration.hpp>
  24. #define DEBUG(x) { ndbout << "TC::" << x << endl; }
  27. void Dbtc::initData() 
  28. {
  29.   cattrbufFilesize = ZATTRBUF_FILESIZE;
  30.   capiConnectFilesize = ZAPI_CONNECT_FILESIZE;
  31.   ccacheFilesize = ZAPI_CONNECT_FILESIZE;
  32.   chostFilesize = MAX_NODES;
  33.   cdatabufFilesize = ZDATABUF_FILESIZE;
  34.   cgcpFilesize = ZGCP_FILESIZE;
  35.   cscanrecFileSize = ZSCANREC_FILE_SIZE;
  36.   cscanFragrecFileSize = ZSCAN_FRAGREC_FILE_SIZE;
  37.   ctabrecFilesize = ZTABREC_FILESIZE;
  38.   ctcConnectFilesize = ZTC_CONNECT_FILESIZE;
  39.   cdihblockref = DBDIH_REF;
  40.   cdictblockref = DBDICT_REF;
  41.   clqhblockref = DBLQH_REF;
  42.   cerrorBlockref = NDBCNTR_REF;
  44.   cacheRecord = 0;
  45.   apiConnectRecord = 0;
  46.   tcConnectRecord = 0;
  47.   hostRecord = 0;
  48.   tableRecord = 0;
  49.   scanRecord = 0;
  50.   databufRecord = 0;
  51.   attrbufRecord = 0;
  52.   gcpRecord = 0;
  53.   tcFailRecord = 0;
  54.   c_apiConTimer = 0;
  55.   c_apiConTimer_line = 0;
  56.   // Records with constant sizes
  57.   tcFailRecord = (TcFailRecord*)allocRecord("TcFailRecord",
  58.     sizeof(TcFailRecord), 1);
  60.   // Variables
  61.   ctcTimer = 0;
  63.   // Trigger and index pools
  64.   c_theDefinedTriggerPool.setSize(c_maxNumberOfDefinedTriggers);
  65.   c_theFiredTriggerPool.setSize(c_maxNumberOfFiredTriggers);
  66.   c_theIndexPool.setSize(c_maxNumberOfIndexes);
  67.   c_theIndexOperationPool.setSize(c_maxNumberOfIndexOperations);
  68.   c_theAttributeBufferPool.setSize(c_transactionBufferSpace);
  69.   c_firedTriggerHash.setSize((c_maxNumberOfFiredTriggers+10)/10);
  70. }//Dbtc::initData()
  72. void Dbtc::initRecords() 
  73. {
  74.   void *p;
  75.   // Records with dynamic sizes
  76.   cacheRecord = (CacheRecord*)allocRecord("CacheRecord",
  77.   sizeof(CacheRecord), 
  78.   ccacheFilesize);
  80.   apiConnectRecord = (ApiConnectRecord*)allocRecord("ApiConnectRecord",
  81.     sizeof(ApiConnectRecord),
  82.     capiConnectFilesize);
  84.   for(unsigned i = 0; i<capiConnectFilesize; i++) {
  85.     p = &apiConnectRecord[i];
  86.     new (p) ApiConnectRecord(c_theFiredTriggerPool, 
  87.      c_theIndexOperationPool);
  88.   }
  89.   // Init all fired triggers
  90.   DLFifoList<TcFiredTriggerData> triggers(c_theFiredTriggerPool);
  91.   FiredTriggerPtr tptr;
  92.   while(triggers.seize(tptr) == true) {
  93.     p= tptr.p;
  94.     new (p) TcFiredTriggerData();
  95.   }
  96.   triggers.release();
  98.   /*
  99.   // Init all index records
  100.   ArrayList<TcIndexData> indexes(c_theIndexPool);
  101.   TcIndexDataPtr iptr;
  102.   while(indexes.seize(iptr) == true) {
  103.     new (iptr.p) TcIndexData(c_theAttrInfoListPool);
  104.   }
  105.   indexes.release();
  106.   */
  108.   // Init all index operation records
  109.   ArrayList<TcIndexOperation> indexOps(c_theIndexOperationPool);
  110.   TcIndexOperationPtr ioptr;
  111.   while(indexOps.seize(ioptr) == true) {
  112.     p= ioptr.p;
  113.     new (p) TcIndexOperation(c_theAttributeBufferPool);
  114.   }
  115.   indexOps.release();
  117.   c_apiConTimer = (UintR*)allocRecord("ApiConTimer",
  118.       sizeof(UintR),
  119.       capiConnectFilesize);
  120.   
  121.   c_apiConTimer_line = (UintR*)allocRecord("ApiConTimer_line",
  122.    sizeof(UintR),
  123.    capiConnectFilesize);
  125.   tcConnectRecord = (TcConnectRecord*)allocRecord("TcConnectRecord",
  126.   sizeof(TcConnectRecord),
  127.   ctcConnectFilesize);
  128.   
  129.   m_commitAckMarkerPool.setSize(capiConnectFilesize);
  130.   m_commitAckMarkerHash.setSize(512);
  132.   hostRecord = (HostRecord*)allocRecord("HostRecord",
  133. sizeof(HostRecord),
  134. chostFilesize);
  136.   tableRecord = (TableRecord*)allocRecord("TableRecord",
  137.   sizeof(TableRecord),
  138.   ctabrecFilesize);
  140.   scanRecord = (ScanRecord*)allocRecord("ScanRecord",
  141. sizeof(ScanRecord),
  142. cscanrecFileSize);
  145.   c_scan_frag_pool.setSize(cscanFragrecFileSize);
  146.   {
  147.     ScanFragRecPtr ptr;
  148.     SLList<ScanFragRec> tmp(c_scan_frag_pool);
  149.     while(tmp.seize(ptr)) {
  150.       new (ptr.p) ScanFragRec();
  151.     }
  152.     tmp.release();
  153.   }
  155.   indexOps.release();
  156.   
  157.   databufRecord = (DatabufRecord*)allocRecord("DatabufRecord",
  158.       sizeof(DatabufRecord),
  159.       cdatabufFilesize);
  161.   attrbufRecord = (AttrbufRecord*)allocRecord("AttrbufRecord",
  162.       sizeof(AttrbufRecord),
  163.       cattrbufFilesize);
  165.   gcpRecord = (GcpRecord*)allocRecord("GcpRecord",
  166.       sizeof(GcpRecord), 
  167.       cgcpFilesize);
  168.   
  169. }//Dbtc::initRecords()
  171. Dbtc::Dbtc(const class Configuration & conf):
  172.   SimulatedBlock(DBTC, conf),
  173.   c_theDefinedTriggers(c_theDefinedTriggerPool),
  174.   c_firedTriggerHash(c_theFiredTriggerPool),
  175.   c_maxNumberOfDefinedTriggers(0),
  176.   c_maxNumberOfFiredTriggers(0),
  177.   c_theIndexes(c_theIndexPool),
  178.   c_maxNumberOfIndexes(0),
  179.   c_maxNumberOfIndexOperations(0),
  180.   m_commitAckMarkerHash(m_commitAckMarkerPool)
  181. {
  182.   BLOCK_CONSTRUCTOR(Dbtc);
  183.   
  184.   const ndb_mgm_configuration_iterator * p = conf.getOwnConfigIterator();
  185.   ndbrequire(p != 0);
  187.   Uint32 transactionBufferMemory = 0;
  188.   Uint32 maxNoOfIndexes = 0, maxNoOfConcurrentIndexOperations = 0;
  189.   Uint32 maxNoOfTriggers = 0, maxNoOfFiredTriggers = 0;
  191.   ndb_mgm_get_int_parameter(p, CFG_DB_TRANS_BUFFER_MEM,  
  192.     &transactionBufferMemory);
  193.   ndb_mgm_get_int_parameter(p, CFG_DB_NO_UNIQUE_HASH_INDEXES, 
  194.     &maxNoOfIndexes);
  195.   ndb_mgm_get_int_parameter(p, CFG_DB_NO_INDEX_OPS, 
  196.     &maxNoOfConcurrentIndexOperations);
  197.   ndb_mgm_get_int_parameter(p, CFG_DB_NO_TRIGGERS, 
  198.     &maxNoOfTriggers);
  199.   ndb_mgm_get_int_parameter(p, CFG_DB_NO_TRIGGER_OPS, 
  200.     &maxNoOfFiredTriggers);
  201.   
  202.   c_transactionBufferSpace = 
  203.     transactionBufferMemory / AttributeBuffer::getSegmentSize();
  204.   c_maxNumberOfIndexes = maxNoOfIndexes;
  205.   c_maxNumberOfIndexOperations = maxNoOfConcurrentIndexOperations;
  206.   c_maxNumberOfDefinedTriggers = maxNoOfTriggers;
  207.   c_maxNumberOfFiredTriggers = maxNoOfFiredTriggers;
  209.   // Transit signals
  210.   addRecSignal(GSN_PACKED_SIGNAL, &Dbtc::execPACKED_SIGNAL); 
  211.   addRecSignal(GSN_ABORTED, &Dbtc::execABORTED);
  212.   addRecSignal(GSN_ATTRINFO, &Dbtc::execATTRINFO);
  213.   addRecSignal(GSN_CONTINUEB, &Dbtc::execCONTINUEB);
  214.   addRecSignal(GSN_KEYINFO, &Dbtc::execKEYINFO);
  215.   addRecSignal(GSN_SCAN_NEXTREQ, &Dbtc::execSCAN_NEXTREQ);
  216.   addRecSignal(GSN_TAKE_OVERTCREQ, &Dbtc::execTAKE_OVERTCREQ);
  217.   addRecSignal(GSN_TAKE_OVERTCCONF, &Dbtc::execTAKE_OVERTCCONF);
  218.   addRecSignal(GSN_LQHKEYREF, &Dbtc::execLQHKEYREF);
  220.   // Received signals
  222.   addRecSignal(GSN_DUMP_STATE_ORD, &Dbtc::execDUMP_STATE_ORD);
  223.   addRecSignal(GSN_SEND_PACKED, &Dbtc::execSEND_PACKED);
  224.   addRecSignal(GSN_SCAN_HBREP, &Dbtc::execSCAN_HBREP);
  225.   addRecSignal(GSN_COMPLETED, &Dbtc::execCOMPLETED);
  226.   addRecSignal(GSN_COMMITTED, &Dbtc::execCOMMITTED);
  227.   addRecSignal(GSN_DIGETPRIMCONF, &Dbtc::execDIGETPRIMCONF);
  228.   addRecSignal(GSN_DIGETPRIMREF, &Dbtc::execDIGETPRIMREF);
  229.   addRecSignal(GSN_DISEIZECONF, &Dbtc::execDISEIZECONF);
  230.   addRecSignal(GSN_DIVERIFYCONF, &Dbtc::execDIVERIFYCONF);
  231.   addRecSignal(GSN_DI_FCOUNTCONF, &Dbtc::execDI_FCOUNTCONF);
  232.   addRecSignal(GSN_DI_FCOUNTREF, &Dbtc::execDI_FCOUNTREF);
  233.   addRecSignal(GSN_GCP_NOMORETRANS, &Dbtc::execGCP_NOMORETRANS);
  234.   addRecSignal(GSN_LQHKEYCONF, &Dbtc::execLQHKEYCONF);
  235.   addRecSignal(GSN_NDB_STTOR, &Dbtc::execNDB_STTOR);
  236.   addRecSignal(GSN_READ_NODESCONF, &Dbtc::execREAD_NODESCONF);
  237.   addRecSignal(GSN_READ_NODESREF, &Dbtc::execREAD_NODESREF);
  238.   addRecSignal(GSN_STTOR, &Dbtc::execSTTOR);
  239.   addRecSignal(GSN_TC_COMMITREQ, &Dbtc::execTC_COMMITREQ);
  240.   addRecSignal(GSN_TC_CLOPSIZEREQ, &Dbtc::execTC_CLOPSIZEREQ);
  241.   addRecSignal(GSN_TCGETOPSIZEREQ, &Dbtc::execTCGETOPSIZEREQ);
  242.   addRecSignal(GSN_TCKEYREQ, &Dbtc::execTCKEYREQ);
  243.   addRecSignal(GSN_TCRELEASEREQ, &Dbtc::execTCRELEASEREQ);
  244.   addRecSignal(GSN_TCSEIZEREQ, &Dbtc::execTCSEIZEREQ);
  245.   addRecSignal(GSN_TCROLLBACKREQ, &Dbtc::execTCROLLBACKREQ);
  246.   addRecSignal(GSN_TC_HBREP, &Dbtc::execTC_HBREP);
  247.   addRecSignal(GSN_TC_SCHVERREQ, &Dbtc::execTC_SCHVERREQ);
  248.   addRecSignal(GSN_SCAN_TABREQ, &Dbtc::execSCAN_TABREQ);
  249.   addRecSignal(GSN_SCAN_FRAGCONF, &Dbtc::execSCAN_FRAGCONF);
  250.   addRecSignal(GSN_SCAN_FRAGREF, &Dbtc::execSCAN_FRAGREF);
  251.   addRecSignal(GSN_READ_CONFIG_REQ, &Dbtc::execREAD_CONFIG_REQ, true);
  252.   addRecSignal(GSN_LQH_TRANSCONF, &Dbtc::execLQH_TRANSCONF);
  253.   addRecSignal(GSN_COMPLETECONF, &Dbtc::execCOMPLETECONF);
  254.   addRecSignal(GSN_COMMITCONF, &Dbtc::execCOMMITCONF);
  255.   addRecSignal(GSN_ABORTCONF, &Dbtc::execABORTCONF);
  256.   addRecSignal(GSN_NODE_FAILREP, &Dbtc::execNODE_FAILREP);
  257.   addRecSignal(GSN_INCL_NODEREQ, &Dbtc::execINCL_NODEREQ);
  258.   addRecSignal(GSN_TIME_SIGNAL, &Dbtc::execTIME_SIGNAL);
  259.   addRecSignal(GSN_API_FAILREQ, &Dbtc::execAPI_FAILREQ);
  260.   addRecSignal(GSN_SET_VAR_REQ, &Dbtc::execSET_VAR_REQ);
  262.   addRecSignal(GSN_TC_COMMIT_ACK, &Dbtc::execTC_COMMIT_ACK);
  263.   addRecSignal(GSN_ABORT_ALL_REQ, &Dbtc::execABORT_ALL_REQ);
  265.   addRecSignal(GSN_CREATE_TRIG_REQ, &Dbtc::execCREATE_TRIG_REQ);
  266.   addRecSignal(GSN_DROP_TRIG_REQ, &Dbtc::execDROP_TRIG_REQ);
  267.   addRecSignal(GSN_FIRE_TRIG_ORD, &Dbtc::execFIRE_TRIG_ORD);
  268.   addRecSignal(GSN_TRIG_ATTRINFO, &Dbtc::execTRIG_ATTRINFO);
  269.   
  270.   addRecSignal(GSN_CREATE_INDX_REQ, &Dbtc::execCREATE_INDX_REQ);
  271.   addRecSignal(GSN_DROP_INDX_REQ, &Dbtc::execDROP_INDX_REQ);
  272.   addRecSignal(GSN_TCINDXREQ, &Dbtc::execTCINDXREQ);
  273.   addRecSignal(GSN_INDXKEYINFO, &Dbtc::execINDXKEYINFO);
  274.   addRecSignal(GSN_INDXATTRINFO, &Dbtc::execINDXATTRINFO);
  275.   addRecSignal(GSN_ALTER_INDX_REQ, &Dbtc::execALTER_INDX_REQ);
  277.   addRecSignal(GSN_TRANSID_AI_R, &Dbtc::execTRANSID_AI_R);
  278.   addRecSignal(GSN_KEYINFO20_R, &Dbtc::execKEYINFO20_R);
  280.   // Index table lookup
  281.   addRecSignal(GSN_TCKEYCONF, &Dbtc::execTCKEYCONF);
  282.   addRecSignal(GSN_TCKEYREF, &Dbtc::execTCKEYREF);
  283.   addRecSignal(GSN_TRANSID_AI, &Dbtc::execTRANSID_AI);
  284.   addRecSignal(GSN_TCROLLBACKREP, &Dbtc::execTCROLLBACKREP);
  285.   
  286.   //addRecSignal(GSN_CREATE_TAB_REQ, &Dbtc::execCREATE_TAB_REQ);
  287.   addRecSignal(GSN_DROP_TAB_REQ, &Dbtc::execDROP_TAB_REQ);
  288.   addRecSignal(GSN_PREP_DROP_TAB_REQ, &Dbtc::execPREP_DROP_TAB_REQ);
  289.   addRecSignal(GSN_WAIT_DROP_TAB_REF, &Dbtc::execWAIT_DROP_TAB_REF);
  290.   addRecSignal(GSN_WAIT_DROP_TAB_CONF, &Dbtc::execWAIT_DROP_TAB_CONF);
  291.   
  292.   addRecSignal(GSN_ALTER_TAB_REQ, &Dbtc::execALTER_TAB_REQ);
  294.   initData();
  295.   
  296. #ifdef VM_TRACE
  297.   {
  298.     void* tmp[] = { &apiConnectptr, 
  299.     &tcConnectptr,
  300.     &cachePtr,
  301.     &attrbufptr,
  302.     &hostptr,
  303.     &gcpPtr,
  304.     &tmpApiConnectptr,
  305.     &timeOutptr,
  306.     &scanFragptr,
  307.     &databufptr,
  308.     &tmpDatabufptr }; 
  309.     init_globals_list(tmp, sizeof(tmp)/sizeof(tmp[0]));
  310.   }
  311. #endif
  312. }//Dbtc::Dbtc()
  314. Dbtc::~Dbtc() 
  315. {
  316.   // Records with dynamic sizes
  317.   deallocRecord((void **)&cacheRecord, "CacheRecord",
  318. sizeof(CacheRecord), 
  319. ccacheFilesize);
  320.   
  321.   deallocRecord((void **)&apiConnectRecord, "ApiConnectRecord",
  322. sizeof(ApiConnectRecord),
  323. capiConnectFilesize);
  324.   
  325.   deallocRecord((void **)&tcConnectRecord, "TcConnectRecord",
  326. sizeof(TcConnectRecord),
  327. ctcConnectFilesize);
  329.   deallocRecord((void **)&hostRecord, "HostRecord",
  330. sizeof(HostRecord),
  331. chostFilesize);
  332.   
  333.   deallocRecord((void **)&tableRecord, "TableRecord",
  334. sizeof(TableRecord),
  335. ctabrecFilesize);
  336.   
  337.   deallocRecord((void **)&scanRecord, "ScanRecord",
  338. sizeof(ScanRecord),
  339. cscanrecFileSize);
  340.     
  341.   deallocRecord((void **)&databufRecord, "DatabufRecord",
  342. sizeof(DatabufRecord),
  343. cdatabufFilesize);
  344.   
  345.   deallocRecord((void **)&attrbufRecord, "AttrbufRecord",
  346. sizeof(AttrbufRecord),
  347. cattrbufFilesize);
  348.   
  349.   deallocRecord((void **)&gcpRecord, "GcpRecord",
  350. sizeof(GcpRecord), 
  351. cgcpFilesize);
  352.   
  353.   deallocRecord((void **)&tcFailRecord, "TcFailRecord",
  354. sizeof(TcFailRecord), 1);
  355.   
  356.   deallocRecord((void **)&c_apiConTimer, "ApiConTimer",
  357. sizeof(UintR),
  358. capiConnectFilesize);
  360.   deallocRecord((void **)&c_apiConTimer_line, "ApiConTimer",
  361. sizeof(UintR),
  362. capiConnectFilesize);
  363. }//Dbtc::~Dbtc()
  365. BLOCK_FUNCTIONS(Dbtc)