1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
/* Copyright (c) 2003-2007 MySQL AB
Use is subject to license terms
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; version 2 of the License.
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 Street, Fifth Floor, Boston, MA 02110-1301, USA */
#ifndef GLOBAL_DATA_H
#define GLOBAL_DATA_H
#include <ndb_global.h>
#include <kernel_types.h>
#include "Prio.hpp"
#include "VMSignal.hpp"
#include <BlockNumbers.h>
#include <NodeState.hpp>
#include <NodeInfo.hpp>
#include "ArrayPool.hpp"
class SimulatedBlock;
enum restartStates {initial_state,
perform_start,
system_started,
perform_stop};
struct GlobalData {
Uint32 m_restart_seq; //
NodeVersionInfo m_versionInfo;
NodeInfo m_nodeInfo[MAX_NODES];
Signal VMSignals[1]; // Owned by FastScheduler::
Uint64 internalMillisecCounter; // Owned by ThreadConfig::
Uint32 highestAvailablePrio; // Owned by FastScheduler::
Uint32 JobCounter; // Owned by FastScheduler
Uint64 JobLap; // Owned by FastScheduler
Uint32 loopMax; // Owned by FastScheduler
Uint32 theNextTimerJob; // Owned by TimeQueue::
Uint32 theCurrentTimer; // Owned by TimeQueue::
Uint32 theShortTQIndex; // Owned by TimeQueue::
Uint32 theLongTQIndex; // Owned by TimeQueue::
Uint32 theCountTimer; // Owned by TimeQueue::
Uint32 theFirstFreeTQIndex; // Owned by TimeQueue::
Uint32 testOn; // Owned by the Signal Loggers
NodeId ownId; // Own processor id
Uint32 theStartLevel;
restartStates theRestartFlag;
Uint32 theSignalId;
Uint32 sendPackedActivated;
Uint32 activateSendPacked;
GlobalData(){
theSignalId = 0;
theStartLevel = NodeState::SL_NOTHING;
theRestartFlag = perform_start;
}
~GlobalData(){}
void setBlock(BlockNumber blockNo, SimulatedBlock * block);
SimulatedBlock * getBlock(BlockNumber blockNo);
void incrementWatchDogCounter(Uint32 place);
const Uint32 * getWatchDogPtr();
private:
Uint32 watchDog;
SimulatedBlock* blockTable[NO_OF_BLOCKS]; // Owned by Dispatcher::
public:
ArrayPool<GlobalPage> m_global_page_pool;
ArrayPool<GlobalPage> m_shared_page_pool;
};
extern GlobalData globalData;
#define GLOBAL_TEST_ON (localTestOn)
#define GET_GLOBAL_TEST_FLAG bool localTestOn = globalData.testOn
#define SET_GLOBAL_TEST_ON (globalData.testOn = true)
#define SET_GLOBAL_TEST_OFF (globalData.testOn = false)
#define TOGGLE_GLOBAL_TEST_FLAG (globalData.testOn = (globalData.testOn == true ? false : true))
inline
void
GlobalData::setBlock(BlockNumber blockNo, SimulatedBlock * block){
blockNo -= MIN_BLOCK_NO;
assert((blockTable[blockNo] == 0) || (blockTable[blockNo] == block));
blockTable[blockNo] = block;
}
inline
SimulatedBlock *
GlobalData::getBlock(BlockNumber blockNo){
blockNo -= MIN_BLOCK_NO;
return blockTable[blockNo];
}
inline
void
GlobalData::incrementWatchDogCounter(Uint32 place){
watchDog = place;
}
inline
const Uint32 *
GlobalData::getWatchDogPtr(){
return &watchDog;
}
#endif
|
