Category

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

MySQL

Development Platform:

Visual C++

AccScan.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 ACC_SCAN_HPP
  18. #define ACC_SCAN_HPP
  20. #include "SignalData.hpp"
  22. /*
  23.  * Used by ACC and TUX scan.
  24.  */
  26. class AccScanReq {
  27.   /**
  28.    * Sender(s)
  29.    */
  30.   friend class Dblqh;
  32.   /**
  33.    * Reciver(s)
  34.    */
  35.   friend class Dbacc;
  36.   friend class Dbtux;
  37. public:
  38.   STATIC_CONST( SignalLength = 8 );
  39.   
  40. private:
  41.   Uint32 senderData;
  42.   Uint32 senderRef;
  43.   Uint32 tableId;
  44.   Uint32 fragmentNo;
  45.   Uint32 requestInfo;
  46.   Uint32 transId1;
  47.   Uint32 transId2;
  48.   Uint32 savePointId;
  50.   /**
  51.    * Previously there where also a scan type
  52.    */
  53.   static Uint32 getLockMode(const Uint32 & requestInfo);
  54.   static Uint32 getKeyinfoFlag(const Uint32 & requestInfo);
  55.   static Uint32 getReadCommittedFlag(const Uint32 & requestInfo);
  56.   
  57.   static void setLockMode(Uint32 & requestInfo, Uint32 lockMode);
  58.   static void setKeyinfoFlag(Uint32 & requestInfo, Uint32 keyinfo);
  59.   static void setReadCommittedFlag(Uint32 & requestInfo, Uint32 readCommitted);
  60. };
  62. /**
  63.  * Request Info
  64.  *
  65.  * l = Lock Mode             - 1  Bit 2
  66.  * k = Keyinfo               - 1  Bit 4
  67.  * h = Read Committed        - 1  Bit 5
  68.  *
  69.  *           1111111111222222222233
  70.  * 01234567890123456789012345678901
  71.  *   l kh    
  72.  */
  73. #define AS_LOCK_MODE_SHIFT       (2)
  74. #define AS_LOCK_MODE_MASK        (1)
  76. #define AS_KEYINFO_SHIFT         (4)
  77. #define AS_READ_COMMITTED_SHIFT  (5)
  79. inline 
  80. Uint32
  81. AccScanReq::getLockMode(const Uint32 & requestInfo){
  82.   return (requestInfo >> AS_LOCK_MODE_SHIFT) & AS_LOCK_MODE_MASK;
  83. }
  85. inline
  86. Uint32
  87. AccScanReq::getKeyinfoFlag(const Uint32 & requestInfo){
  88.   return (requestInfo >> AS_KEYINFO_SHIFT) & 1;
  89. }
  91. inline
  92. Uint32
  93. AccScanReq::getReadCommittedFlag(const Uint32 & requestInfo){
  94.   return (requestInfo >> AS_READ_COMMITTED_SHIFT) & 1;
  95. }
  97. inline
  98. void
  99. AccScanReq::setLockMode(UintR & requestInfo, UintR val){
  100.   ASSERT_MAX(val, AS_LOCK_MODE_MASK, "AccScanReq::setLockMode");
  101.   requestInfo |= (val << AS_LOCK_MODE_SHIFT);
  102. }
  104. inline
  105. void
  106. AccScanReq::setKeyinfoFlag(UintR & requestInfo, UintR val){
  107.   ASSERT_BOOL(val, "AccScanReq::setKeyinfoFlag");
  108.   requestInfo |= (val << AS_KEYINFO_SHIFT);
  109. }
  111. inline
  112. void
  113. AccScanReq::setReadCommittedFlag(UintR & requestInfo, UintR val){
  114.   ASSERT_BOOL(val, "AccScanReq::setReadCommittedFlag");
  115.   requestInfo |= (val << AS_READ_COMMITTED_SHIFT);
  116. }
  118. class AccScanConf {
  119.   /**
  120.    * Sender(s)
  121.    */
  122.   friend class Dbacc;
  123.   friend class Dbtux;
  125.   /**
  126.    * Reciver(s)
  127.    */
  128.   friend class Dblqh;
  130.   enum {
  131.     ZEMPTY_FRAGMENT = 0,
  132.     ZNOT_EMPTY_FRAGMENT = 1
  133.   };
  135. public:
  136.   STATIC_CONST( SignalLength = 8 );
  137.   
  138. private:
  139.   Uint32 scanPtr;
  140.   Uint32 accPtr;
  141.   Uint32 unused1;
  142.   Uint32 unused2;
  143.   Uint32 unused3;
  144.   Uint32 unused4;
  145.   Uint32 unused5;
  146.   Uint32 flag;
  147. };
  149. class AccCheckScan {
  150.   friend class Dbacc;
  151.   friend class Dbtux;
  152.   friend class Dblqh;
  153.   enum {
  154.     ZCHECK_LCP_STOP = 0,
  155.     ZNOT_CHECK_LCP_STOP = 1
  156.   };
  157. public:
  158.   STATIC_CONST( SignalLength = 2 );
  159. private:
  160.   Uint32 accPtr;                // scanptr.i in ACC or TUX
  161.   Uint32 checkLcpStop;          // from enum
  162. };
  164. #endif