1 files changed, 138 insertions, 0 deletions
diff --git a/storage/ndb/include/kernel/signaldata/TrigAttrInfo.hpp b/storage/ndb/include/kernel/signaldata/TrigAttrInfo.hpp
new file mode 100644
index 00000000000..e2c029b9033
--- /dev/null
+++ b/storage/ndb/include/kernel/signaldata/TrigAttrInfo.hpp
@@ -0,0 +1,138 @@
+/* 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 TRIG_ATTRINFO_HPP
+#define TRIG_ATTRINFO_HPP
+
+#include "SignalData.hpp"
+#include <NodeBitmask.hpp>
+#include <trigger_definitions.h>
+#include <string.h>
+
+/**
+ * TrigAttrInfo
+ *
+ * This signal is sent by TUP to signal
+ * that a trigger has fired
+ */
+class TrigAttrInfo {
+  /**
+   * Sender(s)
+   */
+  // API
+  
+  /**
+   * Sender(s) / Reciver(s)
+   */
+  friend class Dbtup;
+  
+  /**
+   * Reciver(s)
+   */
+  friend class Dbtc;
+  friend class Backup;
+  friend class SumaParticipant;
+
+  /**
+   * For printing
+   */
+  friend bool printTRIG_ATTRINFO(FILE * output, const Uint32 * theData, Uint32 len, Uint16 receiverBlockNo);
+
+public:
+enum AttrInfoType { 
+  PRIMARY_KEY = 0, 
+  BEFORE_VALUES = 1, 
+  AFTER_VALUES = 2 
+};
+
+  STATIC_CONST( DataLength = 22 );
+  STATIC_CONST( StaticLength = 3 );
+
+private:
+  Uint32 m_connectionPtr; 
+  Uint32 m_trigId;
+  Uint32 m_type;
+  Uint32 m_data[DataLength];
+
+  // Public methods
+public:
+  Uint32 getConnectionPtr() const;
+  void setConnectionPtr(Uint32);  
+  AttrInfoType getAttrInfoType() const;
+  void setAttrInfoType(AttrInfoType anAttrType);
+  Uint32 getTriggerId() const;
+  void setTriggerId(Uint32 aTriggerId);
+  Uint32 getTransactionId1() const;
+  void setTransactionId1(Uint32 aTransId);
+  Uint32 getTransactionId2() const;
+  void setTransactionId2(Uint32 aTransId);
+  Uint32* getData() const;
+  int setData(Uint32* aDataBuf, Uint32 aDataLen);
+};
+
+inline
+Uint32 TrigAttrInfo::getConnectionPtr() const
+{
+  return m_connectionPtr;
+}
+
+inline 
+void TrigAttrInfo::setConnectionPtr(Uint32 aConnectionPtr)
+{
+  m_connectionPtr = aConnectionPtr;
+}
+
+inline
+TrigAttrInfo::AttrInfoType TrigAttrInfo::getAttrInfoType() const
+{
+  return  (TrigAttrInfo::AttrInfoType) m_type;
+}
+
+inline
+void TrigAttrInfo::setAttrInfoType(TrigAttrInfo::AttrInfoType anAttrType)
+{
+  m_type = (Uint32) anAttrType;
+}
+
+inline
+Uint32 TrigAttrInfo::getTriggerId() const
+{
+  return m_trigId;
+}
+
+inline
+void TrigAttrInfo::setTriggerId(Uint32 aTriggerId)
+{
+  m_trigId = aTriggerId;
+}
+
+inline
+Uint32* TrigAttrInfo::getData() const
+{
+  return (Uint32*)&m_data[0];
+}
+
+inline
+int TrigAttrInfo::setData(Uint32* aDataBuf, Uint32 aDataLen)
+{
+  if (aDataLen > DataLength)
+    return -1;
+  memcpy(m_data, aDataBuf, aDataLen*sizeof(Uint32));
+
+  return 0;
+}
+
+#endif