← Back to branch summary

~michaeleguo/ubuntu/trusty/percona-xtradb-cluster-5.5/arm64fix

« back to all changes in this revision

Viewing changes to storage/ndb/src/kernel/blocks/ndbcntr/NdbcntrInit.cpp

  • Committer: Package Import Robot
  • Author(s): James Page
  • Date: 2014-02-10 14:44:23 UTC
  • Revision ID: package-import@ubuntu.com-20140210144423-f2134l2gxuvq2m6l
Tags: upstream-5.5.34-25.9+dfsg
Import upstream version 5.5.34-25.9+dfsg

Show diffs side-by-side

added added

removed removed

Lines of Context:
storage/ndb/src/kernel/blocks/ndbcntr/NdbcntrInit.cpp
 
1
/* Copyright (C) 2003 MySQL AB
 
2
 
 
3
   This program is free software; you can redistribute it and/or modify
 
4
   it under the terms of the GNU General Public License as published by
 
5
   the Free Software Foundation; version 2 of the License.
 
6
 
 
7
   This program is distributed in the hope that it will be useful,
 
8
   but WITHOUT ANY WARRANTY; without even the implied warranty of
 
9
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
10
   GNU General Public License for more details.
 
11
 
 
12
   You should have received a copy of the GNU General Public License
 
13
   along with this program; if not, write to the Free Software
 
14
   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA */
 
15
 
 
16
 
 
17
 
 
18
#define NDBCNTR_C
 
19
#include "Ndbcntr.hpp"
 
20
#include <ndb_limits.h>
 
21
 
 
22
#define DEBUG(x) { ndbout << "Ndbcntr::" << x << endl; }
 
23
 
 
24
 
 
25
void Ndbcntr::initData() 
 
26
{
 
27
  c_start.reset();
 
28
  cmasterNodeId = 0;
 
29
  cnoStartNodes = 0;
 
30
  cnoWaitrep = 0;
 
31
  // Records with constant sizes
 
32
  ndbBlocksRec = new NdbBlocksRec[ZSIZE_NDB_BLOCKS_REC];
 
33
}//Ndbcntr::initData()
 
34
 
 
35
void Ndbcntr::initRecords() 
 
36
{
 
37
  // Records with dynamic sizes
 
38
}//Ndbcntr::initRecords()
 
39
 
 
40
Ndbcntr::Ndbcntr(Block_context& ctx):
 
41
  SimulatedBlock(NDBCNTR, ctx),
 
42
  cnoWaitrep6(0),
 
43
  cnoWaitrep7(0),
 
44
  c_stopRec(* this),
 
45
  c_missra(* this)
 
