@@ -106,7 +106,7 @@ MtmSetClusterStatus(MtmNodeStatus status, char *statusReason)
106
106
}
107
107
108
108
static void
109
- MtmCheckState (void )
109
+ MtmCheckState (int severity )
110
110
{
111
111
// int nVotingNodes = MtmGetNumberOfVotingNodes();
112
112
bool isEnabledState ;
@@ -119,7 +119,7 @@ MtmCheckState(void)
119
119
120
120
old_status = Mtm -> status ;
121
121
122
- MTM_LOG1 ( "[STATE] Status = (disabled=%s, unaccessible=%s, clique=%s, receivers=%s, senders=%s, total=%i, major=%d, stopped=%s)" ,
122
+ MTM_ELOG ( severity , "[STATE] Status = (disabled=%s, unaccessible=%s, clique=%s, receivers=%s, senders=%s, total=%i, major=%d, stopped=%s)" ,
123
123
maskToString (Mtm -> disabledNodeMask , Mtm -> nAllNodes ),
124
124
maskToString (SELF_CONNECTIVITY_MASK , Mtm -> nAllNodes ),
125
125
maskToString (Mtm -> clique , Mtm -> nAllNodes ),
@@ -166,7 +166,7 @@ MtmCheckState(void)
166
166
MtmSetClusterStatus (MTM_RECOVERY , statusReason );
167
167
168
168
if (old_status != Mtm -> status )
169
- MtmCheckState ();
169
+ MtmCheckState (LOG );
170
170
return ;
171
171
}
172
172
break ;
@@ -179,7 +179,7 @@ MtmCheckState(void)
179
179
MtmSetClusterStatus (MTM_RECOVERED , statusReason );
180
180
181
181
if (old_status != Mtm -> status )
182
- MtmCheckState ();
182
+ MtmCheckState (LOG );
183
183
return ;
184
184
}
185
185
break ;
@@ -204,7 +204,7 @@ MtmCheckState(void)
204
204
MtmSetClusterStatus (MTM_ONLINE , statusReason );
205
205
206
206
if (old_status != Mtm -> status )
207
- MtmCheckState ();
207
+ MtmCheckState (LOG );
208
208
return ;
209
209
}
210
210
break ;
@@ -278,7 +278,7 @@ MtmStateProcessNeighborEvent(int node_id, MtmNeighborEvent ev) // XXXX camelcase
278
278
break ;
279
279
280
280
}
281
- MtmCheckState ();
281
+ MtmCheckState (LOG );
282
282
MtmUnlock ();
283
283
}
284
284
@@ -330,7 +330,7 @@ MtmStateProcessEvent(MtmEvent ev)
330
330
break ;
331
331
}
332
332
333
- MtmCheckState ();
333
+ MtmCheckState (LOG );
334
334
MtmUnlock ();
335
335
336
336
}
@@ -404,7 +404,7 @@ void MtmOnNodeDisconnect(int nodeId)
404
404
MtmDisableNode (nodeId );
405
405
Mtm -> nConfigChanges += 1 ;
406
406
BIT_SET (Mtm -> reconnectMask , nodeId - 1 );
407
- MtmCheckState ();
407
+ MtmCheckState (LOG );
408
408
MtmUnlock ();
409
409
}
410
410
@@ -420,7 +420,7 @@ void MtmOnNodeConnect(int nodeId)
420
420
BIT_CLEAR (SELF_CONNECTIVITY_MASK , nodeId - 1 );
421
421
BIT_SET (Mtm -> reconnectMask , nodeId - 1 );
422
422
423
- MtmCheckState ();
423
+ MtmCheckState (LOG );
424
424
MtmUnlock ();
425
425
426
426
// MtmRefreshClusterStatus();
@@ -476,7 +476,7 @@ MtmRefreshClusterStatus()
476
476
* See comment to MTM_RECOVERED -> MTM_ONLINE transition in MtmCheckState()
477
477
*/
478
478
MtmLock (LW_EXCLUSIVE );
479
- MtmCheckState ();
479
+ MtmCheckState (DEBUG1 );
480
480
MtmUnlock ();
481
481
482
482
/*
@@ -516,7 +516,7 @@ MtmRefreshClusterStatus()
516
516
MtmPollStatusOfPreparedTransactions (true);
517
517
}
518
518
MtmEnableNode (MtmNodeId );
519
- MtmCheckState ();
519
+ MtmCheckState (LOG );
520
520
}
521
521
MtmUnlock ();
522
522
}
@@ -610,7 +610,7 @@ MtmRefreshClusterStatus()
610
610
}
611
611
}
612
612
613
- MtmCheckState ();
613
+ MtmCheckState (LOG );
614
614
MtmUnlock ();
615
615
}
616
616
0 commit comments