Category

Development Platform
Home > SourceCode/Document > Database system > MySQL > View Code
TransporterDefinitions.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++

TransporterDefinitions.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 TransporterDefinitions_H
  18. #define TransporterDefinitions_H
  20. #include <ndb_global.h> 
  21. #include <kernel_types.h> 
  22. #include <NdbOut.hpp>
  24. /**
  25.  * The maximum number of transporters allowed
  26.  * A maximum is needed to be able to allocate the array of transporters
  27.  */
  28. const int MAX_NTRANSPORTERS = 128;
  30. /**
  31.  * The sendbuffer limit after which the contents of the buffer is sent
  32.  */
  33. const int TCP_SEND_LIMIT = 64000;
  35. enum SendStatus { 
  36.   SEND_OK = 0, 
  37.   SEND_BLOCKED = 1, 
  38.   SEND_DISCONNECTED = 2, 
  39.   SEND_BUFFER_FULL = 3,
  40.   SEND_MESSAGE_TOO_BIG = 4,
  41.   SEND_UNKNOWN_NODE = 5
  42. };
  44. /**
  45.  * Protocol6 Header + 
  46.  *  (optional signal id) + (optional checksum) + (signal data)
  47.  */
  48. //const Uint32 MAX_MESSAGE_SIZE = (12+4+4+(4*25));
  49. const Uint32 MAX_MESSAGE_SIZE = (12+4+4+(4*25)+(3*4)+4*4096);
  51. /**
  52.  * TCP Transporter Configuration
  53.  */
  54. struct TCP_TransporterConfiguration {
  55.   Uint32 port; 
  56.   const char *remoteHostName;
  57.   const char *localHostName;
  58.   NodeId remoteNodeId;
  59.   NodeId localNodeId;
  60.   Uint32 sendBufferSize;     // Size of SendBuffer of priority B 
  61.   Uint32 maxReceiveSize;     // Maximum no of bytes to receive
  62.   bool checksum;
  63.   bool signalId;
  64. };
  66. /**
  67.  * SHM Transporter Configuration
  68.  */
  69. struct SHM_TransporterConfiguration {
  70.   Uint32 port; 
  71.   const char *remoteHostName;
  72.   const char *localHostName;
  73.   NodeId remoteNodeId;
  74.   NodeId localNodeId;
  75.   bool checksum;
  76.   bool signalId;
  77.   
  78.   Uint32 shmKey;
  79.   Uint32 shmSize;
  80.   int    signum;
  81. };
  83. /**
  84.  * OSE Transporter Configuration
  85.  */
  86. struct OSE_TransporterConfiguration {
  87.   const char *remoteHostName;
  88.   const char *localHostName;
  89.   NodeId remoteNodeId;
  90.   NodeId localNodeId;
  91.   bool checksum;
  92.   bool signalId;
  93.   
  94.   Uint32 prioASignalSize;
  95.   Uint32 prioBSignalSize;
  96.   Uint32 receiveBufferSize; // In number of signals
  97. };
  99. /**
  100.  * SCI Transporter Configuration
  101.  */
  102. struct SCI_TransporterConfiguration {
  103.   const char *remoteHostName;
  104.   const char *localHostName;
  105.   Uint32 port; 
  106.   Uint32 sendLimit;        // Packet size
  107.   Uint32 bufferSize;       // Buffer size
  109.   Uint32 nLocalAdapters;   // 1 or 2, the number of adapters on local host
  110.   
  111.   Uint32 remoteSciNodeId0; // SCInodeId for adapter 1
  112.   Uint32 remoteSciNodeId1; // SCInodeId for adapter 2
  113.   
  114.   NodeId localNodeId;      // Local node Id
  115.   NodeId remoteNodeId;     // Remote node Id
  117.   bool checksum;
  118.   bool signalId;
  120. };
  122. struct SignalHeader {
  123.   Uint32 theVerId_signalNumber;    // 4 bit ver id - 16 bit gsn
  124.   Uint32 theReceiversBlockNumber;  // Only 16 bit blocknum  
  125.   Uint32 theSendersBlockRef;
  126.   Uint32 theLength;
  127.   Uint32 theSendersSignalId;
  128.   Uint32 theSignalId;
  129.   Uint16 theTrace;
  130.   Uint8  m_noOfSections;
  131.   Uint8  m_fragmentInfo;
  132. }; /** 7x4 = 28 Bytes */
  134. struct LinearSectionPtr {
  135.   Uint32 sz;
  136.   Uint32 * p;
  137. };
  139. struct SegmentedSectionPtr {
  140.   Uint32 sz;
  141.   Uint32 i;
  142.   struct SectionSegment * p;
  144.   void setNull() { p = 0;}
  145.   bool isNull() const { return p == 0;}
  146. };
  148. class NdbOut & operator <<(class NdbOut & out, SignalHeader & sh);
  150. #endif // Define of TransporterDefinitions_H