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

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

MySQL数据库

开发平台：

Visual C++

RepImpl.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 REP_IMPL_HPP
  18. #define REP_IMPL_HPP
  20. #include "SignalData.hpp"
  21. #include <NodeBitmask.hpp>
  22. #include <ndb_limits.h>
  23. #include <debugger/GrepError.hpp>
  25. /**
  26.  * RecordType
  27.  * sz = no of elems in enum
  28.  * @todo support for meta_log must be added
  29.  */
  30. enum RecordType 
  31. {
  32.   DATA_SCAN = 0, 
  33.   DATA_LOG = 1, 
  34.   META_SCAN = 2, 
  35.   //  META_LOG = 3,  //removed META_LOG. not supported
  36.   RecordTypeSize = 3 // =4 if meta log is supported
  37. };
  39. /**
  40.  * Wait GCP
  41.  */
  42. class RepWaitGcpReq 
  43. {
  44.   /**
  45.    * Sender(s)/Reciver(s)
  46.    */
  47.   friend class Rep;
  48.   friend class GrepParticipant;
  49.   friend bool printREP_WAITGCP_REQ(FILE *, const Uint32 *, Uint32, Uint16);
  51. public:
  52.   STATIC_CONST( SignalLength = 5 );
  53.   Uint32 senderData;
  54.   Uint32 subscriptionId;
  55.   Uint32 subscriptionKey;
  56.   Uint32 gcp;
  57.   Uint32 senderNodeId;
  58. };
  60. class RepWaitGcpConf 
  61. {
  62.   /**
  63.    * Sender(s)/Reciver(s)
  64.    */
  65.   friend class Rep;
  66.   friend class GrepParticipant;
  67.   
  68.   friend bool printREP_WAITGCP_CONF(FILE *, const Uint32 *, Uint32, Uint16);
  70. public:
  71.   STATIC_CONST( SignalLength = 5 );
  72.   Uint32 senderData;
  73.   Uint32 senderRef;
  74.   Uint32 subscriptionId;
  75.   Uint32 subscriptionKey;
  76.   Uint32 senderNodeId;
  77. };
  79. class RepWaitGcpRef 
  80. {
  81.   /**
  82.    * Sender(s)/Reciver(s)
  83.    */
  84.   friend class Rep;
  85.   friend class GrepParticipant;
  87.   friend bool printREP_WAITGCP_REF(FILE *, const Uint32 *, Uint32, Uint16);
  89. public:
  90.   STATIC_CONST( SignalLength = 6 );
  91.   Uint32 senderData;
  92.   Uint32 senderRef;
  93.   Uint32 subscriptionId;
  94.   Uint32 subscriptionKey;
  95.   Uint32 senderNodeId;
  96.   GrepError::GE_Code err;
  97. };
  99. class RepGetGciReq 
  100. {
  101.   /**
  102.    * Sender(s)/Reciver(s)
  103.    */
  104.   friend class Rep;
  105.   friend class Grep;
  106.   
  107.   friend bool printREP_GET_GCI_REQ(FILE *, const Uint32 *, Uint32, Uint16);
  108.    
  109. public:
  110.   STATIC_CONST( SignalLength = 3 );
  111.   Uint32 senderData;
  112.   Uint32 senderRef;
  113.   Uint32 nodeGrp;
  114. };
  116. class RepGetGciConf 
  117. {
  118.   /**
  119.    * Sender(s)/Reciver(s)
  120.    */
  121.   friend class Rep;
  122.   
  123.   friend bool printREP_GET_GCI_CONF(FILE *, const Uint32 *, Uint32, Uint16);
  124.    
  125. public:
  126.   STATIC_CONST( SignalLength = 7 );
  127.   Uint32 senderData;
  128.   Uint32 senderRef;
  129.   Uint32 nodeGrp;
  130.   Uint32 firstPSGCI;
  131.   Uint32 lastPSGCI;
  132.   Uint32 firstSSGCI;
  133.   Uint32 lastSSGCI;
  134. };
  136. class RepGetGciRef 
  137. {
  138.   /**
  139.    * Sender(s)/Reciver(s)
  140.    */
  141.   friend class Rep;
  142.   
  143.   friend bool printREP_GET_GCI_REF(FILE *, const Uint32 *, Uint32, Uint16);
  144.    
  145. public:
  146.   STATIC_CONST( SignalLength = 8);
  147.   Uint32 senderData;
  148.   Uint32 senderRef;
  149.   Uint32 nodeGrp;
  150.   Uint32 firstPSGCI;
  151.   Uint32 lastPSGCI;
  152.   Uint32 firstSSGCI;
  153.   Uint32 lastSSGCI;
  154.   GrepError::GE_Code err;
  155. };
  157. class RepGetGciBufferReq {
  158.   /**
  159.    * Sender(s)/Reciver(s)
  160.    */
  161.   friend class Rep;
  163.   friend bool printREP_GET_GCIBUFFER_REQ(FILE *, const Uint32 *, 
  164.  Uint32, Uint16);
  165. public:
  166.   STATIC_CONST( SignalLength = 5 );
  167.   Uint32 senderRef;
  168.   Uint32 senderData;  
  169.   Uint32 firstGCI;
  170.   Uint32 lastGCI;
  171.   Uint32 nodeGrp;
  172. };
  175. class RepGetGciBufferConf {
  176.   /**
  177.    * Sender(s)/Reciver(s)
  178.    */
  179.   friend class Rep;
  180.   
  181.   friend bool printREP_GET_GCIBUFFER_CONF(FILE *, const Uint32 *, 
  182.   Uint32, Uint16);
  184. public:
  185.   STATIC_CONST( SignalLength = 8 );
  186.   Uint32 senderData;
  187.   Uint32 senderRef;
  188.   Uint32 firstPSGCI;
  189.   Uint32 lastPSGCI;
  190.   Uint32 firstSSGCI;
  191.   Uint32 lastSSGCI;
  192.   Uint32 currentGCIBuffer;
  193.   Uint32 nodeGrp;
  194. };
  196. class RepGetGciBufferRef 
  197. {
  198.   /**
  199.    * Sender(s)/Reciver(s)
  200.    */
  201.   friend class Rep;
  202.   
  203.   friend bool printREP_GET_GCIBUFFER_REF(FILE *, const Uint32 *, 
  204.  Uint32, Uint16);
  205.  
  206. public:
  207.   STATIC_CONST( SignalLength = 9 );
  208.   Uint32 senderData;
  209.   Uint32 senderRef;
  210.   Uint32 firstPSGCI;
  211.   Uint32 lastPSGCI;
  212.   Uint32 firstSSGCI;
  213.   Uint32 lastSSGCI;
  214.   Uint32 currentGCIBuffer;
  215.   Uint32 nodeGrp;
  216.   GrepError::GE_Code err;
  217. };
  219. class RepInsertGciBufferReq 
  220. {
  221.   /**
  222.    * Sender(s)/Reciver(s)
  223.    */
  224.   friend class Rep;
  225.   
  226.   friend bool printREP_INSERT_GCIBUFFER_REQ(FILE *, const Uint32 *, 
  227.     Uint32, Uint16);
  228.     
  229. public:
  230.   STATIC_CONST( SignalLength = 5 );
  231.   Uint32 senderData;
  232.   Uint32 senderRef;
  233.   Uint32 gci;
  234.   Uint32 nodeGrp;
  235.   Uint32 force;
  236. };
  238. class RepInsertGciBufferRef 
  239. {
  240.   /**
  241.    * Sender(s)/Reciver(s)
  242.    */
  243.   friend class Rep;
  244.   
  245.   friend bool printREP_INSERT_GCIBUFFER_REF(FILE *, const Uint32 *, 
  246.     Uint32, Uint16);
  247. public:
  248.   STATIC_CONST( SignalLength = 7 );
  249.   Uint32 senderData;
  250.   Uint32 senderRef;
  251.   Uint32 gci;
  252.   Uint32 nodeGrp;
  253.   Uint32 tableId;
  254.   Uint32 force;
  255.   GrepError::GE_Code err;
  256. };
  258. class RepInsertGciBufferConf 
  259. {
  260.   /**
  261.    * Sender(s)/Reciver(s)
  262.    */
  263.   friend class Rep;
  264.   
  265.   friend bool printREP_INSERT_GCIBUFFER_CONF(FILE *, const Uint32 *, 
  266.      Uint32, Uint16);
  267. public:
  268.   STATIC_CONST( SignalLength = 5 );  
  269.   Uint32 senderData;
  270.   Uint32 senderRef;
  271.   Uint32 gci;
  272.   Uint32 nodeGrp;
  273.   Uint32 force;
  274. };
  277. class RepClearPSGciBufferReq 
  278. {
  279.   /**
  280.    * Sender(s)/Reciver(s)
  281.    */
  282.   friend class Rep;
  283.   
  284.   friend bool printREP_CLEAR_PS_GCIBUFFER_REQ(FILE *, const Uint32 *, 
  285.       Uint32, Uint16);
  286. public:
  287.   STATIC_CONST( SignalLength = 5 );  
  288.   Uint32 senderData;
  289.   Uint32 senderRef;
  290.   Uint32 firstGCI;
  291.   Uint32 lastGCI;
  292.   Uint32 nodeGrp;
  293. };
  295. class RepClearPSGciBufferRef 
  296. {
  297.   /**
  298.    * Sender(s)/Reciver(s)
  299.    */
  300.   friend class Rep;
  301.   
  302.   friend bool printREP_CLEAR_PS_GCIBUFFER_REF(FILE *, const Uint32 *, 
  303.       Uint32, Uint16);
  304.   
  305. public:
  306.   STATIC_CONST( SignalLength = 7 );  
  307.   Uint32 senderData;
  308.   Uint32 senderRef;
  309.   Uint32 firstGCI;
  310.   Uint32 lastGCI;
  311.   Uint32 currentGCI;
  312.   Uint32 nodeGrp;
  313.   GrepError::GE_Code err;
  314. };
  316. class RepClearPSGciBufferConf 
  317. {
  318.   /**
  319.    * Sender(s)/Reciver(s)
  320.    */
  321.   friend class Rep;
  322.   
  323.   friend bool printREP_CLEAR_PS_GCIBUFFER_CONF(FILE *, const Uint32 *, 
  324.        Uint32, Uint16);
  325. public:
  326.   STATIC_CONST( SignalLength = 5 );  
  327.   Uint32 senderData;
  328.   Uint32 senderRef;
  329.   Uint32 firstGCI;
  330.   Uint32 lastGCI;
  331.   Uint32 nodeGrp;
  332. };
  334. class RepClearSSGciBufferReq 
  335. {
  336.   /**
  337.    * Sender(s)/Reciver(s)
  338.    */
  339.   friend class Rep;
  340.   
  341.   friend bool printREP_CLEAR_SS_GCIBUFFER_REQ(FILE *, const Uint32 *, 
  342.       Uint32, Uint16);
  343. public:
  344.   STATIC_CONST( SignalLength = 5 );  
  345.   Uint32 senderData;
  346.   Uint32 senderRef;
  347.   Uint32 firstGCI;
  348.   Uint32 lastGCI;
  349.   Uint32 nodeGrp;
  350. };
  352. class RepClearSSGciBufferRef 
  353. {
  354.   /**
  355.    * Sender(s)/Reciver(s)
  356.    */
  357.   friend class Rep;
  358.   
  359.   friend bool printREP_CLEAR_SS_GCIBUFFER_REF(FILE *, const Uint32 *, 
  360.       Uint32, Uint16);
  361.       
  362. public:
  363.   STATIC_CONST( SignalLength = 7 );  
  364.   Uint32 senderData;
  365.   Uint32 senderRef;
  366.   Uint32 firstGCI;
  367.   Uint32 lastGCI;
  368.   Uint32 currentGCI;
  369.   Uint32 nodeGrp;
  370.   GrepError::GE_Code err;
  371. };
  373. class RepClearSSGciBufferConf 
  374. {
  375.   /**
  376.    * Sender(s)/Reciver(s)
  377.    */
  378.   friend class Rep;
  379.   
  380.   friend bool printREP_CLEAR_SS_GCIBUFFER_CONF(FILE *, const Uint32 *, 
  381.        Uint32, Uint16);
  382. public:
  383.   STATIC_CONST( SignalLength = 5 );  
  384.   Uint32 senderData;
  385.   Uint32 senderRef;
  386.   Uint32 firstGCI;
  387.   Uint32 lastGCI;
  388.   Uint32 nodeGrp;
  389. };
  392. class RepDataPage 
  393. {
  394.   /**
  395.    * Sender(s)/Reciver(s)
  396.    */
  397.   friend class Rep;
  398.   
  399.   friend bool printREP_DATA_PAGE(FILE *, const Uint32 *, Uint32, Uint16);
  400.  
  401. public:
  402.   STATIC_CONST( SignalLength = 4 );
  403.   Uint32 senderData;
  404.   Uint32 senderRef;
  405.   Uint32 nodeGrp;
  406.   Uint32 gci;  
  407. };
  410. class RepGciBufferAccRep 
  411. {
  412.   /**
  413.    * Sender(s)/Reciver(s)
  414.    */
  415.   friend class Rep;
  416.   
  417.   friend bool printREP_GCIBUFFER_ACC_REP(FILE *, const Uint32 *, 
  418.  Uint32, Uint16);
  419. public:
  420.   STATIC_CONST( SignalLength = 5 );
  421.   Uint32 senderData;
  422.   Uint32 senderRef;
  423.   Uint32 nodeGrp;
  424.   Uint32 gci;  
  425.   Uint32 totalSentBytes;  
  426. };
  428. class RepDropTableReq 
  429. {
  430.   /**
  431.    * Sender(s)/Reciver(s)
  432.    */
  433.   friend class Rep;
  434.   
  435.   friend bool printREP_DROP_TABLE_REQ(FILE *, const Uint32 *, 
  436.       Uint32, Uint16);
  437.   
  438. public:
  439.   STATIC_CONST( SignalLength = 4 );
  440.   Uint32 tableId;
  441.   //  char   tableName[MAX_TAB_NAME_SIZE]; 
  442. };
  444. class RepDropTableRef 
  445. {
  446.   /**
  447.    * Sender(s)/Reciver(s)
  448.    */
  449.   friend class Rep;
  450.   
  451.   friend bool printREP_DROP_TABLE_REF(FILE *, const Uint32 *, 
  452.       Uint32, Uint16);
  453.       
  454. public:
  455.   STATIC_CONST( SignalLength = 4 );
  456.   Uint32 tableId;
  457.   // char   tableName[MAX_TAB_NAME_SIZE]; 
  458. };
  460. class RepDropTableConf 
  461. {
  462.   /**
  463.    * Sender(s)/Reciver(s)
  464.    */
  465.   friend class Rep;
  466.   
  467.   friend bool printREP_DROP_TABLE_CONF(FILE *, const Uint32 *, Uint32, Uint16);
  468.       
  469. public:
  470.   STATIC_CONST( SignalLength = 4 );
  471.   Uint32 tableId;
  472.   //char   tableName[MAX_TAB_NAME_SIZE]; 
  473. };
  475. class RepDisconnectRep 
  476. {
  477.   /**
  478.    * Sender(s)/Reciver(s)
  479.    */
  480.   friend class Rep;
  481.   friend class Grep;
  482.   
  483.   friend bool printREP_DISCONNECT_REP(FILE *, const Uint32 *, Uint32, Uint16);
  484.       
  485. public:
  486.   enum NodeType {
  487.     DB = 0,
  488.     REP = 1
  489.   };
  490.   STATIC_CONST( SignalLength = 7 );
  491.   Uint32 senderData;
  492.   Uint32 senderRef;
  493.   Uint32 nodeId;
  494.   Uint32 nodeType;
  495.   Uint32 subId;
  496.   Uint32 subKey;
  497.   Uint32 err;
  498. };
  500. #endif