Category

Development Platform
Home > SourceCode/Document > Database system > MySQL > View Code
LCP.hpp
Package: mysql-4.1.16-win-src.zip　[view]
Upload User: romrleung
Upload Date: 2022-05-23
Package Size: 18897k
Code Size: 3k
Category:

MySQL

Development Platform:

Visual C++

LCP.hpp：Code Content
  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 LCP_SIGNAL_DATA_HPP
  18. #define LCP_SIGNAL_DATA_HPP
  20. #include "SignalData.hpp"
  21. #include <NodeBitmask.hpp>
  23. class StartLcpReq {
  24.   /**
  25.    * Sender(s)
  26.    */
  27.   friend class Dbdih;
  28.   
  29.   /**
  30.    * Sender(s) / Receiver(s)
  31.    */
  32.   
  33.   /**
  34.    * Receiver(s)
  35.    */
  36.   friend class Dblqh;
  38.   friend bool printSTART_LCP_REQ(FILE *, const Uint32 *, Uint32, Uint16);  
  39. public:
  41.   STATIC_CONST( SignalLength = 2 + 2 * NdbNodeBitmask::Size );
  42. private:
  43.   Uint32 senderRef;
  44.   Uint32 lcpId;
  45.   
  46.   NdbNodeBitmask participatingDIH;
  47.   NdbNodeBitmask participatingLQH;
  48. };
  50. class StartLcpConf {
  51.   /**
  52.    * Sender(s)
  53.    */
  54.   friend class Dblqh;
  55.   
  56.   /**
  57.    * Sender(s) / Receiver(s)
  58.    */
  59.   
  60.   /**
  61.    * Receiver(s)
  62.    */
  63.   friend class Dbdih;
  65.   friend bool printSTART_LCP_CONF(FILE *, const Uint32 *, Uint32, Uint16);  
  66. public:
  67.   
  68.   STATIC_CONST( SignalLength = 2 );
  69. private:
  70.   Uint32 senderRef;
  71.   Uint32 lcpId;
  72. };
  74. /**
  75.  * This signals is sent by Dbdih to Dblqh
  76.  * to order checkpointing of a certain
  77.  * fragment.
  78.  */
  79. class LcpFragOrd {
  80.   /**
  81.    * Sender(s)
  82.    */
  83.   friend class Dbdih;
  84.   
  85.   /**
  86.    * Sender(s) / Receiver(s)
  87.    */
  88.   
  89.   /**
  90.    * Receiver(s)
  91.    */
  92.   friend class Dblqh;
  94.   friend bool printLCP_FRAG_ORD(FILE *, const Uint32 *, Uint32, Uint16);  
  95. public:
  96.   STATIC_CONST( SignalLength = 6 );
  97. private:
  98.   
  99.   Uint32 tableId;
  100.   Uint32 fragmentId;
  101.   Uint32 lcpNo;
  102.   Uint32 lcpId;
  103.   Uint32 lastFragmentFlag;
  104.   Uint32 keepGci;
  105. };
  108. class LcpFragRep {
  109.   /**
  110.    * Sender(s) and receiver(s)
  111.    */
  112.   friend class Dbdih;
  114.   /**
  115.    * Sender(s)
  116.    */
  117.   friend class Dblqh;
  119.   friend bool printLCP_FRAG_REP(FILE *, const Uint32 *, Uint32, Uint16);  
  120. public:
  121.   STATIC_CONST( SignalLength = 7 );
  123. private:
  124.   Uint32 nodeId;
  125.   Uint32 lcpId;
  126.   Uint32 lcpNo;
  127.   Uint32 tableId;
  128.   Uint32 fragId;
  129.   Uint32 maxGciCompleted;
  130.   Uint32 maxGciStarted;
  131. };
  133. class LcpCompleteRep {
  134.   /**
  135.    * Sender(s) and receiver(s)
  136.    */
  137.   friend class Dbdih;
  138.   
  139.   /**
  140.    * Sender(s)
  141.    */
  142.   friend class Dblqh;
  144.   friend bool printLCP_COMPLETE_REP(FILE *, const Uint32 *, Uint32, Uint16);  
  145. public:
  146.   STATIC_CONST( SignalLength = 3 );
  147.   
  148. private:
  149.   Uint32 nodeId;
  150.   Uint32 blockNo;
  151.   Uint32 lcpId;
  152. };
  154. #endif