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

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

MySQL数据库

开发平台：

Visual C++

Qmgr.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 QMGR_H
  18. #define QMGR_H
  21. #include <pc.hpp>
  22. #include <NdbTick.h>
  23. #include <SimulatedBlock.hpp>
  24. #include <NodeBitmask.hpp>
  25. #include <SignalCounter.hpp>
  27. #include <signaldata/EventReport.hpp>
  28. #include <signaldata/ArbitSignalData.hpp>
  29. #include <signaldata/CmRegSignalData.hpp>
  30. #include <signaldata/ApiRegSignalData.hpp>
  31. #include <signaldata/FailRep.hpp>
  33. #include "timer.hpp"
  35. #ifdef QMGR_C
  37. #define NO_REG_APP 1
  39. /* Delay values, ms -----------------------------*/
  40. #define ZDELAY_REGREQ 1000
  42. /* Type of refuse in CM_NODEINFOREF -------------*/
  43. #define ZNOT_RUNNING 0
  45. /* Type of continue in CONTINUEB ----------------*/
  46. #define ZREGREQ_TIMELIMIT 0
  47. #define ZHB_HANDLING 1
  48. #define ZREGREQ_MASTER_TIMELIMIT 2
  49. #define ZAPI_HB_HANDLING 3
  50. #define ZTIMER_HANDLING 4
  51. #define ZARBIT_HANDLING 5
  53. /* Error Codes ------------------------------*/
  54. #define ZERRTOOMANY 1101
  55. #define ZERRALREADYREG 1102
  56. #define ZERRNHMISSING 1103
  57. #define ZERRNLMISSING 1104
  58. #define ZERRAPPMISSING 1105
  59. #define ZERROR_NOT_IN_CFGFILE 1106
  60. #define ZERROR_TIMEOUT 1107
  61. #define ZERROR_NOT_ZINIT 1108
  62. #define ZERROR_NODEINFOREF 1109
  63. #define ZERROR_NOTLOCALQMGR 1110
  64. #define ZERROR_NOTRUNNING 1111
  65. #define ZCOULD_NOT_OCCUR_ERROR 1112
  66. #define ZTIME_OUT_ERROR 1113
  67. #define ZERROR_NOT_DEAD 1114
  68. #define ZDECLARED_FAIL_ERROR 1115
  69. #define ZOWN_NODE_ERROR 1116
  70. #define ZWRONG_STATE_ERROR 1117
  71. #define ZNODE_ZERO_ERROR 1118
  72. #define ZWRONG_NODE_ERROR 1119
  74. #endif
  77. class Qmgr : public SimulatedBlock {
  78. public:
  79.   // State values
  80.   enum QmgrState {
  81.     Q_NOT_ACTIVE = 0,
  82.     Q_ACTIVE = 1
  83.   };
  84.   
  85.   enum FailState {
  86.     NORMAL = 0,
  87.     WAITING_FOR_FAILCONF1 = 1,
  88.     WAITING_FOR_FAILCONF2 = 2,
  89.     WAITING_FOR_NDB_FAILCONF = 3
  90.   };
  92.   enum Phase {
  93.     ZINIT = 1,          /* All nodes start in phase INIT         */
  94.     ZSTARTING = 2,  /* Node is connecting to cluster         */
  95.     ZRUNNING = 3,  /* Node is running in the cluster        */
  96.     ZPREPARE_FAIL = 4,       /* PREPARATION FOR FAILURE               */
  97.     ZFAIL_CLOSING = 5,             /* API/NDB IS DISCONNECTING              */
  98.     ZAPI_ACTIVE = 6,            /* API IS RUNNING IN NODE                */
  99.     ZAPI_INACTIVE = 7           /* Inactive API */
  100.   };
  102.   struct StartRecord {
  103.     void reset(){ m_startKey++; m_startNode = 0;}
  104.     Uint32 m_startKey;
  105.     Uint32 m_startNode;
  106.     Uint64 m_startTimeout;
  107.     
  108.     Uint32 m_gsn;
  109.     SignalCounter m_nodes;
  110.   } c_start;
  112.   NdbNodeBitmask c_definedNodes; // DB nodes in config
  113.   NdbNodeBitmask c_clusterNodes; // DB nodes in cluster
  114.   NodeBitmask c_connectedNodes;  // All kinds of connected nodes
  115.   Uint32 c_maxDynamicId;
  116.   
  117.   // Records
  118.   struct NodeRec {
  119.     UintR ndynamicId;
  120.     Phase phase;
  121.     UintR alarmCount;
  122.     
  123.     QmgrState sendPrepFailReqStatus;
  124.     QmgrState sendCommitFailReqStatus;
  125.     QmgrState sendPresToStatus;
  126.     FailState failState;
  127.     BlockReference rcv[2];        // remember which failconf we have received
  128.     BlockReference blockRef;
  130.     NodeRec() { }
  131.   }; /* p2c: size = 52 bytes */
  132.   
  133.   typedef Ptr<NodeRec> NodeRecPtr;
  134.   
  135.   enum ArbitState {
  136.     ARBIT_NULL = 0,
  137.     ARBIT_INIT = 1,             // create new ticket
  138.     ARBIT_FIND = 2, // find candidate arbitrator node
  139.     ARBIT_PREP1 = 3, // PREP db nodes with null ticket
  140.     ARBIT_PREP2 = 4, // PREP db nodes with current ticket
  141.     ARBIT_START = 5, // START arbitrator API thread
  142.     ARBIT_RUN = 6, // running with arbitrator
  143.     ARBIT_CHOOSE = 7, // ask arbitrator after network partition
  144.     ARBIT_CRASH = 8 // crash ourselves
  145.   };
  147.   struct ArbitRec {
  148.     ArbitState state; // state
  149.     bool newstate; // flag to initialize new state
  150.     unsigned thread; // identifies a continueB "thread"
  151.     NodeId node; // current arbitrator candidate
  152.     ArbitTicket ticket; // ticket
  153.     NodeBitmask apiMask[1+2]; // arbitrators 0=all 1,2=per rank
  154.     NodeBitmask newMask; // new nodes to process in RUN state
  155.     Uint8 sendCount; // control send/recv of signals
  156.     Uint8 recvCount;
  157.     NodeBitmask recvMask; // left to recv
  158.     Uint32 code; // code field from signal
  159.     Uint32 failureNr;            // cfailureNr at arbitration start
  160.     Uint32 timeout;             // timeout for CHOOSE state
  161.     NDB_TICKS timestamp; // timestamp for checking timeouts
  163.     inline bool match(ArbitSignalData* sd) {
  164.       return
  165. node == sd->node &&
  166. ticket.match(sd->ticket);
  167.     }
  169.     inline void setTimestamp() {
  170.       timestamp = NdbTick_CurrentMillisecond();
  171.     }
  173.     inline NDB_TICKS getTimediff() {
  174.       NDB_TICKS now = NdbTick_CurrentMillisecond();
  175.       return now < timestamp ? 0 : now - timestamp;
  176.     }
  177.   };
  178.   
  179. public:
  180.   Qmgr(const class Configuration &);
  181.   virtual ~Qmgr();
  183. private:
  184.   BLOCK_DEFINES(Qmgr);
  186.   // Transit signals
  187.   void execDEBUG_SIG(Signal* signal);
  188.   void execCONTINUEB(Signal* signal);
  189.   void execCM_HEARTBEAT(Signal* signal);
  190.   void execCM_ADD(Signal* signal);
  191.   void execCM_ACKADD(Signal* signal);
  192.   void execCM_REGREQ(Signal* signal);
  193.   void execCM_REGCONF(Signal* signal);
  194.   void execCM_REGREF(Signal* signal);
  195.   void execCM_NODEINFOREQ(Signal* signal);
  196.   void execCM_NODEINFOCONF(Signal* signal);
  197.   void execCM_NODEINFOREF(Signal* signal);
  198.   void execPREP_FAILREQ(Signal* signal);
  199.   void execPREP_FAILCONF(Signal* signal);
  200.   void execPREP_FAILREF(Signal* signal);
  201.   void execCOMMIT_FAILREQ(Signal* signal);
  202.   void execCOMMIT_FAILCONF(Signal* signal);
  203.   void execFAIL_REP(Signal* signal);
  204.   void execPRES_TOREQ(Signal* signal);
  205.   void execPRES_TOCONF(Signal* signal);
  206.   void execDISCONNECT_REP(Signal* signal);
  207.   void execSYSTEM_ERROR(Signal* signal);
  209.   // Received signals
  210.   void execDUMP_STATE_ORD(Signal* signal);
  211.   void execCONNECT_REP(Signal* signal);
  212.   void execNDB_FAILCONF(Signal* signal);
  213.   void execSTTOR(Signal* signal);
  214.   void execCM_INFOCONF(Signal* signal);
  215.   void execCLOSE_COMCONF(Signal* signal);
  216.   void execAPI_REGREQ(Signal* signal);
  217.   void execAPI_FAILCONF(Signal* signal);
  218.   void execREAD_NODESREQ(Signal* signal);
  219.   void execSET_VAR_REQ(Signal* signal);
  222.   void execAPI_VERSION_REQ(Signal* signal);
  223.   void execAPI_BROADCAST_REP(Signal* signal);
  225.   // Arbitration signals
  226.   void execARBIT_CFG(Signal* signal);
  227.   void execARBIT_PREPREQ(Signal* signal);
  228.   void execARBIT_PREPCONF(Signal* signal);
  229.   void execARBIT_PREPREF(Signal* signal);
  230.   void execARBIT_STARTCONF(Signal* signal);
  231.   void execARBIT_STARTREF(Signal* signal);
  232.   void execARBIT_CHOOSECONF(Signal* signal);
  233.   void execARBIT_CHOOSEREF(Signal* signal);
  234.   void execARBIT_STOPREP(Signal* signal);
  236.   // Statement blocks
  237.   void node_failed(Signal* signal, Uint16 aFailedNode);
  238.   void checkStartInterface(Signal* signal);
  239.   void failReport(Signal* signal,
  240.                   Uint16 aFailedNode,
  241.                   UintR aSendFailRep,
  242.                   FailRep::FailCause failCause);
  243.   void findNeighbours(Signal* signal);
  244.   Uint16 translateDynamicIdToNodeId(Signal* signal, UintR TdynamicId);
  246.   void initData(Signal* signal);
  247.   void sendCloseComReq(Signal* signal, BlockReference TBRef, Uint16 TfailNo);
  248.   void sendPrepFailReq(Signal* signal, Uint16 aNode);
  249.   void sendApiFailReq(Signal* signal, Uint16 aFailedNode);
  250.   void sendApiRegRef(Signal*, Uint32 ref, ApiRegRef::ErrorCode);
  252.   // Generated statement blocks
  253.   void startphase1(Signal* signal);
  254.   void electionWon();
  255.   void cmInfoconf010Lab(Signal* signal);
  256.   void apiHbHandlingLab(Signal* signal);
  257.   void timerHandlingLab(Signal* signal);
  258.   void hbReceivedLab(Signal* signal);
  259.   void sendCmRegrefLab(Signal* signal, BlockReference ref, 
  260.        CmRegRef::ErrorCode);
  261.   void systemErrorBecauseOtherNodeFailed(Signal* signal, Uint32 line, NodeId);
  262.   void systemErrorLab(Signal* signal, Uint32 line,
  263.       const char* message = NULL);
  264.   void prepFailReqLab(Signal* signal);
  265.   void prepFailConfLab(Signal* signal);
  266.   void prepFailRefLab(Signal* signal);
  267.   void commitFailReqLab(Signal* signal);
  268.   void commitFailConfLab(Signal* signal);
  269.   void failReportLab(Signal* signal, Uint16 aFailedNode, 
  270.      FailRep::FailCause aFailCause);
  271.   void sendCommitFailReq(Signal* signal);
  272.   void presToConfLab(Signal* signal);
  273.   void sendSttorryLab(Signal* signal);
  274.   void sttor020Lab(Signal* signal);
  275.   void closeComConfLab(Signal* signal);
  276.   void apiRegReqLab(Signal* signal);
  277.   void regreqTimeLimitLab(Signal* signal);
  278.   void regreqTimeMasterLimitLab(Signal* signal);
  279.   void cmRegreq010Lab(Signal* signal);
  280.   void cmRegconf010Lab(Signal* signal);
  281.   void sttor010Lab(Signal* signal);
  282.   void sendHeartbeat(Signal* signal);
  283.   void checkHeartbeat(Signal* signal);
  284.   void setHbDelay(UintR aHbDelay);
  285.   void setHbApiDelay(UintR aHbApiDelay);
  286.   void setArbitTimeout(UintR aArbitTimeout);
  288.   // Interface to arbitration module
  289.   void handleArbitStart(Signal* signal);
  290.   void handleArbitApiFail(Signal* signal, Uint16 nodeId);
  291.   void handleArbitNdbAdd(Signal* signal, Uint16 nodeId);
  292.   void handleArbitCheck(Signal* signal);
  294.   // Private arbitration routines
  295.   Uint32 getArbitDelay();
  296.   Uint32 getArbitTimeout();
  297.   void startArbitThread(Signal* signal);
  298.   void runArbitThread(Signal* signal);
  299.   void stateArbitInit(Signal* signal);
  300.   void stateArbitFind(Signal* signal);
  301.   void stateArbitPrep(Signal* signal);
  302.   void stateArbitStart(Signal* signal);
  303.   void stateArbitRun(Signal* signal);
  304.   void stateArbitChoose(Signal* signal);
  305.   void stateArbitCrash(Signal* signal);
  306.   void computeArbitNdbMask(NodeBitmask& aMask);
  307.   void reportArbitEvent(Signal* signal, EventReport::EventType type);
  309.   // Initialisation
  310.   void initData();
  311.   void initRecords();
  313.   // Transit signals
  314.   // Variables
  315.   
  316.   bool checkAPIVersion(NodeId, Uint32 nodeVersion, Uint32 ownVersion) const;
  317.   bool checkNDBVersion(NodeId, Uint32 nodeVersion, Uint32 ownVersion) const;
  319.   void cmAddPrepare(Signal* signal, NodeRecPtr nodePtr, const NodeRec* self);
  320.   void sendCmAckAdd(Signal *, Uint32 nodeId, CmAdd::RequestType);
  321.   void joinedCluster(Signal* signal, NodeRecPtr nodePtr);
  322.   void sendCmRegReq(Signal * signal, Uint32 nodeId);
  323.   void sendCmNodeInfoReq(Signal* signal, Uint32 nodeId, const NodeRec * self);
  325. private:
  326.   void sendPrepFailReqRef(Signal* signal, 
  327.   Uint32 dstBlockRef,
  328.   GlobalSignalNumber gsn,
  329.   Uint32 blockRef,
  330.   Uint32 failNo,
  331.   Uint32 noOfNodes,
  332.   const NodeId theNodes[]);
  333.     
  335.   
  336.   /* Wait this time until we try to join the       */
  337.   /* cluster again                                 */
  339.   /**** Common stored variables ****/
  341.   NodeRec *nodeRec;
  342.   ArbitRec arbitRec;
  344.   /* Block references ------------------------------*/
  345.   BlockReference cpdistref;  /* Dist. ref of president   */
  347.   /* Node numbers. ---------------------------------*/
  348.   Uint16 cneighbourl;   /* Node no. of lower neighbour  */
  349.   Uint16 cneighbourh;   /* Node no. of higher neighbour */
  350.   Uint16 cpresident;   /* Node no. of president        */
  352.   /* Counters --------------------------------------*/
  353.   Uint16 cnoOfNodes;   /* Static node counter          */
  354.   /* Status flags ----------------------------------*/
  356.   Uint32 c_restartPartialTimeout;
  358.   Uint16 creadyDistCom;
  359.   Uint16 c_regReqReqSent;
  360.   Uint16 c_regReqReqRecv;
  361.   Uint64 c_stopElectionTime;
  362.   Uint16 cpresidentCandidate;
  363.   Uint16 cdelayRegreq;
  364.   Uint16 cpresidentAlive;
  365.   Uint16 cnoFailedNodes;
  366.   Uint16 cnoPrepFailedNodes;
  367.   Uint16 cnoCommitFailedNodes;
  368.   Uint16 cactivateApiCheck;
  369.   UintR chbApiDelay;
  371.   UintR ccommitFailureNr;
  372.   UintR cprepareFailureNr;
  373.   UintR ctoFailureNr;
  374.   UintR cfailureNr;
  376.   QmgrState ctoStatus;
  377.   UintR cLqhTimeSignalCount;
  378.   bool cHbSent;
  379.   NDB_TICKS clatestTransactionCheck;
  381.   class Timer interface_check_timer;
  382.   class Timer hb_check_timer;
  383.   class Timer hb_send_timer;
  384.   class Timer hb_api_timer;
  387.   Uint16 cfailedNodes[MAX_NDB_NODES];
  388.   Uint16 cprepFailedNodes[MAX_NDB_NODES];
  389.   Uint16 ccommitFailedNodes[MAX_NDB_NODES];
  391. };
  393. #endif