diff options
Diffstat (limited to 'ndb/src/ndbapi/signal-sender/SignalSender.hpp')
-rw-r--r-- | ndb/src/ndbapi/signal-sender/SignalSender.hpp | 82 |
1 files changed, 0 insertions, 82 deletions
diff --git a/ndb/src/ndbapi/signal-sender/SignalSender.hpp b/ndb/src/ndbapi/signal-sender/SignalSender.hpp deleted file mode 100644 index e4e6c1931d2..00000000000 --- a/ndb/src/ndbapi/signal-sender/SignalSender.hpp +++ /dev/null @@ -1,82 +0,0 @@ -/* Copyright (C) 2003 MySQL AB - - This program is free software; you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation; either version 2 of the License, or - (at your option) any later version. - - This program is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - GNU General Public License for more details. - - You should have received a copy of the GNU General Public License - along with this program; if not, write to the Free Software - Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ - -#ifndef SIGNAL_SENDER_HPP -#define SIGNAL_SENDER_HPP - -#include <ndb_global.h> -#include <TransporterDefinitions.hpp> -#include <TransporterFacade.hpp> -#include <ClusterMgr.hpp> -#include <Vector.hpp> - -struct SimpleSignal { -public: - SimpleSignal(bool dealloc = false); - ~SimpleSignal(); - - void set(class SignalSender&, - Uint8 trace, Uint16 recBlock, Uint16 gsn, Uint32 len); - - struct SignalHeader header; - Uint32 theData[25]; - LinearSectionPtr ptr[3]; - - void print(FILE * out = stdout); -private: - bool deallocSections; -}; - -class SignalSender { -public: - SignalSender(const char * connectString = 0); - virtual ~SignalSender(); - - bool connectOne(Uint32 timeOutMillis = 0); - bool connectAll(Uint32 timeOutMillis = 0); - bool connect(Uint32 timeOutMillis = 0) { return connectAll(timeOutMillis);} - - Uint32 getOwnRef() const; - - Uint32 getAliveNode(); - Uint32 getNoOfConnectedNodes() const; - const ClusterMgr::Node & getNodeInfo(Uint16 nodeId) const; - - SendStatus sendSignal(Uint16 nodeId, const SimpleSignal *); - - SimpleSignal * waitFor(Uint32 timeOutMillis = 0); - SimpleSignal * waitFor(Uint16 nodeId, Uint32 timeOutMillis = 0); - SimpleSignal * waitFor(Uint16 nodeId, Uint16 gsn, Uint32 timeOutMillis = 0); - -private: - int m_blockNo; - TransporterFacade * theFacade; - - static void execSignal(void* signalSender, - NdbApiSignal* signal, - class LinearSectionPtr ptr[3]); - - static void execNodeStatus(void* signalSender, NodeId, - bool alive, bool nfCompleted); - - struct NdbCondition * m_cond; - Vector<SimpleSignal *> m_jobBuffer; - - template<class T> - SimpleSignal * waitFor(Uint32 timeOutMillis, T & t); -}; - -#endif |