@@ -127,6 +127,7 @@ MtmCheckState(void)
127
127
case MTM_RECOVERY :
128
128
if (!BIT_CHECK (Mtm -> disabledNodeMask , MtmNodeId - 1 ))
129
129
{
130
+ MTM_LOG1 ("[LOCK] set lock on MTM_RECOVERY switch" );
130
131
BIT_SET (Mtm -> originLockNodeMask , MtmNodeId - 1 ); // kk trick, XXXX: log that
131
132
MtmSetClusterStatus (MTM_RECOVERED );
132
133
return ;
@@ -148,6 +149,7 @@ MtmCheckState(void)
148
149
* in major mode or with referee we can be working alone
149
150
* so nobody will clean it.
150
151
*/
152
+ MTM_LOG1 ("[LOCK] release lock on MTM_RECOVERED switch" );
151
153
BIT_CLEAR (Mtm -> originLockNodeMask , MtmNodeId - 1 );
152
154
MtmSetClusterStatus (MTM_ONLINE );
153
155
return ;
@@ -177,6 +179,7 @@ MtmStateProcessNeighborEvent(int node_id, MtmNeighborEvent ev) // XXXX camelcase
177
179
178
180
case MTM_NEIGHBOR_WAL_RECEIVER_START :
179
181
BIT_SET (Mtm -> pglogicalReceiverMask , node_id - 1 );
182
+ MTM_LOG1 ("[LOCK] release lock on MTM_NEIGHBOR_WAL_RECEIVER_START event" );
180
183
BIT_CLEAR (Mtm -> originLockNodeMask , MtmNodeId - 1 );
181
184
break ;
182
185
@@ -190,6 +193,7 @@ MtmStateProcessNeighborEvent(int node_id, MtmNeighborEvent ev) // XXXX camelcase
190
193
break ;
191
194
192
195
case MTM_NEIGHBOR_RECOVERY_CAUGHTUP :
196
+ MTM_LOG1 ("[LOCK] release lock on MTM_NEIGHBOR_RECOVERY_CAUGHTUP event" );
193
197
BIT_CLEAR (Mtm -> originLockNodeMask , node_id - 1 );
194
198
MtmEnableNode (node_id );
195
199
break ;
0 commit comments