Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
M
MariaDB
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
nexedi
MariaDB
Commits
76b09dd5
Commit
76b09dd5
authored
Oct 22, 2004
by
unknown
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
fix c++ style comments in .h and .c files
compilation problems on some platforms'
parent
25f1344f
Changes
13
Hide whitespace changes
Inline
Side-by-side
Showing
13 changed files
with
252 additions
and
242 deletions
+252
-242
ndb/include/kernel/BlockNumbers.h
ndb/include/kernel/BlockNumbers.h
+3
-3
ndb/include/kernel/GlobalSignalNumbers.h
ndb/include/kernel/GlobalSignalNumbers.h
+99
-99
ndb/include/kernel/ndb_limits.h
ndb/include/kernel/ndb_limits.h
+5
-5
ndb/include/kernel/trigger_definitions.h
ndb/include/kernel/trigger_definitions.h
+6
-6
ndb/include/mgmapi/mgmapi.h
ndb/include/mgmapi/mgmapi.h
+77
-67
ndb/include/portlib/NdbCondition.h
ndb/include/portlib/NdbCondition.h
+31
-31
ndb/include/portlib/PortDefs.h
ndb/include/portlib/PortDefs.h
+20
-20
ndb/include/portlib/prefetch.h
ndb/include/portlib/prefetch.h
+2
-2
ndb/src/common/portlib/NdbDaemon.c
ndb/src/common/portlib/NdbDaemon.c
+1
-1
ndb/src/common/portlib/NdbMem.c
ndb/src/common/portlib/NdbMem.c
+1
-1
ndb/src/common/portlib/NdbThread.c
ndb/src/common/portlib/NdbThread.c
+2
-2
ndb/src/common/portlib/memtest.c
ndb/src/common/portlib/memtest.c
+4
-4
ndb/src/common/util/basestring_vsnprintf.c
ndb/src/common/util/basestring_vsnprintf.c
+1
-1
No files found.
ndb/include/kernel/BlockNumbers.h
View file @
76b09dd5
...
...
@@ -20,13 +20,13 @@
#include <kernel_types.h>
#include <RefConvert.hpp>
/
/ 240
/
* 240 */
#define MIN_API_BLOCK_NO 0x8000
/
/ 2047
/
* 2047 */
#define API_PACKED 0x07ff
/
/ 4002
/
* 4002 */
#define API_CLUSTERMGR 0x0FA2
#define BACKUP 0xF4
...
...
ndb/include/kernel/GlobalSignalNumbers.h
View file @
76b09dd5
...
...
@@ -78,7 +78,7 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_SCAN_NEXTREQ 28
#define GSN_SCAN_TABCONF 29
/
/ 30 unused
/
* 30 unused */
#define GSN_SCAN_TABREF 31
#define GSN_SCAN_TABREQ 32
#define GSN_KEYINFO20 33
...
...
@@ -91,42 +91,42 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_TCSEIZEREF 38
#define GSN_TCSEIZEREQ 39
/
/ 40 unused
/
/ 41 unused
/
/ 42 unused
/
/ 43 unused
/
/ 44 unused
/
/ 45 unused
/
/ 46 unused
/
/ 47 unused
/
/ 48 unused
/
/ 49 unused
/
/ 50 unused
/
/ 51 unused
/
/ 52 unused
/
/ 53 unused
/
/ 54 unused
/
/ 55 unused
/
/ 56 unused
/
/ 57 unused
/
/ 58 unused
/
/ 59 unused
/
/ 60 unused
/
/ 61 unused
/
/ 62 unused
/
/ 63 unused
/
/ 64 unused
/
/ 65 unused
/
/ 66 unused
/
* 40 unused */
/
* 41 unused */
/
* 42 unused */
/
* 43 unused */
/
* 44 unused */
/
* 45 unused */
/
* 46 unused */
/
* 47 unused */
/
* 48 unused */
/
* 49 unused */
/
* 50 unused */
/
* 51 unused */
/
* 52 unused */
/
* 53 unused */
/
* 54 unused */
/
* 55 unused */
/
* 56 unused */
/
* 57 unused */
/
* 58 unused */
/
* 59 unused */
/
* 60 unused */
/
* 61 unused */
/
* 62 unused */
/
* 63 unused */
/
* 64 unused */
/
* 65 unused */
/
* 66 unused */
/**
* These are used only by kernel
*/
#define GSN_ACC_ABORTCONF 67
/
/ 68 unused
/
/ 69 unused
/
/ 70 unused
/
* 68 unused */
/
* 69 unused */
/
* 70 unused */
#define GSN_ACC_ABORTREQ 71
#define GSN_ACC_CHECK_SCAN 72
#define GSN_ACC_COMMITCONF 73
...
...
@@ -172,42 +172,42 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_API_FAILCONF 113
#define GSN_API_FAILREQ 114
#define GSN_CNTR_START_REQ 115
/
/ 116 not unused
/
* 116 not unused */
#define GSN_CNTR_START_REF 117
#define GSN_CNTR_START_CONF 118
#define GSN_CNTR_START_REP 119
/
/ 120 unused
/
/ 121 unused
/
/ 122 unused
/
/ 123 unused
/
/ 124 unused
/
* 120 unused */
/
* 121 unused */
/
* 122 unused */
/
* 123 unused */
/
* 124 unused */
#define GSN_CHECK_LCP_STOP 125
#define GSN_CLOSE_COMCONF 126 /
/ local
#define GSN_CLOSE_COMREQ 127 /
/ local
#define GSN_CM_ACKADD 128 /
/ distr.
/
/ 129 unused
#define GSN_CM_ADD 130 /
/ distr.
/
/ 131 unused
/
/ 132 not unused
/
/ 133 not unused
#define GSN_CM_HEARTBEAT 134 /
/ distr.
/
/ 135 unused
/
/ 136 unused
/
/ 137 unused
#define GSN_CM_NODEINFOCONF 138 /
/ distr.
#define GSN_CM_NODEINFOREF 139 /
/ distr.
#define GSN_CM_NODEINFOREQ 140 /
/ distr.
#define GSN_CM_REGCONF 141 /
/ distr.
#define GSN_CM_REGREF 142 /
/ distr.
#define GSN_CM_REGREQ 143 /
/ distr.
/
/ 144 unused
/
/ 145 unused
/
/ 146 unused
#define GSN_CM_ADD_REP 147 /
/ local
/
/ 148 unused
/
/ 149 unused
/
/ 150 unused
#define GSN_CNTR_WAITREP 151 /
/ distr.
#define GSN_CLOSE_COMCONF 126
/
* local */
#define GSN_CLOSE_COMREQ 127
/
* local */
#define GSN_CM_ACKADD 128
/
* distr. */
/
* 129 unused */
#define GSN_CM_ADD 130
/
* distr. */
/
* 131 unused */
/
* 132 not unused */
/
* 133 not unused */
#define GSN_CM_HEARTBEAT 134
/
* distr. */
/
* 135 unused */
/
* 136 unused */
/
* 137 unused */
#define GSN_CM_NODEINFOCONF 138
/
* distr. */
#define GSN_CM_NODEINFOREF 139
/
* distr. */
#define GSN_CM_NODEINFOREQ 140
/
* distr. */
#define GSN_CM_REGCONF 141
/
* distr. */
#define GSN_CM_REGREF 142
/
* distr. */
#define GSN_CM_REGREQ 143
/
* distr. */
/
* 144 unused */
/
* 145 unused */
/
* 146 unused */
#define GSN_CM_ADD_REP 147
/
* local */
/
* 148 unused */
/
* 149 unused */
/
* 150 unused */
#define GSN_CNTR_WAITREP 151
/
* distr. */
#define GSN_COMMIT 152
#define GSN_COMMIT_FAILCONF 153
#define GSN_COMMIT_FAILREQ 154
...
...
@@ -220,7 +220,7 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_COMPLETEREQ 162
#define GSN_CONNECT_REP 163
#define GSN_CONTINUEB 164
/
/ 165 not unused
/
* 165 not unused */
#define GSN_COPY_ACTIVECONF 166
#define GSN_COPY_ACTIVEREF 167
#define GSN_COPY_ACTIVEREQ 168
...
...
@@ -243,9 +243,9 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_DIADDTABCONF 185
#define GSN_DIADDTABREF 186
#define GSN_DIADDTABREQ 187
/
/ 188 not unused
/
/ 189 not unused
/
/ 190 not unused
/
* 188 not unused */
/
* 189 not unused */
/
* 190 not unused */
#define GSN_DICTSTARTCONF 191
#define GSN_DICTSTARTREQ 192
...
...
@@ -301,9 +301,9 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_DIH_RESTARTREF 218
#define GSN_DIH_RESTARTREQ 219
/
/ 220 not unused
/
/ 221 not unused
/
/ 222 not unused
/
* 220 not unused */
/
* 221 not unused */
/
* 222 not unused */
#define GSN_EMPTY_LCP_REQ 223
#define GSN_EMPTY_LCP_CONF 224
...
...
@@ -315,8 +315,8 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_MASTER_GCPREF 228
#define GSN_MASTER_GCPREQ 229
/
/ 230 not unused
/
/ 231 not unused
/
* 230 not unused */
/
* 231 not unused */
#define GSN_DIRELEASECONF 232
#define GSN_DIRELEASEREF 233
...
...
@@ -388,8 +388,8 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_LCP_HOLDOPREQ 299
#define GSN_SHRINKCHECK2 301
#define GSN_GET_SCHEMA_INFOREQ 302
/
/ 303 not unused
/
/ 304 not unused
/
* 303 not unused */
/
* 304 not unused */
#define GSN_LQH_RESTART_OP 305
#define GSN_LQH_TRANSCONF 306
#define GSN_LQH_TRANSREQ 307
...
...
@@ -421,12 +421,12 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_NEXT_SCANREQ 332
#define GSN_NEXTOPERATION 333
#define GSN_READ_CONFIG_REQ 334 /
/ new name for sizealt, local
#define GSN_READ_CONFIG_CONF 335 /
/ new name for sizealt, local
#define GSN_READ_CONFIG_REQ 334
/
* new name for sizealt, local */
#define GSN_READ_CONFIG_CONF 335
/
* new name for sizealt, local */
/
/ 336 unused
/
/ 337 unused
/
/ 338 unused
/
* 336 unused */
/
* 337 unused */
/
* 338 unused */
#define GSN_OPEN_COMCONF 339
#define GSN_OPEN_COMREF 340
#define GSN_OPEN_COMREQ 341
...
...
@@ -452,7 +452,7 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_TUP_ALLOCREQ 360
#define GSN_TUP_DEALLOCREQ 361
/
/ 362 not unused
/
* 362 not unused */
#define GSN_TUP_WRITELOG_REQ 363
#define GSN_LQH_WRITELOG_REQ 364
...
...
@@ -507,16 +507,16 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_TEST_ORD 407
#define GSN_TESTSIG 408
#define GSN_TIME_SIGNAL 409
/
/ 410 unused
/
/ 411 unused
/
/ 412 unused
/
* 410 unused */
/
* 411 unused */
/
* 412 unused */
#define GSN_TUP_ABORTREQ 414
#define GSN_TUP_ADD_ATTCONF 415
#define GSN_TUP_ADD_ATTRREF 416
#define GSN_TUP_ADD_ATTRREQ 417
#define GSN_TUP_ATTRINFO 418
#define GSN_TUP_COMMITREQ 419
/
/ 420 unused
/
* 420 unused */
#define GSN_TUP_LCPCONF 421
#define GSN_TUP_LCPREF 422
#define GSN_TUP_LCPREQ 423
...
...
@@ -553,8 +553,8 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_STATISTICS_CONF 454
#define GSN_START_ORD 455
/
/ 456 unused
/
/ 457 unused
/
* 456 unused */
/
* 457 unused */
#define GSN_EVENT_SUBSCRIBE_REQ 458
#define GSN_EVENT_SUBSCRIBE_CONF 459
...
...
@@ -576,7 +576,7 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_CHECKNODEGROUPSREQ 471
#define GSN_CHECKNODEGROUPSCONF 472
/
/ 473 unused
/
* 473 unused */
#define GSN_ARBIT_PREPREQ 474
#define GSN_ARBIT_PREPCONF 475
#define GSN_ARBIT_PREPREF 476
...
...
@@ -612,7 +612,7 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_WAIT_GCP_REF 500
#define GSN_WAIT_GCP_CONF 501
/
/ 502 not used
/
* 502 not used */
/**
* Trigger and index signals
...
...
@@ -732,7 +732,7 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_SUB_STOP_REQ 572
#define GSN_SUB_STOP_REF 573
#define GSN_SUB_STOP_CONF 574
/
/ 575 unused
/
* 575 unused */
#define GSN_SUB_CREATE_REQ 576
#define GSN_SUB_CREATE_REF 577
#define GSN_SUB_CREATE_CONF 578
...
...
@@ -832,7 +832,7 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_GREP_REMOVE_REF 654
#define GSN_GREP_REMOVE_CONF 655
/
/ Start Global Replication
/
* Start Global Replication */
#define GSN_GREP_REQ 656
/**
...
...
@@ -891,8 +891,8 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_TUX_MAINT_CONF 678
#define GSN_TUX_MAINT_REF 679
/
/ not used 680
/
/ not used 681
/
* not used 680 */
/
* not used 681 */
/**
* from mgmtsrvr to NDBCNTR
...
...
@@ -903,10 +903,10 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_API_VERSION_REQ 697
#define GSN_API_VERSION_CONF 698
/
/ not used 686
/
/ not used 687
/
/ not used 689
/
/ not used 690
/
* not used 686 */
/
* not used 687 */
/
* not used 689 */
/
* not used 690 */
/**
* SUMA restart protocol
...
...
@@ -915,9 +915,9 @@ extern const GlobalSignalNumber NO_OF_SIGNAL_NAMES;
#define GSN_SUMA_HANDOVER_REQ 692
#define GSN_SUMA_HANDOVER_CONF 693
/
/ not used 694
/
/ not used 695
/
/ not used 696
/
* not used 694 */
/
* not used 695 */
/
* not used 696 */
/**
* GREP restart protocol
...
...
ndb/include/kernel/ndb_limits.h
View file @
76b09dd5
...
...
@@ -50,7 +50,7 @@
**/
#define MAX_TUPLES_PER_PAGE 8191
#define MAX_TUPLES_BITS 13
/* 13 bits = 8191 tuples per page */
/
/#define MAX_NO_OF_TUPLEKEY 16 Not currently used
/
*#define MAX_NO_OF_TUPLEKEY 16 Not currently used */
#define MAX_TABLES 1600
#define MAX_TAB_NAME_SIZE 128
#define MAX_ATTR_NAME_SIZE 32
...
...
@@ -108,13 +108,13 @@
/*
* Ordered index constants. Make configurable per index later.
*/
#define MAX_TTREE_NODE_SIZE 64
// total words in node
#define MAX_TTREE_PREF_SIZE 4
// words in min prefix
#define MAX_TTREE_NODE_SLACK 2
// diff between max and min occupancy
#define MAX_TTREE_NODE_SIZE 64
/* total words in node */
#define MAX_TTREE_PREF_SIZE 4
/* words in min prefix */
#define MAX_TTREE_NODE_SLACK 2
/* diff between max and min occupancy */
/*
* Blobs.
*/
#define NDB_BLOB_HEAD_SIZE 2
// sizeof(NdbBlob::Head) >> 2
#define NDB_BLOB_HEAD_SIZE 2
/* sizeof(NdbBlob::Head) >> 2 */
#endif
ndb/include/kernel/trigger_definitions.h
View file @
76b09dd5
...
...
@@ -47,11 +47,11 @@ struct TriggerType {
struct
TriggerActionTime
{
enum
Value
{
TA_BEFORE
=
0
,
/
/ Immediate, before operation
TA_AFTER
=
1
,
/
/ Immediate, after operation
TA_DEFERRED
=
2
,
/
/ Before commit
TA_DETACHED
=
3
,
/
/ After commit in a separate transaction, NYI
TA_CUSTOM
=
4
/
/ Hardcoded per TriggerType
TA_BEFORE
=
0
,
/
* Immediate, before operation */
TA_AFTER
=
1
,
/
* Immediate, after operation */
TA_DEFERRED
=
2
,
/
* Before commit */
TA_DETACHED
=
3
,
/
* After commit in a separate transaction, NYI */
TA_CUSTOM
=
4
/
* Hardcoded per TriggerType */
};
};
...
...
@@ -60,7 +60,7 @@ struct TriggerEvent {
TE_INSERT
=
0
,
TE_DELETE
=
1
,
TE_UPDATE
=
2
,
TE_CUSTOM
=
3
/
/ Hardcoded per TriggerType
TE_CUSTOM
=
3
/
* Hardcoded per TriggerType */
};
};
...
...
ndb/include/mgmapi/mgmapi.h
View file @
76b09dd5
...
...
@@ -64,32 +64,32 @@ extern "C" {
* NDB Cluster node types
*/
enum
ndb_mgm_node_type
{
NDB_MGM_NODE_TYPE_UNKNOWN
=
-
1
,
/*/
< Node type not known*/
NDB_MGM_NODE_TYPE_API
=
NODE_TYPE_API
,
/*/
< An application node (API)*/
NDB_MGM_NODE_TYPE_NDB
=
NODE_TYPE_DB
,
/*/
< A database node (DB)*/
NDB_MGM_NODE_TYPE_MGM
=
NODE_TYPE_MGM
,
/*/< A managemen
t server node (MGM)*/
NDB_MGM_NODE_TYPE_REP
=
NODE_TYPE_REP
,
///< A replication node
NDB_MGM_NODE_TYPE_MIN
=
0
,
/*/
< Min valid value*/
NDB_MGM_NODE_TYPE_MAX
=
3
/*/
< Max valid value*/
NDB_MGM_NODE_TYPE_UNKNOWN
=
-
1
,
/*
< Node type not known*/
NDB_MGM_NODE_TYPE_API
=
NODE_TYPE_API
,
/*
< An application node (API)*/
NDB_MGM_NODE_TYPE_NDB
=
NODE_TYPE_DB
,
/*
< A database node (DB)*/
NDB_MGM_NODE_TYPE_MGM
=
NODE_TYPE_MGM
,
/*< A mgm
t server node (MGM)*/
NDB_MGM_NODE_TYPE_REP
=
NODE_TYPE_REP
,
/*< A replication node */
NDB_MGM_NODE_TYPE_MIN
=
0
,
/*
< Min valid value*/
NDB_MGM_NODE_TYPE_MAX
=
3
/*
< Max valid value*/
};
/**
* Database node status
*/
enum
ndb_mgm_node_status
{
NDB_MGM_NODE_STATUS_UNKNOWN
=
0
,
/
//< Node status not known
NDB_MGM_NODE_STATUS_NO_CONTACT
=
1
,
/
//< No contact with node
NDB_MGM_NODE_STATUS_NOT_STARTED
=
2
,
/
//< Has not run starting protocol
NDB_MGM_NODE_STATUS_STARTING
=
3
,
/
//< Is running starting protocol
NDB_MGM_NODE_STATUS_STARTED
=
4
,
/
//< Running
NDB_MGM_NODE_STATUS_SHUTTING_DOWN
=
5
,
/
//< Is shutting down
NDB_MGM_NODE_STATUS_RESTARTING
=
6
,
/
//< Is restarting
NDB_MGM_NODE_STATUS_SINGLEUSER
=
7
,
/
//< Maintenance mode
NDB_MGM_NODE_STATUS_RESUME
=
8
,
/
//< Resume mode
NDB_MGM_NODE_STATUS_MIN
=
0
,
/
//< Min valid value
NDB_MGM_NODE_STATUS_MAX
=
6
/
//< Max valid value
NDB_MGM_NODE_STATUS_UNKNOWN
=
0
,
/
*< Node status not known*/
NDB_MGM_NODE_STATUS_NO_CONTACT
=
1
,
/
*< No contact with node*/
NDB_MGM_NODE_STATUS_NOT_STARTED
=
2
,
/
*< Has not run starting protocol*/
NDB_MGM_NODE_STATUS_STARTING
=
3
,
/
*< Is running starting protocol*/
NDB_MGM_NODE_STATUS_STARTED
=
4
,
/
*< Running*/
NDB_MGM_NODE_STATUS_SHUTTING_DOWN
=
5
,
/
*< Is shutting down*/
NDB_MGM_NODE_STATUS_RESTARTING
=
6
,
/
*< Is restarting*/
NDB_MGM_NODE_STATUS_SINGLEUSER
=
7
,
/
*< Maintenance mode*/
NDB_MGM_NODE_STATUS_RESUME
=
8
,
/
*< Resume mode*/
NDB_MGM_NODE_STATUS_MIN
=
0
,
/
*< Min valid value*/
NDB_MGM_NODE_STATUS_MAX
=
6
/
*< Max valid value*/
};
/**
...
...
@@ -175,24 +175,27 @@ extern "C" {
* Structure returned by ndb_mgm_get_status
*/
struct
ndb_mgm_node_state
{
int
node_id
;
///< NDB Cluster node id
enum
ndb_mgm_node_type
node_type
;
///< Type of NDB Cluster node
enum
ndb_mgm_node_status
node_status
;
///< State of node
int
start_phase
;
///< Start phase.
///< @note Start phase is only
///< valid if
///< node_type is
///< NDB_MGM_NODE_TYPE_NDB and
///< node_status is
///< NDB_MGM_NODE_STATUS_STARTING
int
dynamic_id
;
///< Id for heartbeats and
///< master take-over
///< (only valid for DB nodes)
int
node_group
;
///< Node group of node
///< (only valid for DB nodes)
int
version
;
///< Internal version number
int
connect_count
;
///< No of times node has connected
///< or disconnected to the mgm srv
int
node_id
;
/*< NDB Cluster node id*/
enum
ndb_mgm_node_type
node_type
;
/*< Type of NDB Cluster node*/
enum
ndb_mgm_node_status
node_status
;
/*< State of node*/
int
start_phase
;
/*< Start phase.
*< @note Start phase is only
*< valid if
*< node_type is
*< NDB_MGM_NODE_TYPE_NDB and
*< node_status is
*< NDB_MGM_NODE_STATUS_STARTING
*/
int
dynamic_id
;
/*< Id for heartbeats and
*< master take-over
*< (only valid for DB nodes)
*/
int
node_group
;
/*< Node group of node
*< (only valid for DB nodes)*/
int
version
;
/*< Internal version number*/
int
connect_count
;
/*< No of times node has connected
*< or disconnected to the mgm srv
*/
char
connect_address
[
sizeof
(
"000.000.000.000"
)
+
1
];
};
...
...
@@ -200,9 +203,10 @@ extern "C" {
* Cluster status
*/
struct
ndb_mgm_cluster_state
{
int
no_of_nodes
;
///< No of entries in the
///< node_states array
struct
ndb_mgm_node_state
///< An array with node_states
int
no_of_nodes
;
/*< No of entries in the
*< node_states array
*/
struct
ndb_mgm_node_state
/*< An array with node_states*/
node_states
[
1
];
const
char
*
hostname
;
};
...
...
@@ -211,17 +215,18 @@ extern "C" {
* Default reply from the server
*/
struct
ndb_mgm_reply
{
int
return_code
;
///< 0 if successful,
///< otherwise error code.
char
message
[
256
];
///< Error or reply message.
int
return_code
;
/*< 0 if successful,
*< otherwise error code.
*/
char
message
[
256
];
/*< Error or reply message.*/
};
/**
* Default information types
*/
enum
ndb_mgm_info
{
NDB_MGM_INFO_CLUSTER
,
/
//< ?
NDB_MGM_INFO_CLUSTERLOG
/
//< Cluster log
NDB_MGM_INFO_CLUSTER
,
/
*< ?*/
NDB_MGM_INFO_CLUSTERLOG
/
*< Cluster log*/
};
/**
...
...
@@ -229,39 +234,44 @@ extern "C" {
* (Used only in the development of NDB Cluster.)
*/
enum
ndb_mgm_signal_log_mode
{
NDB_MGM_SIGNAL_LOG_MODE_IN
,
/
//< Log receiving signals
NDB_MGM_SIGNAL_LOG_MODE_OUT
,
/
//< Log sending signals
NDB_MGM_SIGNAL_LOG_MODE_INOUT
,
/
//< Log both sending/receiving
NDB_MGM_SIGNAL_LOG_MODE_OFF
/
//< Log off
NDB_MGM_SIGNAL_LOG_MODE_IN
,
/
*< Log receiving signals */
NDB_MGM_SIGNAL_LOG_MODE_OUT
,
/
*< Log sending signals*/
NDB_MGM_SIGNAL_LOG_MODE_INOUT
,
/
*< Log both sending/receiving*/
NDB_MGM_SIGNAL_LOG_MODE_OFF
/
*< Log off*/
};
/**
* Log severities (used to filter the cluster log)
*/
enum
ndb_mgm_clusterlog_level
{
NDB_MGM_CLUSTERLOG_OFF
=
0
,
///< Cluster log off
NDB_MGM_CLUSTERLOG_DEBUG
=
1
,
///< Used in NDB Cluster
///< developement
NDB_MGM_CLUSTERLOG_INFO
=
2
,
///< Informational messages
NDB_MGM_CLUSTERLOG_WARNING
=
3
,
///< Conditions that are not
///< error condition, but
///< might require handling
NDB_MGM_CLUSTERLOG_ERROR
=
4
,
///< Conditions that should be
///< corrected
NDB_MGM_CLUSTERLOG_CRITICAL
=
5
,
///< Critical conditions, like
///< device errors or out of
///< resources
NDB_MGM_CLUSTERLOG_ALERT
=
6
,
///< A condition that should be
///< corrected immediately,
///< such as a corrupted system
NDB_MGM_CLUSTERLOG_ALL
=
7
///< All severities on
NDB_MGM_CLUSTERLOG_OFF
=
0
,
/*< Cluster log off*/
NDB_MGM_CLUSTERLOG_DEBUG
=
1
,
/*< Used in NDB Cluster
*< developement
*/
NDB_MGM_CLUSTERLOG_INFO
=
2
,
/*< Informational messages*/
NDB_MGM_CLUSTERLOG_WARNING
=
3
,
/*< Conditions that are not
*< error condition, but
*< might require handling
*/
NDB_MGM_CLUSTERLOG_ERROR
=
4
,
/*< Conditions that should be
*< corrected
*/
NDB_MGM_CLUSTERLOG_CRITICAL
=
5
,
/*< Critical conditions, like
*< device errors or out of
*< resources
*/
NDB_MGM_CLUSTERLOG_ALERT
=
6
,
/*< A condition that should be
*< corrected immediately,
*< such as a corrupted system
*/
NDB_MGM_CLUSTERLOG_ALL
=
7
/*< All severities on*/
};
/**
* Log categories
*/
enum
ndb_mgm_event_category
{
NDB_MGM_ILLEGAL_EVENT_CATEGORY
=
-
1
,
/
//
< Invalid
NDB_MGM_ILLEGAL_EVENT_CATEGORY
=
-
1
,
/
*
< Invalid
/**
* Events during all kinds of startups
*/
...
...
ndb/include/portlib/NdbCondition.h
View file @
76b09dd5
...
...
@@ -26,21 +26,21 @@ extern "C" {
struct
NdbCondition
;
/*
//
Create a condition
//
//
* returnvalue: pointer to the condition structure
*/
/*
*
*
Create a condition
*
* returnvalue: pointer to the condition structure
*/
struct
NdbCondition
*
NdbCondition_Create
(
void
);
/*
//
Wait for a condition, allows a thread to wait for
//
a condition and atomically releases the associated mutex.
//
//
* p_cond: pointer to the condition structure
//
* p_mutex: pointer to the mutex structure
//
* returnvalue: 0 = succeeded, 1 = failed
*/
/*
*
*
Wait for a condition, allows a thread to wait for
*
a condition and atomically releases the associated mutex.
*
* p_cond: pointer to the condition structure
* p_mutex: pointer to the mutex structure
* returnvalue: 0 = succeeded, 1 = failed
*/
int
NdbCondition_Wait
(
struct
NdbCondition
*
p_cond
,
NdbMutex
*
p_mutex
);
...
...
@@ -60,29 +60,29 @@ NdbCondition_WaitTimeout(struct NdbCondition* p_cond,
int
msec
);
/*
//
Signal a condition
//
//
* p_cond: pointer to the condition structure
//
* returnvalue: 0 = succeeded, 1 = failed
*/
/*
*
*
Signal a condition
*
* p_cond: pointer to the condition structure
* returnvalue: 0 = succeeded, 1 = failed
*/
int
NdbCondition_Signal
(
struct
NdbCondition
*
p_cond
);
/*
//
Broadcast a condition
//
//
* p_cond: pointer to the condition structure
//
* returnvalue: 0 = succeeded, 1 = failed
*/
/*
*
*
Broadcast a condition
*
* p_cond: pointer to the condition structure
* returnvalue: 0 = succeeded, 1 = failed
*/
int
NdbCondition_Broadcast
(
struct
NdbCondition
*
p_cond
);
/*
//
Destroy a condition
//
//
* p_cond: pointer to the condition structure
//
* returnvalue: 0 = succeeded, 1 = failed
*/
/*
*
*
Destroy a condition
*
* p_cond: pointer to the condition structure
* returnvalue: 0 = succeeded, 1 = failed
*/
int
NdbCondition_Destroy
(
struct
NdbCondition
*
p_cond
);
#ifdef __cplusplus
...
...
ndb/include/portlib/PortDefs.h
View file @
76b09dd5
...
...
@@ -28,35 +28,35 @@
struct
tms
{
time_t
tms_utime
;
// user time
time_t
tms_stime
;
// system time
time_t
tms_cutime
;
// user time of children
time_t
tms_cstime
;
// system time of children
time_t
tms_utime
;
/* user time */
time_t
tms_stime
;
/* system time */
time_t
tms_cutime
;
/* user time of children */
time_t
tms_cstime
;
/* system time of children */
};
struct
timespec
{
long
tv_sec
;
// Seconds
long
tv_nsec
;
// Nanoseconds
long
tv_sec
;
/* Seconds */
long
tv_nsec
;
/* Nanoseconds */
};
#define strcasecmp(a,b) _strcmpi(a,b)
// Exports a WIN32 getopt function
/* Exports a WIN32 getopt function */
extern
int
optind
;
extern
char
*
optarg
;
int
getopt
(
int
,
char
**
,
char
*
opts
);
#endif /
/ NDB_WIN32
#endif
/
* NDB_WIN32 */
#ifdef NDB_ALPHA
#ifdef NDB_GCC /
/ only for NDB_ALPHA
#ifdef NDB_GCC
/
* only for NDB_ALPHA */
extern
int
gnuShouldNotUseRPCC
();
#define RPCC() gnuShouldNotUseRPCC();
#else
#ifdef NDB_WIN32
#ifdef __cplusplus
extern
"C"
{
#endif /
/__cplusplus
#endif
/
* __cplusplus */
u_int64
__asm
(
char
*
,
...);
double
__dasm
(
char
*
,
...);
float
__fasm
(
char
*
,
...);
...
...
@@ -65,32 +65,32 @@ extern "C" {
int
__ADD_ATOMIC_LONG2
(
void
*
,
int
);
#ifdef __cplusplus
};
#endif /
/__cplusplus
#endif
/
* __cplusplus */
#pragma intrinsic (__asm, __dasm, __fasm)
#pragma intrinsic(_ReleaseSpinLock, _AcquireSpinLock)
#pragma intrinsic(__ADD_ATOMIC_LONG2)
#endif /
/ NDB_WIN32
#endif
/
* NDB_WIN32 */
#define RPCC() ((int)__asm(" rpcc v0;"))
#define MB() __asm(" mb;");
#define WMB() __asm(" wmb;");
#ifdef USE_INITIALSP
#define IS_IP() (__asm(" mov sp,v0;") < IPinitialSP)
#else /
/ USE_INITIALSP
#else
/
* USE_INITIALSP */
#define IS_IP() (((__asm(" rpcc v0;") >> 32) & 0x7) == IP_CPU)
#endif
#endif /
/NDB_GCC
#else /
/ NDB_ALPHA
#endif
/
* NDB_GCC */
#else
/
* NDB_ALPHA */
#if defined NDB_SPARC
#define MB() asm ("membar 0x0;"); /
/ LoadLoad
#define WMB() asm ("membar 0x3;"); /
/ StoreStore
#else /
/ NDB_SPARC
#define MB() asm ("membar 0x0;");
/
* LoadLoad */
#define WMB() asm ("membar 0x3;");
/
* StoreStore */
#else
/
* NDB_SPARC */
#define MB()
#define WMB()
#endif /
/ NDB_SPARC
#endif
/
* NDB_SPARC */
#define IS_IP() (1==1)
extern
int
shouldNotUseRPCC
();
#define RPCC() shouldNotUseRPCC();
#endif /
/ NDB_ALPHA
#endif
/
* NDB_ALPHA */
#endif
ndb/include/portlib/prefetch.h
View file @
76b09dd5
...
...
@@ -42,7 +42,7 @@ inline void prefetch(void* p)
{
#ifdef NDB_ALPHA
__asm
(
" ldl r31,0(a0);"
,
p
);
#endif /
/ NDB_ALPHA
#endif
/
* NDB_ALPHA */
#ifdef NDB_FORTE6
sparc_prefetch_read_once
(
p
);
#else
...
...
@@ -54,7 +54,7 @@ inline void writehint(void* p)
{
#ifdef NDB_ALPHA
__asm
(
" wh64 (a0);"
,
p
);
#endif /
/ NDB_ALPHA
#endif
/
* NDB_ALPHA */
#ifdef NDB_FORTE6
sparc_prefetch_write_once
(
p
);
#else
...
...
ndb/src/common/portlib/NdbDaemon.c
View file @
76b09dd5
...
...
@@ -28,7 +28,7 @@ NdbDaemon_Make(const char* lockfile, const char* logfile, unsigned flags)
int
lockfd
=
-
1
,
logfd
=
-
1
,
n
;
char
buf
[
64
];
(
void
)
flags
;
/
/ remove warning for unused parameter
(
void
)
flags
;
/
* remove warning for unused parameter */
/* Check that we have write access to lock file */
assert
(
lockfile
!=
NULL
);
...
...
ndb/src/common/portlib/NdbMem.c
View file @
76b09dd5
...
...
@@ -42,7 +42,7 @@ void* NdbMem_Allocate(size_t size)
void
*
NdbMem_AllocateAlign
(
size_t
size
,
size_t
alignment
)
{
(
void
)
alignment
;
/
/ remove warning for unused parameter
(
void
)
alignment
;
/
* remove warning for unused parameter */
/*
return (void*)memalign(alignment, size);
TEMP fix
...
...
ndb/src/common/portlib/NdbThread.c
View file @
76b09dd5
...
...
@@ -42,7 +42,7 @@ struct NdbThread* NdbThread_Create(NDB_THREAD_FUNC *p_thread_func,
int
result
;
pthread_attr_t
thread_attr
;
(
void
)
thread_prio
;
/
/ remove warning for unused parameter
(
void
)
thread_prio
;
/
* remove warning for unused parameter */
if
(
p_thread_func
==
NULL
)
return
0
;
...
...
@@ -110,7 +110,7 @@ int NdbThread_SetConcurrencyLevel(int level)
#ifdef USE_PTHREAD_EXTRAS
return
pthread_setconcurrency
(
level
);
#else
(
void
)
level
;
/
/ remove warning for unused parameter
(
void
)
level
;
/
* remove warning for unused parameter */
return
0
;
#endif
}
ndb/src/common/portlib/memtest.c
View file @
76b09dd5
...
...
@@ -90,7 +90,7 @@ void malloctest(int loopcount, int memsize, int touch) {
long
long
start
=
0
;
int
total
=
0
;
int
i
=
0
,
j
=
0
;
int
size
=
memsize
*
1024
*
1024
;
/
/bytes
;
int
size
=
memsize
*
1024
*
1024
;
/
*bytes*/
;
float
mean
;
char
*
ptr
=
0
;
...
...
@@ -126,7 +126,7 @@ void mmaptest(int loopcount, int memsize, int touch) {
int
total
=
0
;
int
i
=
0
,
j
=
0
;
char
*
ptr
;
int
size
=
memsize
*
1024
*
1024
;
/
/bytes
;
int
size
=
memsize
*
1024
*
1024
;
/
*bytes*/
;
float
mean
;
printf
(
"Staring mmaptest "
);
...
...
@@ -165,7 +165,7 @@ void unmaptest(loopcount, memsize)
int
total
=
0
;
int
i
=
0
,
j
=
0
;
char
*
ptr
;
int
size
=
memsize
*
1024
*
1024
;
/
/bytes
;
int
size
=
memsize
*
1024
*
1024
;
/
*bytes*/
;
float
mean
;
printf
(
"Staring munmap test (loopcount = 1 no matter what you prev. set)
\n
"
);
...
...
@@ -215,7 +215,7 @@ void freetest(int loopcount, int memsize) {
long
long
start
=
0
;
int
total
=
0
;
int
i
=
0
,
j
=
0
;
int
size
=
memsize
*
1024
*
1024
;
/
/bytes
;
int
size
=
memsize
*
1024
*
1024
;
/
*bytes*/
;
float
mean
;
char
*
ptr
=
0
;
...
...
ndb/src/common/util/basestring_vsnprintf.c
View file @
76b09dd5
...
...
@@ -14,7 +14,7 @@
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
/
/ define on IRIX to get posix compliant vsnprintf
/
* define on IRIX to get posix compliant vsnprintf */
#define _XOPEN_SOURCE 500
#include <stdio.h>
#include <basestring_vsnprintf.h>
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment