Below is the list of changes that have just been committed into a local
5.1 repository of mtaylor. When mtaylor does a push these changes
will be propagated to the main repository and, within 24 hours after the
push, to the public repository.
For information on how to access the public repository
see http://dev.mysql.com/doc/mysql/en/installing-source-tree.html
ChangeSet@stripped, 2008-03-13 12:44:29-05:00, mtaylor@solace.(none) +6 -0
Renamed .h files to .hpp for consistency.
storage/ndb/include/mgmapi/NdbEventListener.hpp@stripped, 2008-03-13 12:44:27-05:00, mtaylor@solace.(none) +2 -2
Renamed .h files to .hpp for consistency.
storage/ndb/include/mgmapi/NdbEventListener.hpp@stripped, 2008-03-13 12:36:16-05:00, mtaylor@solace.(none) +0 -0
Rename: storage/ndb/include/mgmapi/NdbEventListener.h -> storage/ndb/include/mgmapi/NdbEventListener.hpp
storage/ndb/include/mgmapi/events.hpp@stripped, 2008-03-13 12:44:27-05:00, mtaylor@solace.(none) +2 -2
Renamed .h files to .hpp for consistency.
storage/ndb/include/mgmapi/events.hpp@stripped, 2008-03-13 12:36:05-05:00, mtaylor@solace.(none) +0 -0
Rename: storage/ndb/include/mgmapi/events.h -> storage/ndb/include/mgmapi/events.hpp
storage/ndb/include/mgmapi/listeners.hpp@stripped, 2008-03-13 12:44:27-05:00, mtaylor@solace.(none) +4 -4
Renamed .h files to .hpp for consistency.
storage/ndb/include/mgmapi/listeners.hpp@stripped, 2008-03-13 12:36:10-05:00, mtaylor@solace.(none) +0 -0
Rename: storage/ndb/include/mgmapi/listeners.h -> storage/ndb/include/mgmapi/listeners.hpp
storage/ndb/src/mgmapi/NdbEventListener.cpp@stripped, 2008-03-13 12:44:27-05:00, mtaylor@solace.(none) +1 -1
Renamed .h files to .hpp for consistency.
storage/ndb/src/mgmapi/events.cpp@stripped, 2008-03-13 12:44:27-05:00, mtaylor@solace.(none) +1 -1
Renamed .h files to .hpp for consistency.
storage/ndb/src/mgmapi/listeners.cpp@stripped, 2008-03-13 12:44:27-05:00, mtaylor@solace.(none) +1 -1
Renamed .h files to .hpp for consistency.
diff -Nrup a/storage/ndb/include/mgmapi/NdbEventListener.h b/storage/ndb/include/mgmapi/NdbEventListener.h
--- a/storage/ndb/include/mgmapi/NdbEventListener.h 2008-03-11 12:27:00 -05:00
+++ /dev/null Wed Dec 31 16:00:00 196900
@@ -1,91 +0,0 @@
-/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
- * vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
- *
- * Copyright (C) 2008 MySQL, Inc.
- *
- * 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
- */
-
-#ifndef NdbEventListener_h
-#define NdbEventListener_h
-
-#include "ndb_init.h"
-#include "mgmapi.h"
-#include "mgmapi_debug.h"
-
-#include <map>
-
-class NdbLogEventListener {
-public:
- virtual ~NdbLogEventListener() {}
- virtual void le_handleEvent(const ndb_logevent & event) {}
-};
-class NdbLogEventCategoryListener {
-public:
- virtual ~NdbLogEventCategoryListener() {}
- virtual void le_handleEvent(const ndb_logevent & event) {}
- virtual ndb_mgm_event_category getEventCategory() {
- return NDB_MGM_ILLEGAL_EVENT_CATEGORY;
- }
-};
-class NdbLogEventTypeListener {
-public:
- virtual ~NdbLogEventTypeListener() {}
- virtual void le_handleEvent(const ndb_logevent & event) {}
- virtual Ndb_logevent_type getEventType() { return NDB_LE_ILLEGAL_TYPE; }
-};
-
-
-struct BaseEventWrapper {
- int ret;
- ndb_logevent * theEvent;
-};
-
-
-
-class NdbLogEventManager {
-
-private:
-
- ndb_logevent_handle * handle;
-
- std::map<Ndb_logevent_type,NdbLogEventTypeListener *> evtListeners;
- std::map<ndb_mgm_event_category,NdbLogEventCategoryListener *> evtCategoryListeners;
-
-public:
-
- NdbLogEventManager(ndb_logevent_handle * theHandle);
-
- ~NdbLogEventManager();
-
- const char * getMgmError();
-
- // Returns -1 on error, 0 otherwise
- int registerListener(NdbLogEventTypeListener * listener);
-
- // Returns -1 on error, 0 otherwise
- int registerListener(NdbLogEventCategoryListener * listener);
-
-
- bool unregisterListener(NdbLogEventTypeListener * listener);
- bool unregisterListener(NdbLogEventCategoryListener * listener);
-
-
- BaseEventWrapper * getLogEvent(unsigned timeout_in_milliseconds);
- int pollEvents(unsigned timeout_in_milliseconds);
-};
-
-
-#endif
diff -Nrup a/storage/ndb/include/mgmapi/NdbEventListener.hpp b/storage/ndb/include/mgmapi/NdbEventListener.hpp
--- /dev/null Wed Dec 31 16:00:00 196900
+++ b/storage/ndb/include/mgmapi/NdbEventListener.hpp 2008-03-13 12:44:27 -05:00
@@ -0,0 +1,91 @@
+/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ * vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ * Copyright (C) 2008 MySQL, Inc.
+ *
+ * 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+
+#ifndef NdbEventListener_hpp
+#define NdbEventListener_hpp
+
+#include "ndb_init.h"
+#include "mgmapi.h"
+#include "mgmapi_debug.h"
+
+#include <map>
+
+class NdbLogEventListener {
+public:
+ virtual ~NdbLogEventListener() {}
+ virtual void le_handleEvent(const ndb_logevent & event) {}
+};
+class NdbLogEventCategoryListener {
+public:
+ virtual ~NdbLogEventCategoryListener() {}
+ virtual void le_handleEvent(const ndb_logevent & event) {}
+ virtual ndb_mgm_event_category getEventCategory() {
+ return NDB_MGM_ILLEGAL_EVENT_CATEGORY;
+ }
+};
+class NdbLogEventTypeListener {
+public:
+ virtual ~NdbLogEventTypeListener() {}
+ virtual void le_handleEvent(const ndb_logevent & event) {}
+ virtual Ndb_logevent_type getEventType() { return NDB_LE_ILLEGAL_TYPE; }
+};
+
+
+struct BaseEventWrapper {
+ int ret;
+ ndb_logevent * theEvent;
+};
+
+
+
+class NdbLogEventManager {
+
+private:
+
+ ndb_logevent_handle * handle;
+
+ std::map<Ndb_logevent_type,NdbLogEventTypeListener *> evtListeners;
+ std::map<ndb_mgm_event_category,NdbLogEventCategoryListener *> evtCategoryListeners;
+
+public:
+
+ NdbLogEventManager(ndb_logevent_handle * theHandle);
+
+ ~NdbLogEventManager();
+
+ const char * getMgmError();
+
+ // Returns -1 on error, 0 otherwise
+ int registerListener(NdbLogEventTypeListener * listener);
+
+ // Returns -1 on error, 0 otherwise
+ int registerListener(NdbLogEventCategoryListener * listener);
+
+
+ bool unregisterListener(NdbLogEventTypeListener * listener);
+ bool unregisterListener(NdbLogEventCategoryListener * listener);
+
+
+ BaseEventWrapper * getLogEvent(unsigned timeout_in_milliseconds);
+ int pollEvents(unsigned timeout_in_milliseconds);
+};
+
+
+#endif
diff -Nrup a/storage/ndb/include/mgmapi/events.h b/storage/ndb/include/mgmapi/events.h
--- a/storage/ndb/include/mgmapi/events.h 2008-03-11 12:27:00 -05:00
+++ /dev/null Wed Dec 31 16:00:00 196900
@@ -1,562 +0,0 @@
-/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
- * vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
- *
- * Copyright (C) 2008 MySQL, Inc.
- *
- * 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
- */
-
-#ifndef events_h
-#define events_h
-
-#include "ndb_init.h"
-#include "mgmapi.h"
-#include "mgmapi_debug.h"
-
-class BaseEvent {
- Ndb_logevent_type theType;
- int theSourceNodeId;
- Uint32 theEventTime;
- ndb_mgm_event_category theCategory;
- ndb_mgm_event_severity theSeverity;
-protected:
- BaseEvent();
-public:
- ndb_logevent event;
- explicit BaseEvent(const ndb_logevent & theEvent);
- Ndb_logevent_type getType();
- int getSourceNodeId();
- Uint32 getEventTime();
- ndb_mgm_event_category getEventCategory();
- ndb_mgm_event_severity getEventSeverity();
-};
-
-
-
-class Connected : public BaseEvent {
-public:
- explicit Connected(const ndb_logevent & theEvent);
- unsigned node;
-};
-
-class Disconnected : public BaseEvent {
-public:
- explicit Disconnected(const ndb_logevent & theEvent);
- unsigned node;
-};
-
-class CommunicationOpened : public BaseEvent {
-public:
- explicit CommunicationOpened(const ndb_logevent & theEvent);
- unsigned node;
-};
-
-class CommunicationClosed : public BaseEvent {
-public:
- explicit CommunicationClosed(const ndb_logevent & theEvent);
- unsigned node;
-};
-
-class ConnectedApiVersion : public BaseEvent {
-public:
- explicit ConnectedApiVersion(const ndb_logevent & theEvent);
- unsigned node;
- unsigned version;
-};
-
-
-class GlobalCheckpointStarted : public BaseEvent {
-public:
-
- unsigned gci;
-
- explicit GlobalCheckpointStarted(const ndb_logevent & theEvent);
-};
-
-class GlobalCheckpointCompleted : public BaseEvent {
-public:
-
- unsigned gci;
-
- explicit GlobalCheckpointCompleted(const ndb_logevent & theEvent);
-};
-
-
-class LocalCheckpointStarted : public BaseEvent {
-public:
-
- unsigned lci;
- unsigned keepGci;
- unsigned restoreGci;
-
- explicit LocalCheckpointStarted(const ndb_logevent & theEvent);
-};
-
-class LocalCheckpointCompleted : public BaseEvent {
-public:
-
- unsigned lci;
-
- explicit LocalCheckpointCompleted(const ndb_logevent & theEvent);
-};
-
-class LCPStoppedInCalcKeepGci : public BaseEvent {
-public:
- unsigned data;
-
- explicit LCPStoppedInCalcKeepGci(const ndb_logevent & theEvent);
-};
-
-class LCPFragmentCompleted : public BaseEvent {
-public:
- unsigned node;
- unsigned tableId;
- unsigned fragmentId;
-
- explicit LCPFragmentCompleted(const ndb_logevent & theEvent);
-};
-
-class UndoLogBlocked : public BaseEvent {
-public:
- unsigned accCount;
- unsigned tupCount;
-
- explicit UndoLogBlocked(const ndb_logevent & theEvent);
-};
-
-class NdbStartStarted : public BaseEvent {
-public:
- unsigned version;
-
- explicit NdbStartStarted(const ndb_logevent & theEvent);
-};
-
-class NdbStartCompleted : public BaseEvent {
-public:
- unsigned version;
-
- explicit NdbStartCompleted(const ndb_logevent & theEvent);
-};
-
-class STTORRYRecieved : public BaseEvent {
-public:
- explicit STTORRYRecieved(const ndb_logevent & theEvent);
-};
-
-class StartPhaseCompleted : public BaseEvent {
-public:
- unsigned phase;
- unsigned startType;
-
- explicit StartPhaseCompleted(const ndb_logevent & theEvent);
-};
-
-class CmRegConf : public BaseEvent {
-public:
- unsigned ownId;
- unsigned presidentId;
- unsigned dynamicId;
-
- explicit CmRegConf(const ndb_logevent & theEvent);
-};
-
-class CmRegRef : public BaseEvent {
-public:
- unsigned ownId;
- unsigned otherId;
- unsigned cause;
-
- explicit CmRegRef(const ndb_logevent & theEvent);
-};
-
-class FindNeighbours : public BaseEvent {
-public:
- unsigned ownId;
- unsigned leftId;
- unsigned rightId;
- unsigned dynamicId;
-
- explicit FindNeighbours(const ndb_logevent & theEvent);
-};
-
-class NdbStopStarted : public BaseEvent {
-public:
- unsigned stopType;
-
- explicit NdbStopStarted(const ndb_logevent & theEvent);
-};
-
-class NdbStopCompleted : public BaseEvent {
-public:
- unsigned action;
- unsigned sigNum;
-
- explicit NdbStopCompleted(const ndb_logevent & theEvent);
-};
-
-class NdbStopForced : public BaseEvent {
-public:
- unsigned action;
- unsigned signum;
- unsigned error;
- unsigned sphase;
- unsigned extra;
-
- explicit NdbStopForced(const ndb_logevent & theEvent);
-};
-
-class NdbStopAborted : public BaseEvent {
-public:
-
- explicit NdbStopAborted(const ndb_logevent & theEvent);
-};
-
-class StartREDOLog : public BaseEvent {
-public:
- unsigned node;
- unsigned keepGci;
- unsigned completedGci;
- unsigned restorableGci;
-
- explicit StartREDOLog(const ndb_logevent & theEvent);
-};
-
-class StartLog : public BaseEvent {
-public:
- unsigned logPart;
- unsigned startMb;
- unsigned stopMb;
- unsigned gci;
-
- explicit StartLog(const ndb_logevent & theEvent);
-};
-
-class UNDORecordsExecuted : public BaseEvent {
-public:
- unsigned block;
- unsigned data1;
- unsigned data2;
- unsigned data3;
- unsigned data4;
- unsigned data5;
- unsigned data6;
- unsigned data7;
- unsigned data8;
- unsigned data9;
- unsigned data10;
-
- explicit UNDORecordsExecuted(const ndb_logevent & theEvent);
-};
-
-class NRCopyDict : public BaseEvent {
-public:
-
- explicit NRCopyDict(const ndb_logevent & theEvent);
-};
-
-class NRCopyDistr : public BaseEvent {
-public:
-
- explicit NRCopyDistr(const ndb_logevent & theEvent);
-};
-
-class NRCopyFragsStarted : public BaseEvent {
-public:
- unsigned destNode;
-
- explicit NRCopyFragsStarted(const ndb_logevent & theEvent);
-};
-
-class NRCopyFragDone : public BaseEvent {
-public:
- unsigned destNode;
- unsigned tableId;
- unsigned fragmentId;
-
- explicit NRCopyFragDone(const ndb_logevent & theEvent);
-
-};
-
-class NRCopyFragsCompleted : public BaseEvent {
-public:
- unsigned destNode;
-
- explicit NRCopyFragsCompleted(const ndb_logevent & theEvent);
-
-};
-
-class NodeFailCompleted : public BaseEvent {
-public:
- unsigned block; /* 0 = all */
- unsigned failedNode;
- unsigned completingNode; /* 0 = all */
-
- explicit NodeFailCompleted(const ndb_logevent & theEvent);
-
-};
-
-class NodeFailReported : public BaseEvent {
-public:
- unsigned failedNode;
- unsigned failureState;
-
- explicit NodeFailReported(const ndb_logevent & theEvent);
-
-};
-
-class ArbitState : public BaseEvent {
-public:
-
- unsigned code; /* const code & state & << 16 ; */
- unsigned arbitNode;
- unsigned ticket0;
- unsigned ticket1;
-
- explicit ArbitState(const ndb_logevent & theEvent);
-
-};
-
-class ArbitResult : public BaseEvent {
-public:
- unsigned code; /* code & state << 16 */
- unsigned arbitNode;
- unsigned ticket0;
- unsigned ticket1;
-
- explicit ArbitResult(const ndb_logevent & theEvent);
-
-};
-
-class GCPTakeoverStarted : public BaseEvent {
-public:
-
- explicit GCPTakeoverStarted(const ndb_logevent & theEvent);
-};
-
-class GCPTakeoverCompleted : public BaseEvent {
-public:
-
- explicit GCPTakeoverCompleted(const ndb_logevent & theEvent);
-};
-
-class LCPTakeoverStarted : public BaseEvent {
-public:
-
- explicit LCPTakeoverStarted(const ndb_logevent & theEvent);
-};
-
-class LCPTakeoverCompleted : public BaseEvent {
-public:
- unsigned state;
-
- explicit LCPTakeoverCompleted(const ndb_logevent & theEvent);
-};
-
-class TransReportCounters : public BaseEvent {
-public:
- unsigned transCount;
- unsigned commitCount;
- unsigned readCount;
- unsigned simpleReadCount;
- unsigned writeCount;
- unsigned attrinfoCount;
- unsigned concOpCount;
- unsigned abortCount;
- unsigned scanCount;
- unsigned rangeScanCount;
-
- explicit TransReportCounters(const ndb_logevent & theEvent);
-
-};
-
-class OperationReportCounters : public BaseEvent {
-public:
- unsigned ops;
-
- explicit OperationReportCounters(const ndb_logevent & theEvent);
-
-};
-
-class TableCreated : public BaseEvent {
-public:
- unsigned tableId;
-
- explicit TableCreated(const ndb_logevent & theEvent);
-};
-
-class JobStatistic : public BaseEvent {
-public:
- unsigned meanLoopCount;
-
- explicit JobStatistic(const ndb_logevent & theEvent);
-};
-
-class SendBytesStatistic : public BaseEvent {
-public:
- unsigned toNode;
- unsigned meanSentBytes;
-
- explicit SendBytesStatistic(const ndb_logevent & theEvent);
-};
-
-class ReceiveBytesStatistic : public BaseEvent {
-public:
- unsigned fromNode;
- unsigned meanReceivedBytes;
-
- explicit ReceiveBytesStatistic(const ndb_logevent & theEvent);
-};
-
-class MemoryUsage : public BaseEvent {
-public:
- int gth;
- unsigned pageSizeKb;
- unsigned pagesUsed;
- unsigned pagesTotal;
- unsigned block;
-
- explicit MemoryUsage(const ndb_logevent & theEvent);
-};
-
-class TransporterError : public BaseEvent {
-public:
- unsigned toNode;
- unsigned code;
-
- explicit TransporterError(const ndb_logevent & theEvent);
-};
-
-class TransporterWarning : public BaseEvent {
-public:
- unsigned toNode;
- unsigned code;
-
- explicit TransporterWarning(const ndb_logevent & theEvent);
-};
-
-class MissedHeartbeat : public BaseEvent {
-public:
- unsigned node;
- unsigned count;
-
- explicit MissedHeartbeat(const ndb_logevent & theEvent);
-};
-
-class DeadDueToHeartbeat : public BaseEvent {
-public:
- unsigned node;
-
- explicit DeadDueToHeartbeat(const ndb_logevent & theEvent);
-};
-
-class Warning : public BaseEvent {
-public:
-
- explicit Warning(const ndb_logevent & theEvent);
-};
-
-class SentHeartbeat : public BaseEvent {
-public:
- unsigned node;
-
- explicit SentHeartbeat(const ndb_logevent & theEvent);
-};
-
-class CreateLogBytes : public BaseEvent {
-public:
- unsigned node;
-
- explicit CreateLogBytes(const ndb_logevent & theEvent);
-};
-
-class InfoEvent : public BaseEvent {
-public:
-
- explicit InfoEvent(const ndb_logevent & theEvent);
-};
-
-class EventBufferStatus : public BaseEvent {
-public:
- unsigned usage;
- unsigned alloc;
- unsigned max;
- unsigned applyGciL;
- unsigned applyGciH;
- unsigned latestGciL;
- unsigned latestGciH;
-
- explicit EventBufferStatus(const ndb_logevent & theEvent);
-};
-
-
-class BackupStarted : public BaseEvent {
-public:
- unsigned startingNode;
- unsigned backupId;
-
- explicit BackupStarted(const ndb_logevent & theEvent);
-};
-
-class BackupFailedToStart : public BaseEvent {
-public:
- unsigned startingNode;
- unsigned error;
-
- explicit BackupFailedToStart(const ndb_logevent & theEvent);
-};
-
-class BackupCompleted : public BaseEvent {
-public:
- unsigned startingNode;
- unsigned backupId;
- unsigned startGci;
- unsigned stopGci;
- unsigned numRecords;
- unsigned numLogRecords;
- unsigned numBytes;
- unsigned numLogBytes;
-
- explicit BackupCompleted(const ndb_logevent & theEvent);
-};
-
-class BackupAborted : public BaseEvent {
-public:
- unsigned startingNode;
- unsigned backupId;
- unsigned error;
-
- explicit BackupAborted(const ndb_logevent & theEvent);
-};
-
-class SingleUser : public BaseEvent {
-public:
- unsigned eventType;
- unsigned nodeId;
-
- explicit SingleUser(const ndb_logevent & theEvent);
-};
-
-class StartReport : public BaseEvent {
-public:
- unsigned reportType;
- unsigned remainingTime;
- unsigned bitmaskSize;
- //unsigned bitmaskData[1];
-
- explicit StartReport(const ndb_logevent & theEvent);
-};
-
-
-#endif
diff -Nrup a/storage/ndb/include/mgmapi/events.hpp b/storage/ndb/include/mgmapi/events.hpp
--- /dev/null Wed Dec 31 16:00:00 196900
+++ b/storage/ndb/include/mgmapi/events.hpp 2008-03-13 12:44:27 -05:00
@@ -0,0 +1,562 @@
+/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ * vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ * Copyright (C) 2008 MySQL, Inc.
+ *
+ * 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+
+#ifndef events_hpp
+#define events_hpp
+
+#include "ndb_init.h"
+#include "mgmapi.h"
+#include "mgmapi_debug.h"
+
+class BaseEvent {
+ Ndb_logevent_type theType;
+ int theSourceNodeId;
+ Uint32 theEventTime;
+ ndb_mgm_event_category theCategory;
+ ndb_mgm_event_severity theSeverity;
+protected:
+ BaseEvent();
+public:
+ ndb_logevent event;
+ explicit BaseEvent(const ndb_logevent & theEvent);
+ Ndb_logevent_type getType();
+ int getSourceNodeId();
+ Uint32 getEventTime();
+ ndb_mgm_event_category getEventCategory();
+ ndb_mgm_event_severity getEventSeverity();
+};
+
+
+
+class Connected : public BaseEvent {
+public:
+ explicit Connected(const ndb_logevent & theEvent);
+ unsigned node;
+};
+
+class Disconnected : public BaseEvent {
+public:
+ explicit Disconnected(const ndb_logevent & theEvent);
+ unsigned node;
+};
+
+class CommunicationOpened : public BaseEvent {
+public:
+ explicit CommunicationOpened(const ndb_logevent & theEvent);
+ unsigned node;
+};
+
+class CommunicationClosed : public BaseEvent {
+public:
+ explicit CommunicationClosed(const ndb_logevent & theEvent);
+ unsigned node;
+};
+
+class ConnectedApiVersion : public BaseEvent {
+public:
+ explicit ConnectedApiVersion(const ndb_logevent & theEvent);
+ unsigned node;
+ unsigned version;
+};
+
+
+class GlobalCheckpointStarted : public BaseEvent {
+public:
+
+ unsigned gci;
+
+ explicit GlobalCheckpointStarted(const ndb_logevent & theEvent);
+};
+
+class GlobalCheckpointCompleted : public BaseEvent {
+public:
+
+ unsigned gci;
+
+ explicit GlobalCheckpointCompleted(const ndb_logevent & theEvent);
+};
+
+
+class LocalCheckpointStarted : public BaseEvent {
+public:
+
+ unsigned lci;
+ unsigned keepGci;
+ unsigned restoreGci;
+
+ explicit LocalCheckpointStarted(const ndb_logevent & theEvent);
+};
+
+class LocalCheckpointCompleted : public BaseEvent {
+public:
+
+ unsigned lci;
+
+ explicit LocalCheckpointCompleted(const ndb_logevent & theEvent);
+};
+
+class LCPStoppedInCalcKeepGci : public BaseEvent {
+public:
+ unsigned data;
+
+ explicit LCPStoppedInCalcKeepGci(const ndb_logevent & theEvent);
+};
+
+class LCPFragmentCompleted : public BaseEvent {
+public:
+ unsigned node;
+ unsigned tableId;
+ unsigned fragmentId;
+
+ explicit LCPFragmentCompleted(const ndb_logevent & theEvent);
+};
+
+class UndoLogBlocked : public BaseEvent {
+public:
+ unsigned accCount;
+ unsigned tupCount;
+
+ explicit UndoLogBlocked(const ndb_logevent & theEvent);
+};
+
+class NdbStartStarted : public BaseEvent {
+public:
+ unsigned version;
+
+ explicit NdbStartStarted(const ndb_logevent & theEvent);
+};
+
+class NdbStartCompleted : public BaseEvent {
+public:
+ unsigned version;
+
+ explicit NdbStartCompleted(const ndb_logevent & theEvent);
+};
+
+class STTORRYRecieved : public BaseEvent {
+public:
+ explicit STTORRYRecieved(const ndb_logevent & theEvent);
+};
+
+class StartPhaseCompleted : public BaseEvent {
+public:
+ unsigned phase;
+ unsigned startType;
+
+ explicit StartPhaseCompleted(const ndb_logevent & theEvent);
+};
+
+class CmRegConf : public BaseEvent {
+public:
+ unsigned ownId;
+ unsigned presidentId;
+ unsigned dynamicId;
+
+ explicit CmRegConf(const ndb_logevent & theEvent);
+};
+
+class CmRegRef : public BaseEvent {
+public:
+ unsigned ownId;
+ unsigned otherId;
+ unsigned cause;
+
+ explicit CmRegRef(const ndb_logevent & theEvent);
+};
+
+class FindNeighbours : public BaseEvent {
+public:
+ unsigned ownId;
+ unsigned leftId;
+ unsigned rightId;
+ unsigned dynamicId;
+
+ explicit FindNeighbours(const ndb_logevent & theEvent);
+};
+
+class NdbStopStarted : public BaseEvent {
+public:
+ unsigned stopType;
+
+ explicit NdbStopStarted(const ndb_logevent & theEvent);
+};
+
+class NdbStopCompleted : public BaseEvent {
+public:
+ unsigned action;
+ unsigned sigNum;
+
+ explicit NdbStopCompleted(const ndb_logevent & theEvent);
+};
+
+class NdbStopForced : public BaseEvent {
+public:
+ unsigned action;
+ unsigned signum;
+ unsigned error;
+ unsigned sphase;
+ unsigned extra;
+
+ explicit NdbStopForced(const ndb_logevent & theEvent);
+};
+
+class NdbStopAborted : public BaseEvent {
+public:
+
+ explicit NdbStopAborted(const ndb_logevent & theEvent);
+};
+
+class StartREDOLog : public BaseEvent {
+public:
+ unsigned node;
+ unsigned keepGci;
+ unsigned completedGci;
+ unsigned restorableGci;
+
+ explicit StartREDOLog(const ndb_logevent & theEvent);
+};
+
+class StartLog : public BaseEvent {
+public:
+ unsigned logPart;
+ unsigned startMb;
+ unsigned stopMb;
+ unsigned gci;
+
+ explicit StartLog(const ndb_logevent & theEvent);
+};
+
+class UNDORecordsExecuted : public BaseEvent {
+public:
+ unsigned block;
+ unsigned data1;
+ unsigned data2;
+ unsigned data3;
+ unsigned data4;
+ unsigned data5;
+ unsigned data6;
+ unsigned data7;
+ unsigned data8;
+ unsigned data9;
+ unsigned data10;
+
+ explicit UNDORecordsExecuted(const ndb_logevent & theEvent);
+};
+
+class NRCopyDict : public BaseEvent {
+public:
+
+ explicit NRCopyDict(const ndb_logevent & theEvent);
+};
+
+class NRCopyDistr : public BaseEvent {
+public:
+
+ explicit NRCopyDistr(const ndb_logevent & theEvent);
+};
+
+class NRCopyFragsStarted : public BaseEvent {
+public:
+ unsigned destNode;
+
+ explicit NRCopyFragsStarted(const ndb_logevent & theEvent);
+};
+
+class NRCopyFragDone : public BaseEvent {
+public:
+ unsigned destNode;
+ unsigned tableId;
+ unsigned fragmentId;
+
+ explicit NRCopyFragDone(const ndb_logevent & theEvent);
+
+};
+
+class NRCopyFragsCompleted : public BaseEvent {
+public:
+ unsigned destNode;
+
+ explicit NRCopyFragsCompleted(const ndb_logevent & theEvent);
+
+};
+
+class NodeFailCompleted : public BaseEvent {
+public:
+ unsigned block; /* 0 = all */
+ unsigned failedNode;
+ unsigned completingNode; /* 0 = all */
+
+ explicit NodeFailCompleted(const ndb_logevent & theEvent);
+
+};
+
+class NodeFailReported : public BaseEvent {
+public:
+ unsigned failedNode;
+ unsigned failureState;
+
+ explicit NodeFailReported(const ndb_logevent & theEvent);
+
+};
+
+class ArbitState : public BaseEvent {
+public:
+
+ unsigned code; /* const code & state & << 16 ; */
+ unsigned arbitNode;
+ unsigned ticket0;
+ unsigned ticket1;
+
+ explicit ArbitState(const ndb_logevent & theEvent);
+
+};
+
+class ArbitResult : public BaseEvent {
+public:
+ unsigned code; /* code & state << 16 */
+ unsigned arbitNode;
+ unsigned ticket0;
+ unsigned ticket1;
+
+ explicit ArbitResult(const ndb_logevent & theEvent);
+
+};
+
+class GCPTakeoverStarted : public BaseEvent {
+public:
+
+ explicit GCPTakeoverStarted(const ndb_logevent & theEvent);
+};
+
+class GCPTakeoverCompleted : public BaseEvent {
+public:
+
+ explicit GCPTakeoverCompleted(const ndb_logevent & theEvent);
+};
+
+class LCPTakeoverStarted : public BaseEvent {
+public:
+
+ explicit LCPTakeoverStarted(const ndb_logevent & theEvent);
+};
+
+class LCPTakeoverCompleted : public BaseEvent {
+public:
+ unsigned state;
+
+ explicit LCPTakeoverCompleted(const ndb_logevent & theEvent);
+};
+
+class TransReportCounters : public BaseEvent {
+public:
+ unsigned transCount;
+ unsigned commitCount;
+ unsigned readCount;
+ unsigned simpleReadCount;
+ unsigned writeCount;
+ unsigned attrinfoCount;
+ unsigned concOpCount;
+ unsigned abortCount;
+ unsigned scanCount;
+ unsigned rangeScanCount;
+
+ explicit TransReportCounters(const ndb_logevent & theEvent);
+
+};
+
+class OperationReportCounters : public BaseEvent {
+public:
+ unsigned ops;
+
+ explicit OperationReportCounters(const ndb_logevent & theEvent);
+
+};
+
+class TableCreated : public BaseEvent {
+public:
+ unsigned tableId;
+
+ explicit TableCreated(const ndb_logevent & theEvent);
+};
+
+class JobStatistic : public BaseEvent {
+public:
+ unsigned meanLoopCount;
+
+ explicit JobStatistic(const ndb_logevent & theEvent);
+};
+
+class SendBytesStatistic : public BaseEvent {
+public:
+ unsigned toNode;
+ unsigned meanSentBytes;
+
+ explicit SendBytesStatistic(const ndb_logevent & theEvent);
+};
+
+class ReceiveBytesStatistic : public BaseEvent {
+public:
+ unsigned fromNode;
+ unsigned meanReceivedBytes;
+
+ explicit ReceiveBytesStatistic(const ndb_logevent & theEvent);
+};
+
+class MemoryUsage : public BaseEvent {
+public:
+ int gth;
+ unsigned pageSizeKb;
+ unsigned pagesUsed;
+ unsigned pagesTotal;
+ unsigned block;
+
+ explicit MemoryUsage(const ndb_logevent & theEvent);
+};
+
+class TransporterError : public BaseEvent {
+public:
+ unsigned toNode;
+ unsigned code;
+
+ explicit TransporterError(const ndb_logevent & theEvent);
+};
+
+class TransporterWarning : public BaseEvent {
+public:
+ unsigned toNode;
+ unsigned code;
+
+ explicit TransporterWarning(const ndb_logevent & theEvent);
+};
+
+class MissedHeartbeat : public BaseEvent {
+public:
+ unsigned node;
+ unsigned count;
+
+ explicit MissedHeartbeat(const ndb_logevent & theEvent);
+};
+
+class DeadDueToHeartbeat : public BaseEvent {
+public:
+ unsigned node;
+
+ explicit DeadDueToHeartbeat(const ndb_logevent & theEvent);
+};
+
+class Warning : public BaseEvent {
+public:
+
+ explicit Warning(const ndb_logevent & theEvent);
+};
+
+class SentHeartbeat : public BaseEvent {
+public:
+ unsigned node;
+
+ explicit SentHeartbeat(const ndb_logevent & theEvent);
+};
+
+class CreateLogBytes : public BaseEvent {
+public:
+ unsigned node;
+
+ explicit CreateLogBytes(const ndb_logevent & theEvent);
+};
+
+class InfoEvent : public BaseEvent {
+public:
+
+ explicit InfoEvent(const ndb_logevent & theEvent);
+};
+
+class EventBufferStatus : public BaseEvent {
+public:
+ unsigned usage;
+ unsigned alloc;
+ unsigned max;
+ unsigned applyGciL;
+ unsigned applyGciH;
+ unsigned latestGciL;
+ unsigned latestGciH;
+
+ explicit EventBufferStatus(const ndb_logevent & theEvent);
+};
+
+
+class BackupStarted : public BaseEvent {
+public:
+ unsigned startingNode;
+ unsigned backupId;
+
+ explicit BackupStarted(const ndb_logevent & theEvent);
+};
+
+class BackupFailedToStart : public BaseEvent {
+public:
+ unsigned startingNode;
+ unsigned error;
+
+ explicit BackupFailedToStart(const ndb_logevent & theEvent);
+};
+
+class BackupCompleted : public BaseEvent {
+public:
+ unsigned startingNode;
+ unsigned backupId;
+ unsigned startGci;
+ unsigned stopGci;
+ unsigned numRecords;
+ unsigned numLogRecords;
+ unsigned numBytes;
+ unsigned numLogBytes;
+
+ explicit BackupCompleted(const ndb_logevent & theEvent);
+};
+
+class BackupAborted : public BaseEvent {
+public:
+ unsigned startingNode;
+ unsigned backupId;
+ unsigned error;
+
+ explicit BackupAborted(const ndb_logevent & theEvent);
+};
+
+class SingleUser : public BaseEvent {
+public:
+ unsigned eventType;
+ unsigned nodeId;
+
+ explicit SingleUser(const ndb_logevent & theEvent);
+};
+
+class StartReport : public BaseEvent {
+public:
+ unsigned reportType;
+ unsigned remainingTime;
+ unsigned bitmaskSize;
+ //unsigned bitmaskData[1];
+
+ explicit StartReport(const ndb_logevent & theEvent);
+};
+
+
+#endif
diff -Nrup a/storage/ndb/include/mgmapi/listeners.h b/storage/ndb/include/mgmapi/listeners.h
--- a/storage/ndb/include/mgmapi/listeners.h 2008-03-11 12:27:00 -05:00
+++ /dev/null Wed Dec 31 16:00:00 196900
@@ -1,889 +0,0 @@
-/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
- * vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
- *
- * Copyright (C) 2008 MySQL, Inc.
- *
- * 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
- */
-
-#ifndef listeners_h
-#define listeners_h
-
-#include "ndb_init.h"
-#include "mgmapi.h"
-#include "mgmapi_debug.h"
-
-#include "events.h"
-#include "NdbEventListener.h"
-
-
-class ArbitResultTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- ArbitResult * wrappedEvent;
-
-public:
-
- virtual void handleEvent(ArbitResult * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-
-
-class ArbitStateTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- ArbitState * wrappedEvent;
-
-public:
-
- virtual void handleEvent(ArbitState * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-
-
-class BackupAbortedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- BackupAborted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(BackupAborted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class BackupCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- BackupCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(BackupCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class BackupFailedToStartTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- BackupFailedToStart * wrappedEvent;
-
-public:
-
- virtual void handleEvent(BackupFailedToStart * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class BackupStartedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- BackupStarted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(BackupStarted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class CmRegConfTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- CmRegConf * wrappedEvent;
-
-public:
-
- virtual void handleEvent(CmRegConf * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class CmRegRefTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- CmRegRef * wrappedEvent;
-
-public:
-
- virtual void handleEvent(CmRegRef * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class CommunicationClosedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- CommunicationClosed * wrappedEvent;
-
-public:
-
- virtual void handleEvent(CommunicationClosed * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class CommunicationOpenedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- CommunicationOpened * wrappedEvent;
-
-public:
-
- virtual void handleEvent(CommunicationOpened * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class ConnectedApiVersionTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- ConnectedApiVersion * wrappedEvent;
-
-public:
-
- virtual void handleEvent(ConnectedApiVersion * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class CreateLogBytesTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- CreateLogBytes * wrappedEvent;
-
-public:
-
- virtual void handleEvent(CreateLogBytes * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class DeadDueToHeartbeatTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- DeadDueToHeartbeat * wrappedEvent;
-
-public:
-
- virtual void handleEvent(DeadDueToHeartbeat * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class ConnectedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- Connected * wrappedEvent;
-
-public:
-
- virtual void handleEvent(Connected * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-class DisconnectedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- Disconnected * wrappedEvent;
-
-public:
-
- virtual void handleEvent(Disconnected * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class EventBufferStatusTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- EventBufferStatus * wrappedEvent;
-
-public:
-
- virtual void handleEvent(EventBufferStatus * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class FindNeighboursTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- FindNeighbours * wrappedEvent;
-
-public:
-
- virtual void handleEvent(FindNeighbours * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class GCPTakeoverCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- GCPTakeoverCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(GCPTakeoverCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class GCPTakeoverStartedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- GCPTakeoverStarted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(GCPTakeoverStarted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class GlobalCheckpointCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- GlobalCheckpointCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(GlobalCheckpointCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class GlobalCheckpointStartedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- GlobalCheckpointStarted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(GlobalCheckpointStarted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class InfoEventTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- InfoEvent * wrappedEvent;
-
-public:
-
- virtual void handleEvent(InfoEvent * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class JobStatisticTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- JobStatistic * wrappedEvent;
-
-public:
-
- virtual void handleEvent(JobStatistic * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class LCPFragmentCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- LCPFragmentCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(LCPFragmentCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class LCPStoppedInCalcKeepGciTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- LCPStoppedInCalcKeepGci * wrappedEvent;
-
-public:
-
- virtual void handleEvent(LCPStoppedInCalcKeepGci * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class LCPTakeoverCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- LCPTakeoverCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(LCPTakeoverCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class LCPTakeoverStartedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- LCPTakeoverStarted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(LCPTakeoverStarted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class LocalCheckpointCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- LocalCheckpointCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(LocalCheckpointCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class LocalCheckpointStartedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- LocalCheckpointStarted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(LocalCheckpointStarted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class MemoryUsageTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- MemoryUsage * wrappedEvent;
-
-public:
-
- virtual void handleEvent(MemoryUsage * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class MissedHeartbeatTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- MissedHeartbeat * wrappedEvent;
-
-public:
-
- virtual void handleEvent(MissedHeartbeat * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NdbStartCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NdbStartCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NdbStartCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NdbStartStartedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NdbStartStarted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NdbStartStarted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NdbStopAbortedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NdbStopAborted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NdbStopAborted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NdbStopCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NdbStopCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NdbStopCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NdbStopForcedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NdbStopForced * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NdbStopForced * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NdbStopStartedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NdbStopStarted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NdbStopStarted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NodeFailCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NodeFailCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NodeFailCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NodeFailReportedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NodeFailReported * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NodeFailReported * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NRCopyDictTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NRCopyDict * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NRCopyDict * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NRCopyDistrTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NRCopyDistr * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NRCopyDistr * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NRCopyFragDoneTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NRCopyFragDone * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NRCopyFragDone * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NRCopyFragsCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NRCopyFragsCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NRCopyFragsCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class NRCopyFragsStartedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- NRCopyFragsStarted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(NRCopyFragsStarted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class OperationReportCountersTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- OperationReportCounters * wrappedEvent;
-
-public:
-
- virtual void handleEvent(OperationReportCounters * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class ReceiveBytesStatisticTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- ReceiveBytesStatistic * wrappedEvent;
-
-public:
-
- virtual void handleEvent(ReceiveBytesStatistic * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class SendBytesStatisticTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- SendBytesStatistic * wrappedEvent;
-
-public:
-
- virtual void handleEvent(SendBytesStatistic * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class SentHeartbeatTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- SentHeartbeat * wrappedEvent;
-
-public:
-
- virtual void handleEvent(SentHeartbeat * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class SingleUserTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- SingleUser * wrappedEvent;
-
-public:
-
- virtual void handleEvent(SingleUser * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class StartLogTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- StartLog * wrappedEvent;
-
-public:
-
- virtual void handleEvent(StartLog * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class StartPhaseCompletedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- StartPhaseCompleted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(StartPhaseCompleted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class StartREDOLogTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- StartREDOLog * wrappedEvent;
-
-public:
-
- virtual void handleEvent(StartREDOLog * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class StartReportTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- StartReport * wrappedEvent;
-
-public:
-
- virtual void handleEvent(StartReport * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class STTORRYRecievedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- STTORRYRecieved * wrappedEvent;
-
-public:
-
- virtual void handleEvent(STTORRYRecieved * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class TableCreatedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- TableCreated * wrappedEvent;
-
-public:
-
- virtual void handleEvent(TableCreated * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class TransporterErrorTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- TransporterError * wrappedEvent;
-
-public:
-
- virtual void handleEvent(TransporterError * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class TransporterWarningTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- TransporterWarning * wrappedEvent;
-
-public:
-
- virtual void handleEvent(TransporterWarning * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class TransReportCountersTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- TransReportCounters * wrappedEvent;
-
-public:
-
- virtual void handleEvent(TransReportCounters * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class UndoLogBlockedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- UndoLogBlocked * wrappedEvent;
-
-public:
-
- virtual void handleEvent(UndoLogBlocked * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class UNDORecordsExecutedTypeListener : public NdbLogEventTypeListener {
-
-private:
-
- UNDORecordsExecuted * wrappedEvent;
-
-public:
-
- virtual void handleEvent(UNDORecordsExecuted * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-class WarningTypeListener : public NdbLogEventTypeListener {
-
-
- Warning * wrappedEvent;
-
-public:
-
- virtual void handleEvent(Warning * event) {};
- void le_handleEvent(const ndb_logevent & event);
- Ndb_logevent_type getEventType();
-
-};
-
-#endif
-
diff -Nrup a/storage/ndb/include/mgmapi/listeners.hpp b/storage/ndb/include/mgmapi/listeners.hpp
--- /dev/null Wed Dec 31 16:00:00 196900
+++ b/storage/ndb/include/mgmapi/listeners.hpp 2008-03-13 12:44:27 -05:00
@@ -0,0 +1,889 @@
+/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
+ * vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
+ *
+ * Copyright (C) 2008 MySQL, Inc.
+ *
+ * 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+
+#ifndef listeners_hpp
+#define listeners_hpp
+
+#include "ndb_init.h"
+#include "mgmapi.h"
+#include "mgmapi_debug.h"
+
+#include "events.hpp"
+#include "NdbEventListener.hpp"
+
+
+class ArbitResultTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ ArbitResult * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(ArbitResult * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+
+
+class ArbitStateTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ ArbitState * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(ArbitState * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+
+
+class BackupAbortedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ BackupAborted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(BackupAborted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class BackupCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ BackupCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(BackupCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class BackupFailedToStartTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ BackupFailedToStart * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(BackupFailedToStart * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class BackupStartedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ BackupStarted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(BackupStarted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class CmRegConfTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ CmRegConf * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(CmRegConf * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class CmRegRefTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ CmRegRef * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(CmRegRef * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class CommunicationClosedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ CommunicationClosed * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(CommunicationClosed * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class CommunicationOpenedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ CommunicationOpened * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(CommunicationOpened * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class ConnectedApiVersionTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ ConnectedApiVersion * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(ConnectedApiVersion * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class CreateLogBytesTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ CreateLogBytes * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(CreateLogBytes * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class DeadDueToHeartbeatTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ DeadDueToHeartbeat * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(DeadDueToHeartbeat * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class ConnectedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ Connected * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(Connected * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+class DisconnectedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ Disconnected * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(Disconnected * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class EventBufferStatusTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ EventBufferStatus * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(EventBufferStatus * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class FindNeighboursTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ FindNeighbours * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(FindNeighbours * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class GCPTakeoverCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ GCPTakeoverCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(GCPTakeoverCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class GCPTakeoverStartedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ GCPTakeoverStarted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(GCPTakeoverStarted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class GlobalCheckpointCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ GlobalCheckpointCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(GlobalCheckpointCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class GlobalCheckpointStartedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ GlobalCheckpointStarted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(GlobalCheckpointStarted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class InfoEventTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ InfoEvent * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(InfoEvent * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class JobStatisticTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ JobStatistic * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(JobStatistic * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class LCPFragmentCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ LCPFragmentCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(LCPFragmentCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class LCPStoppedInCalcKeepGciTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ LCPStoppedInCalcKeepGci * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(LCPStoppedInCalcKeepGci * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class LCPTakeoverCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ LCPTakeoverCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(LCPTakeoverCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class LCPTakeoverStartedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ LCPTakeoverStarted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(LCPTakeoverStarted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class LocalCheckpointCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ LocalCheckpointCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(LocalCheckpointCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class LocalCheckpointStartedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ LocalCheckpointStarted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(LocalCheckpointStarted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class MemoryUsageTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ MemoryUsage * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(MemoryUsage * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class MissedHeartbeatTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ MissedHeartbeat * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(MissedHeartbeat * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NdbStartCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NdbStartCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NdbStartCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NdbStartStartedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NdbStartStarted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NdbStartStarted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NdbStopAbortedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NdbStopAborted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NdbStopAborted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NdbStopCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NdbStopCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NdbStopCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NdbStopForcedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NdbStopForced * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NdbStopForced * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NdbStopStartedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NdbStopStarted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NdbStopStarted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NodeFailCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NodeFailCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NodeFailCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NodeFailReportedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NodeFailReported * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NodeFailReported * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NRCopyDictTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NRCopyDict * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NRCopyDict * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NRCopyDistrTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NRCopyDistr * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NRCopyDistr * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NRCopyFragDoneTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NRCopyFragDone * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NRCopyFragDone * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NRCopyFragsCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NRCopyFragsCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NRCopyFragsCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class NRCopyFragsStartedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ NRCopyFragsStarted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(NRCopyFragsStarted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class OperationReportCountersTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ OperationReportCounters * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(OperationReportCounters * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class ReceiveBytesStatisticTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ ReceiveBytesStatistic * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(ReceiveBytesStatistic * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class SendBytesStatisticTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ SendBytesStatistic * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(SendBytesStatistic * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class SentHeartbeatTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ SentHeartbeat * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(SentHeartbeat * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class SingleUserTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ SingleUser * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(SingleUser * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class StartLogTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ StartLog * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(StartLog * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class StartPhaseCompletedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ StartPhaseCompleted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(StartPhaseCompleted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class StartREDOLogTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ StartREDOLog * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(StartREDOLog * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class StartReportTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ StartReport * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(StartReport * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class STTORRYRecievedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ STTORRYRecieved * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(STTORRYRecieved * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class TableCreatedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ TableCreated * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(TableCreated * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class TransporterErrorTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ TransporterError * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(TransporterError * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class TransporterWarningTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ TransporterWarning * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(TransporterWarning * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class TransReportCountersTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ TransReportCounters * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(TransReportCounters * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class UndoLogBlockedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ UndoLogBlocked * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(UndoLogBlocked * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class UNDORecordsExecutedTypeListener : public NdbLogEventTypeListener {
+
+private:
+
+ UNDORecordsExecuted * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(UNDORecordsExecuted * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+class WarningTypeListener : public NdbLogEventTypeListener {
+
+
+ Warning * wrappedEvent;
+
+public:
+
+ virtual void handleEvent(Warning * event) {};
+ void le_handleEvent(const ndb_logevent & event);
+ Ndb_logevent_type getEventType();
+
+};
+
+#endif
+
diff -Nrup a/storage/ndb/src/mgmapi/NdbEventListener.cpp b/storage/ndb/src/mgmapi/NdbEventListener.cpp
--- a/storage/ndb/src/mgmapi/NdbEventListener.cpp 2008-03-11 12:26:59 -05:00
+++ b/storage/ndb/src/mgmapi/NdbEventListener.cpp 2008-03-13 12:44:27 -05:00
@@ -19,7 +19,7 @@
*/
-#include "NdbEventListener.h"
+#include "NdbEventListener.hpp"
NdbLogEventManager::NdbLogEventManager(ndb_logevent_handle * theHandle) {
diff -Nrup a/storage/ndb/src/mgmapi/events.cpp b/storage/ndb/src/mgmapi/events.cpp
--- a/storage/ndb/src/mgmapi/events.cpp 2008-03-11 12:26:59 -05:00
+++ b/storage/ndb/src/mgmapi/events.cpp 2008-03-13 12:44:27 -05:00
@@ -19,7 +19,7 @@
*/
-#include "events.h"
+#include "events.hpp"
//BaseEvent::BaseEvent() {}
diff -Nrup a/storage/ndb/src/mgmapi/listeners.cpp b/storage/ndb/src/mgmapi/listeners.cpp
--- a/storage/ndb/src/mgmapi/listeners.cpp 2008-03-11 12:26:59 -05:00
+++ b/storage/ndb/src/mgmapi/listeners.cpp 2008-03-13 12:44:27 -05:00
@@ -18,7 +18,7 @@
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
-#include "listeners.h"
+#include "listeners.hpp"
Ndb_logevent_type ArbitResultTypeListener::getEventType() {
return NDB_LE_ArbitResult;
| Thread |
|---|
| • bk commit into 5.1 tree (mtaylor:1.2551) | Monty Taylor | 13 Mar |
