Category

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

ExtNDB.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 EXTNDB_HPP
  18. #define EXTNDB_HPP
  20. #include <ndb_global.h>
  22. #include <TransporterDefinitions.hpp>
  23. #include <TransporterFacade.hpp>
  24. #include <ClusterMgr.hpp>
  25. #include <API.hpp>
  26. #include <Vector.hpp>
  28. #include <signaldata/RepImpl.hpp>
  29. #include <signaldata/GrepImpl.hpp>
  31. #include <rep/SignalQueue.hpp>
  32. #include <rep/ExtSender.hpp>
  34. #include <rep/storage/GCIContainerPS.hpp>
  35. #include "ExtAPI.hpp"
  37. extern "C" {
  38. static void * signalExecThread_C(void *);
  39. }
  41. /**
  42.  * @class ExtNDB
  43.  * @brief Class responsible for connection to primary system GREP
  44.  */
  45. class ExtNDB 
  46. {
  47. public:
  48.   /***************************************************************************
  49.    * Constructor / Destructor
  50.    ***************************************************************************/
  51.   ExtNDB(GCIContainerPS * gciContainer, ExtAPI * extAPI);
  52.   ~ExtNDB();
  53.   bool init(const char * connectString = NULL);
  54.   
  55.   /***************************************************************************
  56.    * Public Methods
  57.    ***************************************************************************/
  58.   void           setGrepSender(ExtSender * es) { m_grepSender = es; };
  59.   ExtSender *    getGrepSender() { return m_grepSender; };
  60.   void           setRepSender(ExtSender * es) { 
  61.     m_extAPI->setRepSender(es); m_repSender = es; };
  62.   void           signalErrorHandler(NdbApiSignal * s, Uint32 nodeId);
  64. private:
  65.   friend void * signalExecThread_C(void *);
  66.   void           signalExecThreadRun();
  67.   
  68.   static void    execSignal(void* signalSender, NdbApiSignal* signal, 
  69.     class LinearSectionPtr ptr[3]);
  70.   
  71.   static void    execNodeStatus(void* signalSender, NodeId, 
  72. bool alive, bool nfCompleted);
  73.   
  74.   void           sendSignalRep(NdbApiSignal *);
  75.   void           sendDisconnectRep(Uint32 nodeId);
  77.   /***************************************************************************
  78.    * Signal Executors
  79.    ***************************************************************************/
  80.   void execSUB_GCP_COMPLETE_REP(NdbApiSignal*);
  81.   void execGREP_SUB_CREATE_CONF(NdbApiSignal * signal);
  82.   void execGREP_SUB_REMOVE_CONF(NdbApiSignal * signal);
  83.   void execGREP_SUB_START_CONF(NdbApiSignal * signal);
  84.   void sendGREP_SUB_START_CONF(NdbApiSignal * signal, Uint32 gci);
  85.   void execSUB_TABLE_DATA(NdbApiSignal * signal,LinearSectionPtr ptr[3]);
  86.   void execSUB_META_DATA(NdbApiSignal * signal,LinearSectionPtr ptr[3]);
  87.   
  88.   // Signals that are actually just fowarded to REP
  89.   void execGREP_CREATE_SUBID_CONF(NdbApiSignal *);
  91.   /***************************************************************************
  92.    * Private Variables
  93.    ***************************************************************************/
  94.   struct NdbThread *      m_signalExecThread;
  95.   class SignalQueue       m_signalRecvQueue;
  97.   Uint32                  m_ownNodeId;          ///< NodeId of this node
  98.   Uint32                  m_ownBlockNo;         ///< BlockNo of this "block"
  99.   BlockReference          m_ownRef;             ///< Reference to this 
  100.   
  101.   ExtSender *             m_grepSender;         ///< Responsible send to GREP
  102.   ExtSender *             m_repSender;          ///< Responsible send to SS REP
  103.   
  104.   NodeGroupInfo *   m_nodeGroupInfo;
  105.   GCIContainerPS *   m_gciContainerPS; ///< Interface to GCICotainer
  106. ///< seen by PS
  107.   TransporterFacade *   m_transporterFacade;
  109.   bool                    m_doneSetGrepSender;    ///< Only done once
  110.   bool                    m_dataLogStarted;
  111.   Uint32                  m_subId;
  112.   Uint32                  m_subKey;
  113.   Uint32                  m_firstGCI;
  115.   ExtAPI *                m_extAPI;
  116. };
  118. #endif