46
{
 
47
 
 
48
  BLOCK_CONSTRUCTOR(Ndbcntr);
 
49
 
 
50
  // Transit signals
 
51
  addRecSignal(GSN_CONTINUEB, &Ndbcntr::execCONTINUEB);
 
52
  addRecSignal(GSN_READ_NODESCONF, &Ndbcntr::execREAD_NODESCONF);
 
53
  addRecSignal(GSN_READ_NODESREF, &Ndbcntr::execREAD_NODESREF);
 
54
  addRecSignal(GSN_CM_ADD_REP, &Ndbcntr::execCM_ADD_REP);
 
55
  addRecSignal(GSN_CNTR_START_REQ, &Ndbcntr::execCNTR_START_REQ);
 
56
  addRecSignal(GSN_CNTR_START_REF, &Ndbcntr::execCNTR_START_REF);
 
57
  addRecSignal(GSN_CNTR_START_CONF, &Ndbcntr::execCNTR_START_CONF);
 
58
  addRecSignal(GSN_CNTR_WAITREP, &Ndbcntr::execCNTR_WAITREP);
 
59
  addRecSignal(GSN_CNTR_START_REP, &Ndbcntr::execCNTR_START_REP);
 
60
  addRecSignal(GSN_API_START_REP, &Ndbcntr::execAPI_START_REP, true);
 
61
  addRecSignal(GSN_NODE_FAILREP, &Ndbcntr::execNODE_FAILREP);
 
62
  addRecSignal(GSN_SYSTEM_ERROR , &Ndbcntr::execSYSTEM_ERROR);
 
63
  
 
64
  // Received signals
 
65
  addRecSignal(GSN_DUMP_STATE_ORD, &Ndbcntr::execDUMP_STATE_ORD);
 
66
  addRecSignal(GSN_READ_CONFIG_REQ, &Ndbcntr::execREAD_CONFIG_REQ);
 
67
  addRecSignal(GSN_STTOR, &Ndbcntr::execSTTOR);
 
68
  addRecSignal(GSN_TCSEIZECONF, &Ndbcntr::execTCSEIZECONF);
 
69
  addRecSignal(GSN_TCSEIZEREF, &Ndbcntr::execTCSEIZEREF);
 
70
  addRecSignal(GSN_TCRELEASECONF, &Ndbcntr::execTCRELEASECONF);
 
71
  addRecSignal(GSN_TCRELEASEREF, &Ndbcntr::execTCRELEASEREF);
 
72
  addRecSignal(GSN_TCKEYCONF, &Ndbcntr::execTCKEYCONF);
 
73
  addRecSignal(GSN_TCKEYREF, &Ndbcntr::execTCKEYREF);
 
74
  addRecSignal(GSN_TCROLLBACKREP, &Ndbcntr::execTCROLLBACKREP);
 
75
  addRecSignal(GSN_GETGCICONF, &Ndbcntr::execGETGCICONF);
 
76
  addRecSignal(GSN_DIH_RESTARTCONF, &Ndbcntr::execDIH_RESTARTCONF);
 
77
  addRecSignal(GSN_DIH_RESTARTREF, &Ndbcntr::execDIH_RESTARTREF);
 
78
  addRecSignal(GSN_CREATE_TABLE_REF, &Ndbcntr::execCREATE_TABLE_REF);
 
79
  addRecSignal(GSN_CREATE_TABLE_CONF, &Ndbcntr::execCREATE_TABLE_CONF);
 
80
  addRecSignal(GSN_NDB_STTORRY, &Ndbcntr::execNDB_STTORRY);
 
81
  addRecSignal(GSN_NDB_STARTCONF, &Ndbcntr::execNDB_STARTCONF);
 
82
  addRecSignal(GSN_READ_NODESREQ, &Ndbcntr::execREAD_NODESREQ);
 
83
  addRecSignal(GSN_NDB_STARTREF, &Ndbcntr::execNDB_STARTREF);
 
84
 
 
85
  addRecSignal(GSN_STOP_PERM_REF, &Ndbcntr::execSTOP_PERM_REF);
 
86
  addRecSignal(GSN_STOP_PERM_CONF, &Ndbcntr::execSTOP_PERM_CONF);
 
87
 
 
88
  addRecSignal(GSN_STOP_ME_REF, &Ndbcntr::execSTOP_ME_REF);
 
89
  addRecSignal(GSN_STOP_ME_CONF, &Ndbcntr::execSTOP_ME_CONF);
 
90
 
 
91
  addRecSignal(GSN_STOP_REQ, &Ndbcntr::execSTOP_REQ);
 
92
  addRecSignal(GSN_STOP_CONF, &Ndbcntr::execSTOP_CONF);
 
93
  addRecSignal(GSN_RESUME_REQ, &Ndbcntr::execRESUME_REQ);
 
94
 
 
95
  addRecSignal(GSN_WAIT_GCP_REF, &Ndbcntr::execWAIT_GCP_REF);
 
96
  addRecSignal(GSN_WAIT_GCP_CONF, &Ndbcntr::execWAIT_GCP_CONF);
 
97
  addRecSignal(GSN_CHANGE_NODE_STATE_CONF, 
 
98
               &Ndbcntr::execCHANGE_NODE_STATE_CONF);
 
99
 
 
100
  addRecSignal(GSN_ABORT_ALL_REF, &Ndbcntr::execABORT_ALL_REF);
 
101
  addRecSignal(GSN_ABORT_ALL_CONF, &Ndbcntr::execABORT_ALL_CONF);
 
102
 
 
103
  addRecSignal(GSN_START_ORD, &Ndbcntr::execSTART_ORD);
 
104
  addRecSignal(GSN_STTORRY, &Ndbcntr::execSTTORRY);
 
105
  addRecSignal(GSN_READ_CONFIG_CONF, &Ndbcntr::execREAD_CONFIG_CONF);
 
106
 
 
107
  addRecSignal(GSN_FSREMOVECONF, &Ndbcntr::execFSREMOVECONF);
 
108
  
 
109
  initData();
 
110
  ctypeOfStart = NodeState::ST_ILLEGAL_TYPE;
 
111
  c_start.m_startTime = NdbTick_CurrentMillisecond();
 
112
}//Ndbcntr::Ndbcntr()
 
113
 
 
114
Ndbcntr::~Ndbcntr() 
 
115
{
 
116
  delete []ndbBlocksRec;
 
117
 
 
118
}//Ndbcntr::~Ndbcntr()
 
119
 
 
120
BLOCK_FUNCTIONS(Ndbcntr)