summaryrefslogtreecommitdiff
path: root/storage/ndb/src/common/debugger/signaldata/MasterLCP.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'storage/ndb/src/common/debugger/signaldata/MasterLCP.cpp')
-rw-r--r--storage/ndb/src/common/debugger/signaldata/MasterLCP.cpp87
1 files changed, 87 insertions, 0 deletions
diff --git a/storage/ndb/src/common/debugger/signaldata/MasterLCP.cpp b/storage/ndb/src/common/debugger/signaldata/MasterLCP.cpp
new file mode 100644
index 00000000000..078b92f6f2e
--- /dev/null
+++ b/storage/ndb/src/common/debugger/signaldata/MasterLCP.cpp
@@ -0,0 +1,87 @@
+/* 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 */
+
+
+#include <signaldata/MasterLCP.hpp>
+#include <RefConvert.hpp>
+
+static
+void
+print(char *buf, size_t buf_len, MasterLCPConf::State s){
+ switch(s){
+ case MasterLCPConf::LCP_STATUS_IDLE:
+ BaseString::snprintf(buf, buf_len, "LCP_STATUS_IDLE");
+ break;
+ case MasterLCPConf::LCP_STATUS_ACTIVE:
+ BaseString::snprintf(buf, buf_len, "LCP_STATUS_ACTIVE");
+ break;
+ case MasterLCPConf::LCP_TAB_COMPLETED:
+ BaseString::snprintf(buf, buf_len, "LCP_TAB_COMPLETED");
+ break;
+ case MasterLCPConf::LCP_TAB_SAVED:
+ BaseString::snprintf(buf, buf_len, "LCP_TAB_SAVED");
+ break;
+ }
+}
+
+NdbOut &
+operator<<(NdbOut& out, const MasterLCPConf::State& s){
+ static char buf[255];
+ print(buf, sizeof(buf), s);
+ out << buf;
+ return out;
+}
+
+bool
+printMASTER_LCP_CONF(FILE * output,
+ const Uint32 * theData,
+ Uint32 len,
+ Uint16 recBlockNo){
+
+ MasterLCPConf * sig = (MasterLCPConf *)&theData[0];
+
+ static char buf[255];
+ print(buf, sizeof(buf), (MasterLCPConf::State)sig->lcpState);
+ fprintf(output, " senderNode=%d failedNode=%d SenderState=%s\n",
+ sig->senderNodeId, sig->failedNodeId, buf);
+ return true;
+}
+
+bool
+printMASTER_LCP_REQ(FILE * output,
+ const Uint32 * theData,
+ Uint32 len,
+ Uint16 recBlockNo){
+
+ MasterLCPReq * sig = (MasterLCPReq *)&theData[0];
+
+ fprintf(output, " masterRef=(node=%d, block=%d), failedNode=%d\n",
+ refToNode(sig->masterRef), refToBlock(sig->masterRef),
+ sig->failedNodeId);
+ return true;
+}
+
+bool
+printMASTER_LCP_REF(FILE * output,
+ const Uint32 * theData,
+ Uint32 len,
+ Uint16 recBlockNo){
+
+ MasterLCPRef * sig = (MasterLCPRef *)&theData[0];
+ fprintf(output, " senderNode=%d failedNode=%d\n",
+ sig->senderNodeId, sig->failedNodeId);
+ return true;
+}