Category

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

MySQL

Development Platform:

Visual C++

records.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. #include <NdbMain.h>
  18. #include <NdbOut.hpp>
  19. #include <ndb_types.h>
  21. #define ZNEW_PREP_OP_TYPE 0
  22. #define ZPREP_OP_TYPE 1
  23. #define ZCOMMIT_TYPE 2
  24. #define ZABORT_TYPE 3
  25. #define ZFD_TYPE 4
  26. #define ZFRAG_SPLIT_TYPE 5
  27. #define ZNEXT_LOG_RECORD_TYPE 6
  28. #define ZNEXT_MBYTE_TYPE 7
  29. #define ZCOMPLETED_GCI_TYPE 8
  30. #define ZINVALID_COMMIT_TYPE 9
  32. #define MAX_FILE_DESCRIPTORS 40
  33. #define NO_MBYTE_IN_FILE 16
  35. #define PAGESIZE 8192
  36. #define NO_PAGES_IN_MBYTE 32
  37. #define NO_MBYTE_IN_FILE 16
  39. #define COMMITTRANSACTIONRECORDSIZE 9
  40. #define COMPLETEDGCIRECORDSIZE 2
  41. #define PAGEHEADERSIZE 32
  42. #define FILEDESCRIPTORHEADERSIZE 3
  43. #define FILEDESCRIPTORRECORDSIZE 48
  44. #define NEXTMBYTERECORDSIZE 1
  45. #define ABORTTRANSACTIONRECORDSIZE 3
  48. //----------------------------------------------------------------
  49. // 
  50. //----------------------------------------------------------------
  52. class AbortTransactionRecord {
  53.   friend NdbOut& operator<<(NdbOut&, const AbortTransactionRecord&);
  54. public:
  55.   bool check();
  56.   Uint32 getLogRecordSize();
  57. protected:
  58.   Uint32 m_recordType;
  59.   Uint32 m_transactionId1;
  60.   Uint32 m_transactionId2;
  61. };
  64. //----------------------------------------------------------------
  65. // 
  66. //----------------------------------------------------------------
  68. class NextMbyteRecord {
  69.   friend NdbOut& operator<<(NdbOut&, const NextMbyteRecord&);
  70. public:
  71.   bool check();
  72.   Uint32 getLogRecordSize();
  73. protected:
  74.   Uint32 m_recordType;
  75. };
  77. //----------------------------------------------------------------
  78. // 
  79. //----------------------------------------------------------------
  82. class PrepareOperationRecord {
  83.   friend NdbOut& operator<<(NdbOut&, const PrepareOperationRecord&);
  84. public:
  85.   bool check();
  86.   Uint32 getLogRecordSize(Uint32 wordsRead);
  88. protected:
  89.   Uint32 m_recordType;
  90.   Uint32 m_logRecordSize;
  91.   Uint32 m_hashValue;
  92.   Uint32 m_operationType; // 0 READ, 1 UPDATE, 2 INSERT, 3 DELETE
  93.   Uint32 m_attributeLength;
  94.   Uint32 m_keyLength;
  95.   Uint32 *m_keyInfo; // In this order
  96.   Uint32 *m_attrInfo;// In this order
  97. };
  99. //----------------------------------------------------------------
  100. // 
  101. //----------------------------------------------------------------
  103. class CompletedGCIRecord {
  104.   friend NdbOut& operator<<(NdbOut&, const CompletedGCIRecord&);
  105. public:
  106.   bool check();
  107.   Uint32 getLogRecordSize();
  108. protected:
  109.   Uint32 m_recordType;
  110.   Uint32 m_theCompletedGCI;
  111. };
  113. //----------------------------------------------------------------
  114. // 
  115. //----------------------------------------------------------------
  117. class NextLogRecord {
  118.   friend NdbOut& operator<<(NdbOut&, const NextLogRecord&);
  119. public:
  120.   bool check();
  121.   Uint32 getLogRecordSize(Uint32);
  122. protected:
  123.   Uint32 m_recordType;
  124. };
  126. //----------------------------------------------------------------
  127. // 
  128. //----------------------------------------------------------------
  130. class PageHeader {
  131.   friend NdbOut& operator<<(NdbOut&, const PageHeader&);
  132. public:
  133.   bool check();
  134.   Uint32 getLogRecordSize();
  135.   bool lastPage();
  136.   Uint32 lastWord();
  137. protected:
  138.   Uint32 m_checksum;
  139.   Uint32 m_lap;
  140.   Uint32 m_max_gci_completed;
  141.   Uint32 m_max_gci_started;
  142.   Uint32 m_next_page;
  143.   Uint32 m_previous_page;
  144.   Uint32 m_ndb_version;
  145.   Uint32 m_number_of_logfiles;
  146.   Uint32 m_current_page_index;
  147.   Uint32 m_old_prepare_file_number;
  148.   Uint32 m_old_prepare_page_reference;
  149.   Uint32 m_dirty_flag;
  150. /* Debug info Start */
  151.   Uint32 m_log_timer;
  152.   Uint32 m_page_i_value;
  153.   Uint32 m_place_written_from;
  154.   Uint32 m_page_no;
  155.   Uint32 m_file_no;
  156.   Uint32 m_word_written;
  157.   Uint32 m_in_writing_flag;
  158.   Uint32 m_prev_page_no;
  159.   Uint32 m_in_free_list;
  160. /* Debug info End */
  161. };
  163. //----------------------------------------------------------------
  164. // File descriptor.
  165. //----------------------------------------------------------------
  167. class FileDescriptorHeader {
  168. public:
  169.  Uint32 m_recordType;
  170.   Uint32 m_noOfDescriptors;
  171.   Uint32 m_fileNo;
  172. };
  174. class FileDescriptorRecord {
  175. public:
  176.   Uint32 m_maxGciCompleted[16];
  177.   Uint32 m_maxGciStarted[16];
  178.   Uint32 m_lastPreparedReference[16];
  179. };
  181. class FileDescriptor {
  182.   friend NdbOut& operator<<(NdbOut&, const FileDescriptor&);
  183. public:
  184.   bool check();
  185.   Uint32 getLogRecordSize();
  186. protected:
  187.   void printARecord( Uint32 ) const;
  188.   FileDescriptorHeader m_fdHeader;
  189.   FileDescriptorRecord m_fdRecord[1];
  190. };
  193. //----------------------------------------------------------------
  194. // 
  195. //----------------------------------------------------------------
  197. class CommitTransactionRecord {
  198.   friend NdbOut& operator<<(NdbOut&, const CommitTransactionRecord&);
  199. public:
  200.   bool check();
  201.   Uint32 getLogRecordSize();
  202. protected:
  203.   Uint32 m_recordType;
  204.   Uint32 m_tableId;
  205.   Uint32 m_schemaVersion;
  206.   Uint32 m_fragmentId;
  207.   Uint32 m_fileNumberOfPrepareOperation;
  208.   Uint32 m_startPageNumberOfPrepareOperation;
  209.   Uint32 m_startPageIndexOfPrepareOperation;
  210.   Uint32 m_stopPageNumberOfPrepareOperation;
  211.   Uint32 m_globalCheckpoint;
  212. };
  214. //----------------------------------------------------------------
  215. // 
  216. //----------------------------------------------------------------
  218. class InvalidCommitTransactionRecord {
  219.   friend NdbOut& operator<<(NdbOut&, const InvalidCommitTransactionRecord&);
  220. public:
  221.   bool check();
  222.   Uint32 getLogRecordSize();
  223. protected:
  224.   Uint32 m_recordType;
  225.   Uint32 m_tableId;
  226.   Uint32 m_fragmentId;
  227.   Uint32 m_fileNumberOfPrepareOperation;
  228.   Uint32 m_startPageNumberOfPrepareOperation;
  229.   Uint32 m_startPageIndexOfPrepareOperation;
  230.   Uint32 m_stopPageNumberOfPrepareOperation;
  231.   Uint32 m_globalCheckpoint;
  232. };
  234. //----------------------------------------------------------------
  235. // 
  236. //----------------------------------------------------------------
  238. struct NextLogRec {
  240. };
  242. struct NewPrepareOperation {
  244. };
  246. struct FragmentSplit {
  248. };