GCIContainerPS.hpp
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:3k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2003 MySQL AB
  2.    This program is free software; you can redistribute it and/or modify
  3.    it under the terms of the GNU General Public License as published by
  4.    the Free Software Foundation; either version 2 of the License, or
  5.    (at your option) any later version.
  6.    This program is distributed in the hope that it will be useful,
  7.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  8.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  9.    GNU General Public License for more details.
  10.    You should have received a copy of the GNU General Public License
  11.    along with this program; if not, write to the Free Software
  12.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  13. #ifndef GCI_CONTAINER_PS_HPP
  14. #define GCI_CONTAINER_PS_HPP
  15. #include <Vector.hpp>
  16. #include <TransporterDefinitions.hpp>
  17. #include "NodeGroupInfo.hpp"
  18. #include <rep/storage/GCIContainer.hpp>
  19. #include <list>
  20. #include <iterator>
  21. /**
  22.  * @class GCIContainerPS
  23.  * @brief Interface to GCIContainer that takes node groups into account
  24.  */
  25. class GCIContainerPS 
  26. {
  27. public:
  28.   GCIContainerPS(Uint32 maxNoOfNodeGrps);
  29.   ~GCIContainerPS();
  30.   
  31.   void setNodeGroupInfo(NodeGroupInfo * info);
  32.   NodeGroupInfo * getNodeGroupInfo() {return m_nodeGroupInfo;};
  33.   
  34.   void createGCIBuffer(Uint32 gci, Uint32 id);
  35.   void getAvailableGCIBuffers(Uint32 id /*nodegrp */, 
  36.       Uint32 * first, Uint32 * last);
  37.   /***************************************************************************
  38.    * Record interface
  39.    ***************************************************************************/
  40.   void insertLogRecord(Uint32 grpId, Uint32 tableId, Uint32 operation,
  41.        class LinearSectionPtr ptr[3], Uint32 gci);
  42.   
  43.   void insertMetaRecord(Uint32 grpId, Uint32 tableId, 
  44. class LinearSectionPtr ptr[3], Uint32 gci);
  45.   /**
  46.    *  Destroy all buffers with GCI strictly less than gci.
  47.    */
  48.   void destroyGCIBuffersBeforeGCI(Uint32 gci);
  49.   /**
  50.    * Set that buffer is completed, i.e. no more records are to be inserted
  51.    */
  52.   void setCompleted(Uint32 gci, Uint32 id);
  53.   /**
  54.    * Fetch buffer
  55.    * @return    GCIBuffer for gci, or NULL if no buffer found
  56.    */
  57.   GCIBuffer * getGCIBuffer(Uint32 gci, Uint32 id);
  58.   /**
  59.    *  Destroy all buffers with GCI gci.
  60.    *  @return   true if buffer was deleted, false if no buffer exists
  61.    */
  62.   bool destroyGCIBuffer(Uint32 gci, Uint32 id);
  63.   /**
  64.    * Resets the gcicontainer to its original state (initial state and empty)
  65.    * @return   true if reset was ok
  66.    */
  67.   bool reset();
  68. private:
  69.   GCIContainer *         m_container;
  70.   NodeGroupInfo *        m_nodeGroupInfo;
  71. };
  72. #endif