Initial revision of NDB Cluster files

BitKeeper/etc/logging_ok:
  Logging to logging@openlogging.org accepted

1 files changed, 212 insertions, 0 deletions

diff --git a/ndb/src/ndbapi/NdbApiSignal.hpp b/ndb/src/ndbapi/NdbApiSignal.hpp
new file mode 100644
index 00000000000..76cefe0e882
--- /dev/null
+++ b/ndb/src/ndbapi/NdbApiSignal.hpp
@@ -0,0 +1,212 @@
+/* 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 */
+
+/**********************************************************************
+ * Name:		NdbApiSignal.H
+ * Include:	
+ * Link:		
+ * Author:		UABMNST Mona Natterkvist UAB/B/SD
+ * Date:		97----
+ * Version:	0.1
+ * Description:	Interface between TIS and NDB
+ * Documentation:
+ * Adjust:		971204  UABMNST   First version.
+ * Adjust:         000705  QABANAB   Changes in Protocol2
+ * Comment:	
+ *****************************************************************************/
+#ifndef NdbApiSignal_H
+#define NdbApiSignal_H
+
+#include <kernel_types.h>
+#include "AttrType.hpp" 
+#include "TransporterFacade.hpp"
+#include <TransporterDefinitions.hpp>
+#include "Ndb.hpp"
+
+#define CAST_PTR(X,Y) static_cast<X*>(static_cast<void*>(Y))
+#define CAST_CONSTPTR(X,Y) static_cast<const X*>(static_cast<const void*>(Y))
+
+/**
+ * A NdbApiSignal : public SignalHeader
+ *
+ * Stores the address to theData in theSignalId
+ */
+class NdbApiSignal : public SignalHeader
+ {
+public:  
+  			NdbApiSignal(BlockReference myRef);
+  			NdbApiSignal(const NdbApiSignal &);
+                        NdbApiSignal(const SignalHeader &header)
+			  : SignalHeader(header), theNextSignal(0), theRealData(0) {};
+  			~NdbApiSignal();
+
+  void                  set(Uint8  trace,
+			    Uint16 receiversBlockNumber,
+			    Uint16 signalNumber,
+			    Uint32 length);
+
+  
+  void 			setData(Uint32 aWord, Uint32 aDataNo);  
+  Uint32 		readData(Uint32 aDataNo) const; // Read word in signal
+  
+  int 			setSignal(int NdbSignalType);  	// Set signal header  
+  int 			readSignalNumber();    		// Read signal number  
+  Uint32             	getLength() const;
+  void	             	setLength(Uint32 aLength);
+  void 			next(NdbApiSignal* anApiSignal);  
+  NdbApiSignal* 	next();
+ 
+   const Uint32 *       getDataPtr() const;
+         Uint32 *       getDataPtrSend();
+
+  /**
+   * Fragmentation
+   */
+  bool isFirstFragment() const { return m_fragmentInfo <= 1;}
+  bool isLastFragment() const { 
+    return m_fragmentInfo == 0 || m_fragmentInfo == 3; 
+  }
+  
+  Uint32 getFragmentId() const { 
+    return (m_fragmentInfo == 0 ? 0 : getDataPtr()[theLength - 1]); 
+  }
+  
+private:
+  friend void execute(void * callbackObj, 
+		      struct SignalHeader * const header, 
+		      Uint8 prio, Uint32 * const theData, 
+		      LinearSectionPtr ptr[3]);
+   
+  void setDataPtr(Uint32 *);
+  
+  friend class NdbConnection;
+  friend class NdbScanReceiver;
+  friend class Table;
+  void copyFrom(const NdbApiSignal * src);
+
+  /**
+   * Only used when creating a signal in the api
+   */
+  Uint32 theData[25];
+  NdbApiSignal *theNextSignal;
+  Uint32 *theRealData;
+};
+/**********************************************************************
+void getLength
+Remark:        Get the length of the signal.
+******************************************************************************/
+inline
+Uint32
+NdbApiSignal::getLength() const{
+  return theLength;
+}
+
+/**********************************************************************
+void setLength
+Parameters:    aLength: Signal length
+Remark:        Set the length in the signal.
+******************************************************************************/
+inline
+void
+NdbApiSignal::setLength(Uint32 aLength){
+  theLength = aLength;
+}
+
+/**********************************************************************
+void next(NdbApiSignal* aSignal);
+
+Parameters:     aSignal: Signal object.
+Remark:         Insert signal rear in a linked list.   
+*****************************************************************************/
+inline
+void 
+NdbApiSignal::next(NdbApiSignal* aSignal){
+  theNextSignal = aSignal;
+}
+/**********************************************************************
+NdbApiSignal* next();
+
+Return Value:   Return theNext signal object if the next was successful.
+                Return NULL: In all other case.  
+Remark:         Read the theNext in signal.   
+*****************************************************************************/
+inline
+NdbApiSignal* 
+NdbApiSignal::next(){
+  return theNextSignal;
+}
+/**********************************************************************
+int readSignalNo();
+
+Return Value:    Return the signalNumber. 
+Remark:          Read signal number 
+*****************************************************************************/
+inline
+int		
+NdbApiSignal::readSignalNumber()
+{
+  return (int)theVerId_signalNumber;
+}
+/**********************************************************************
+Uint32 readData(Uint32 aDataNo);
+
+Return Value:   Return Data word in a signal.
+                Return -1: In all other case.
+                aDataNo: Data number in signal.
+Remark:         Return the dataWord information in a signal for a dataNo.  
+******************************************************************************/
+inline
+Uint32
+NdbApiSignal::readData(Uint32 aDataNo) const {
+  return getDataPtr()[aDataNo-1];
+}
+/**********************************************************************
+int setData(Uint32 aWord, int aDataNo);
+
+Return Value:   Return 0 : setData was successful.
+                Return -1: In all other case.  
+Parameters:     aWord: Data word.
+                aDataNo: Data number in signal.
+Remark:         Set Data word in signal 1 - 25  
+******************************************************************************/
+inline
+void
+NdbApiSignal::setData(Uint32 aWord, Uint32 aDataNo){
+  getDataPtrSend()[aDataNo -1] = aWord;
+}
+
+/**
+ * Return pointer to data structure
+ */
+inline
+const Uint32 *
+NdbApiSignal::getDataPtr() const {
+  return theRealData;
+}
+
+inline
+Uint32 *
+NdbApiSignal::getDataPtrSend(){
+  return (Uint32*)&theData[0];
+}
+
+inline
+void
+NdbApiSignal::setDataPtr(Uint32 * ptr){
+  theRealData = ptr;
+}
+
+#endif