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

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

MySQL数据库

开发平台：

Visual C++

NdbcntrInit.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 NDBCNTR_C
  20. #include "Ndbcntr.hpp"
  21. #include <ndb_limits.h>
  23. #define DEBUG(x) { ndbout << "Ndbcntr::" << x << endl; }
  26. void Ndbcntr::initData() 
  27. {
  29.   // Records with constant sizes
  30.   ndbBlocksRec = new NdbBlocksRec[ZSIZE_NDB_BLOCKS_REC];
  31. }//Ndbcntr::initData()
  33. void Ndbcntr::initRecords() 
  34. {
  35.   // Records with dynamic sizes
  36. }//Ndbcntr::initRecords()
  38. Ndbcntr::Ndbcntr(const class Configuration & conf):
  39.   SimulatedBlock(NDBCNTR, conf),
  40.   cnoWaitrep6(0),
  41.   cnoWaitrep7(0),
  42.   c_stopRec(* this),
  43.   c_missra(* this)
  44. {
  46.   BLOCK_CONSTRUCTOR(Ndbcntr);
  48.   // Transit signals
  49.   addRecSignal(GSN_CONTINUEB, &Ndbcntr::execCONTINUEB);
  50.   addRecSignal(GSN_READ_NODESCONF, &Ndbcntr::execREAD_NODESCONF);
  51.   addRecSignal(GSN_READ_NODESREF, &Ndbcntr::execREAD_NODESREF);
  52.   addRecSignal(GSN_CM_ADD_REP, &Ndbcntr::execCM_ADD_REP);
  53.   addRecSignal(GSN_CNTR_START_REQ, &Ndbcntr::execCNTR_START_REQ);
  54.   addRecSignal(GSN_CNTR_START_REF, &Ndbcntr::execCNTR_START_REF);
  55.   addRecSignal(GSN_CNTR_START_CONF, &Ndbcntr::execCNTR_START_CONF);
  56.   addRecSignal(GSN_CNTR_WAITREP, &Ndbcntr::execCNTR_WAITREP);
  57.   addRecSignal(GSN_CNTR_START_REP, &Ndbcntr::execCNTR_START_REP);
  58.   addRecSignal(GSN_NODE_FAILREP, &Ndbcntr::execNODE_FAILREP);
  59.   addRecSignal(GSN_SYSTEM_ERROR , &Ndbcntr::execSYSTEM_ERROR);
  60.   
  61.   // Received signals
  62.   addRecSignal(GSN_DUMP_STATE_ORD, &Ndbcntr::execDUMP_STATE_ORD);
  63.   addRecSignal(GSN_STTOR, &Ndbcntr::execSTTOR);
  64.   addRecSignal(GSN_TCSEIZECONF, &Ndbcntr::execTCSEIZECONF);
  65.   addRecSignal(GSN_TCSEIZEREF, &Ndbcntr::execTCSEIZEREF);
  66.   addRecSignal(GSN_TCRELEASECONF, &Ndbcntr::execTCRELEASECONF);
  67.   addRecSignal(GSN_TCRELEASEREF, &Ndbcntr::execTCRELEASEREF);
  68.   addRecSignal(GSN_TCKEYCONF, &Ndbcntr::execTCKEYCONF);
  69.   addRecSignal(GSN_TCKEYREF, &Ndbcntr::execTCKEYREF);
  70.   addRecSignal(GSN_TCROLLBACKREP, &Ndbcntr::execTCROLLBACKREP);
  71.   addRecSignal(GSN_GETGCICONF, &Ndbcntr::execGETGCICONF);
  72.   addRecSignal(GSN_DIH_RESTARTCONF, &Ndbcntr::execDIH_RESTARTCONF);
  73.   addRecSignal(GSN_DIH_RESTARTREF, &Ndbcntr::execDIH_RESTARTREF);
  74.   addRecSignal(GSN_CREATE_TABLE_REF, &Ndbcntr::execCREATE_TABLE_REF);
  75.   addRecSignal(GSN_CREATE_TABLE_CONF, &Ndbcntr::execCREATE_TABLE_CONF);
  76.   addRecSignal(GSN_NDB_STTORRY, &Ndbcntr::execNDB_STTORRY);
  77.   addRecSignal(GSN_NDB_STARTCONF, &Ndbcntr::execNDB_STARTCONF);
  78.   addRecSignal(GSN_READ_NODESREQ, &Ndbcntr::execREAD_NODESREQ);
  79.   addRecSignal(GSN_NDB_STARTREF, &Ndbcntr::execNDB_STARTREF);
  80.   addRecSignal(GSN_SET_VAR_REQ, &Ndbcntr::execSET_VAR_REQ);
  82.   addRecSignal(GSN_STOP_PERM_REF, &Ndbcntr::execSTOP_PERM_REF);
  83.   addRecSignal(GSN_STOP_PERM_CONF, &Ndbcntr::execSTOP_PERM_CONF);
  85.   addRecSignal(GSN_STOP_ME_REF, &Ndbcntr::execSTOP_ME_REF);
  86.   addRecSignal(GSN_STOP_ME_CONF, &Ndbcntr::execSTOP_ME_CONF);
  88.   addRecSignal(GSN_STOP_REQ, &Ndbcntr::execSTOP_REQ);
  89.   addRecSignal(GSN_RESUME_REQ, &Ndbcntr::execRESUME_REQ);
  91.   addRecSignal(GSN_WAIT_GCP_REF, &Ndbcntr::execWAIT_GCP_REF);
  92.   addRecSignal(GSN_WAIT_GCP_CONF, &Ndbcntr::execWAIT_GCP_CONF);
  93.   addRecSignal(GSN_CHANGE_NODE_STATE_CONF, 
  94.        &Ndbcntr::execCHANGE_NODE_STATE_CONF);
  96.   addRecSignal(GSN_ABORT_ALL_REF, &Ndbcntr::execABORT_ALL_REF);
  97.   addRecSignal(GSN_ABORT_ALL_CONF, &Ndbcntr::execABORT_ALL_CONF);
  99.   addRecSignal(GSN_START_ORD, &Ndbcntr::execSTART_ORD);
  100.   addRecSignal(GSN_STTORRY, &Ndbcntr::execSTTORRY);
  101.   addRecSignal(GSN_READ_CONFIG_CONF, &Ndbcntr::execREAD_CONFIG_CONF);
  103.   addRecSignal(GSN_FSREMOVECONF, &Ndbcntr::execFSREMOVECONF);
  104.   
  105.   initData();
  106.   ctypeOfStart = NodeState::ST_ILLEGAL_TYPE;
  107.   c_start.m_startTime = NdbTick_CurrentMillisecond();
  108. }//Ndbcntr::Ndbcntr()
  110. Ndbcntr::~Ndbcntr() 
  111. {
  112.   delete []ndbBlocksRec;
  114. }//Ndbcntr::~Ndbcntr()
  116. BLOCK_FUNCTIONS(Ndbcntr)