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

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

MySQL数据库

开发平台：

Visual C++

Ndbcntr.hpp：源码内容
  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. #ifndef NDBCNTR_H
  18. #define NDBCNTR_H
  21. #include <pc.hpp>
  22. #include <SimulatedBlock.hpp>
  23. #include <ndb_limits.h>
  24. #include <signaldata/StopReq.hpp>
  25. #include <signaldata/ResumeReq.hpp>
  26. #include <signaldata/DictTabInfo.hpp>
  27. #include <signaldata/CntrStart.hpp>
  28. #include <signaldata/CheckNodeGroups.hpp>
  30. #include <signaldata/UpgradeStartup.hpp>
  32. #include <NodeState.hpp>
  33. #include <NdbTick.h>
  35. #ifdef NDBCNTR_C
  36. /*
  37. 2.1 GLOBAL SYMBOLS
  38. ------------------
  39. */
  40. /*
  41. 2.2 LOCAL SYMBOLS
  42. ----------------- 
  43. */
  44. #define ZNO_NDB_BLOCKS 6           /* ACC, DICT, DIH, LQH, TC, TUP         */
  46. #define ZNOT_AVAILABLE 913
  48. //------- OTHERS ---------------------------------------------
  49. #define ZSTARTUP  1
  50. #define ZSHUTDOWN 2
  52. #define ZSIZE_NDB_BLOCKS_REC 16 /* MAX BLOCKS IN NDB                    */
  53. #define ZSIZE_SYSTAB 2048
  54. #define ZSTART_PHASE_1 1
  55. #define ZSTART_PHASE_2 2
  56. #define ZSTART_PHASE_3 3
  57. #define ZSTART_PHASE_4 4
  58. #define ZSTART_PHASE_5 5
  59. #define ZSTART_PHASE_6 6
  60. #define ZSTART_PHASE_7 7
  61. #define ZSTART_PHASE_8 8
  62. #define ZSTART_PHASE_9 9
  63. #define ZSTART_PHASE_END 255
  64. #define ZWAITPOINT_4_1 1
  65. #define ZWAITPOINT_4_2 2
  66. #define ZWAITPOINT_5_1 3
  67. #define ZWAITPOINT_5_2 4
  68. #define ZWAITPOINT_6_1 5
  69. #define ZWAITPOINT_6_2 6
  70. #define ZWAITPOINT_7_1 7
  71. #define ZWAITPOINT_7_2 8
  72. #define ZSYSTAB_VERSION 1
  73. #endif
  75. class Ndbcntr: public SimulatedBlock {
  76. public:
  77. // Records
  79. /* FSREADREQ FSWRITEREQ         */
  80. /**
  81.  * 2.3 RECORDS AND FILESIZES
  82.  * ------------------------------------------------------------
  83.  */
  85.   struct StartRecord {
  86.     Uint64 m_startTime;
  87.     
  88.     void reset();
  89.     NdbNodeBitmask m_starting;
  90.     NdbNodeBitmask m_waiting; // == (m_withLog | m_withoutLog)
  91.     NdbNodeBitmask m_withLog;
  92.     NdbNodeBitmask m_withoutLog;
  93.     Uint32 m_lastGci;
  94.     Uint32 m_lastGciNodeId;
  96.     Uint64 m_startPartialTimeout;
  97.     Uint64 m_startPartitionedTimeout;
  98.     Uint64 m_startFailureTimeout;
  99.     struct {
  100.       Uint32 m_nodeId;
  101.       Uint32 m_lastGci;
  102.     } m_logNodes[MAX_NDB_NODES];
  103.     Uint32 m_logNodesCount;
  104.   } c_start;
  105.   
  106.   struct NdbBlocksRec {
  107.     BlockReference blockref;
  108.   }; /* p2c: size = 2 bytes */
  109.   
  110.   typedef Ptr<NdbBlocksRec> NdbBlocksRecPtr;
  112.   /**
  113.    * Ndbcntr creates and initializes system tables on initial system start.
  114.    * The tables are defined in static structs in NdbcntrSysTable.cpp.
  115.    */
  116.   struct SysColumn {
  117.     unsigned pos;
  118.     const char* name;
  119.     // DictTabInfo
  120.     DictTabInfo::ExtType type;
  121.     Uint32 length;
  122.     bool keyFlag;
  123.     bool nullable;
  124.   };
  125.   struct SysTable {
  126.     const char* name;
  127.     unsigned columnCount;
  128.     const SysColumn* columnList;
  129.     // DictTabInfo
  130.     DictTabInfo::TableType tableType;
  131.     DictTabInfo::FragmentType fragmentType;
  132.     bool tableLoggedFlag;
  133.     // saved table id
  134.     mutable Uint32 tableId;
  135.   };
  136.   struct SysIndex {
  137.     const char* name;
  138.     const SysTable* primaryTable;
  139.     Uint32 columnCount;
  140.     Uint32 columnList[4];
  141.     // DictTabInfo
  142.     DictTabInfo::TableType indexType;
  143.     DictTabInfo::FragmentType fragmentType;
  144.     bool indexLoggedFlag;
  145.     // saved index table id
  146.     mutable Uint32 indexId;
  147.   };
  148.   static const SysTable* g_sysTableList[];
  149.   static const unsigned g_sysTableCount;
  150.   // the system tables
  151.   static const SysTable g_sysTable_SYSTAB_0;
  152.   static const SysTable g_sysTable_NDBEVENTS_0;
  154. public:
  155.   Ndbcntr(const class Configuration &);
  156.   virtual ~Ndbcntr();
  158. private:
  159.   BLOCK_DEFINES(Ndbcntr);
  161.   // Transit signals
  162.   void execCONTINUEB(Signal* signal);
  163.   void execREAD_NODESCONF(Signal* signal);
  164.   void execREAD_NODESREF(Signal* signal);
  165.   void execCM_ADD_REP(Signal* signal);
  166.   void execCNTR_START_REQ(Signal* signal);
  167.   void execCNTR_START_REF(Signal* signal);
  168.   void execCNTR_START_CONF(Signal* signal);
  169.   void execCNTR_START_REP(Signal* signal);
  170.   void execCNTR_WAITREP(Signal* signal);
  171.   void execNODE_FAILREP(Signal* signal);
  172.   void execSYSTEM_ERROR(Signal* signal);
  174.   // Received signals
  175.   void execDUMP_STATE_ORD(Signal* signal);
  176.   void execSTTOR(Signal* signal);
  177.   void execTCSEIZECONF(Signal* signal);
  178.   void execTCSEIZEREF(Signal* signal);
  179.   void execTCRELEASECONF(Signal* signal);
  180.   void execTCRELEASEREF(Signal* signal);
  181.   void execTCKEYCONF(Signal* signal);
  182.   void execTCKEYREF(Signal* signal);
  183.   void execTCROLLBACKREP(Signal* signal);
  184.   void execGETGCICONF(Signal* signal);
  185.   void execDIH_RESTARTCONF(Signal* signal);
  186.   void execDIH_RESTARTREF(Signal* signal);
  187.   void execCREATE_TABLE_REF(Signal* signal);
  188.   void execCREATE_TABLE_CONF(Signal* signal);
  189.   void execNDB_STTORRY(Signal* signal);
  190.   void execNDB_STARTCONF(Signal* signal);
  191.   void execREAD_NODESREQ(Signal* signal);
  192.   void execNDB_STARTREF(Signal* signal);
  193.   void execSET_VAR_REQ(Signal* signal);
  195.   void execSTOP_PERM_REF(Signal* signal);
  196.   void execSTOP_PERM_CONF(Signal* signal);
  198.   void execSTOP_ME_REF(Signal* signal);
  199.   void execSTOP_ME_CONF(Signal* signal);
  200.   
  201.   void execWAIT_GCP_REF(Signal* signal);
  202.   void execWAIT_GCP_CONF(Signal* signal);
  204.   void execSTOP_REQ(Signal* signal);
  205.   void execRESUME_REQ(Signal* signal);
  207.   void execCHANGE_NODE_STATE_CONF(Signal* signal);
  209.   void execABORT_ALL_REF(Signal* signal);
  210.   void execABORT_ALL_CONF(Signal* signal);
  212.   // Statement blocks
  213.   void sendCreateTabReq(Signal* signal, const char* buffer, Uint32 bufLen);
  214.   void startInsertTransactions(Signal* signal);
  215.   void initData(Signal* signal);
  216.   void resetStartVariables(Signal* signal);
  217.   void sendCntrStartReq(Signal* signal);
  218.   void sendCntrStartRef(Signal*, Uint32 nodeId, CntrStartRef::ErrorCode);
  219.   void sendNdbSttor(Signal* signal);
  220.   void sendSttorry(Signal* signal);
  222.   bool trySystemRestart(Signal* signal);
  223.   void startWaitingNodes(Signal* signal);
  224.   CheckNodeGroups::Output checkNodeGroups(Signal*, const NdbNodeBitmask &);
  225.   
  226.   // Generated statement blocks
  227.   void systemErrorLab(Signal* signal);
  229.   void createSystableLab(Signal* signal, unsigned index);
  230.   void crSystab7Lab(Signal* signal);
  231.   void crSystab8Lab(Signal* signal);
  232.   void crSystab9Lab(Signal* signal);
  234.   void startPhase1Lab(Signal* signal);
  235.   void startPhase2Lab(Signal* signal);
  236.   void startPhase3Lab(Signal* signal);
  237.   void startPhase4Lab(Signal* signal);
  238.   void startPhase5Lab(Signal* signal);
  239.   // jump 2 to resync phase counters
  240.   void startPhase8Lab(Signal* signal);
  241.   void startPhase9Lab(Signal* signal);
  242.   void ph2ALab(Signal* signal);
  243.   void ph2CLab(Signal* signal);
  244.   void ph2ELab(Signal* signal);
  245.   void ph2FLab(Signal* signal);
  246.   void ph2GLab(Signal* signal);
  247.   void ph3ALab(Signal* signal);
  248.   void ph4ALab(Signal* signal);
  249.   void ph4BLab(Signal* signal);
  250.   void ph4CLab(Signal* signal);
  251.   void ph5ALab(Signal* signal);
  252.   void ph6ALab(Signal* signal);
  253.   void ph6BLab(Signal* signal);
  254.   void ph7ALab(Signal* signal);
  255.   void ph8ALab(Signal* signal);
  258.   void waitpoint41Lab(Signal* signal);
  259.   void waitpoint51Lab(Signal* signal);
  260.   void waitpoint52Lab(Signal* signal);
  261.   void waitpoint61Lab(Signal* signal);
  262.   void waitpoint71Lab(Signal* signal);
  264.   void updateNodeState(Signal* signal, const NodeState & newState) const ;
  265.   void getNodeGroup(Signal* signal);
  267.   // Initialisation
  268.   void initData();
  269.   void initRecords();
  271.   // Variables
  272.   /**------------------------------------------------------------------------
  273.    * CONTAIN INFO ABOUT ALL NODES IN CLUSTER. NODE_PTR ARE USED AS NODE NUMBER
  274.    * IF THE STATE ARE ZDELETE THEN THE NODE DOESN'T EXIST. NODES ARE ALLOWED 
  275.    * TO REGISTER (ZADD) DURING RESTART.
  276.    *
  277.    * WHEN THE SYSTEM IS RUNNING THE MASTER WILL CHECK IF ANY NODE HAS MADE 
  278.    * A CNTR_MASTERREQ AND TAKE CARE OF THE REQUEST. 
  279.    * TO CONFIRM THE REQ, THE MASTER DEMANDS THAT ALL RUNNING NODES HAS VOTED 
  280.    * FOR THE NEW NODE. 
  281.    * NODE_PTR:MASTER_REQ IS USED DURING RESTART TO LOG 
  282.    * POSTPONED CNTR_MASTERREQ'S 
  283.    *------------------------------------------------------------------------*/
  284.   NdbBlocksRec *ndbBlocksRec;
  286.   /*
  287.     2.4 COMMON STORED VARIABLES
  288.   */
  289.   UintR cgciSystab;
  290.   UintR ckey;
  291.   //UintR csystabId;
  292.   UintR cnoWaitrep6;
  293.   UintR cnoWaitrep7;
  294.   UintR ctcConnectionP;
  295.   UintR ctcReqInfo;
  296.   Uint8 ctransidPhase;
  297.   Uint16 cresponses;
  299.   Uint8 cstartPhase;
  300.   Uint16 cinternalStartphase;
  302.   Uint16 cmasterNodeId;
  303.   Uint16 cndbBlocksCount;
  304.   Uint16 cnoStartNodes;
  305.   UintR cnoWaitrep;
  306.   NodeState::StartType ctypeOfStart;
  307.   Uint16 cdynamicNodeId;
  309.   Uint32 c_fsRemoveCount;
  310.   Uint32 c_nodeGroup;
  311.   void clearFilesystem(Signal* signal);
  312.   void execFSREMOVECONF(Signal* signal);
  314.   NdbNodeBitmask c_allDefinedNodes;
  315.   NdbNodeBitmask c_clusterNodes; // All members of qmgr cluster
  316.   NdbNodeBitmask c_startedNodes; // All cntr started nodes
  317.   
  318. public:
  319.   struct StopRecord {
  320.   public:
  321.     StopRecord(Ndbcntr & _cntr) : cntr(_cntr) {
  322.       stopReq.senderRef = 0;
  323.     }
  325.     Ndbcntr & cntr;
  326.     StopReq stopReq;          // Signal data
  327.     NDB_TICKS stopInitiatedTime; // When was the stop initiated
  328.     
  329.     bool checkNodeFail(Signal* signal);
  330.     void checkTimeout(Signal* signal);
  331.     void checkApiTimeout(Signal* signal);
  332.     void checkTcTimeout(Signal* signal);
  333.     void checkLqhTimeout_1(Signal* signal);
  334.     void checkLqhTimeout_2(Signal* signal);
  335.     
  336.     BlockNumber number() const { return cntr.number(); }
  337.     void progError(int line, int cause, const char * extra) { 
  338.       cntr.progError(line, cause, extra); 
  339.     }
  340.   };
  341. private:
  342.   StopRecord c_stopRec;
  343.   friend struct StopRecord;
  345.   struct Missra {
  346.     Missra(Ndbcntr & ref) : cntr(ref) { }
  348.     Uint32 currentBlockIndex;
  349.     Uint32 currentStartPhase;
  350.     Uint32 nextStartPhase[NO_OF_BLOCKS];
  352.     void execSTART_ORD(Signal* signal);
  353.     void execSTTORRY(Signal* signal);
  354.     void sendNextSTTOR(Signal* signal);
  355.     void execREAD_CONFIG_CONF(Signal* signal);
  356.     void sendNextREAD_CONFIG_REQ(Signal* signal);
  357.     
  358.     BlockNumber number() const { return cntr.number(); }
  359.     void progError(int line, int cause, const char * extra) { 
  360.       cntr.progError(line, cause, extra); 
  361.     }
  362.     Ndbcntr & cntr;
  363.   };
  365.   Missra c_missra;
  366.   friend struct Missra;
  368.   void execSTTORRY(Signal* signal);
  369.   void execSTART_ORD(Signal* signal);
  370.   void execREAD_CONFIG_CONF(Signal*);
  372.   friend struct UpgradeStartup;
  373. };
  375. #endif