@@ -3334,40 +3334,6 @@ MtmReplicationMode MtmGetReplicationMode(int nodeId, sig_atomic_t volatile* shut
3334
3334
Mtm -> preparedTransactionsLoaded = true;
3335
3335
}
3336
3336
3337
- // while (BIT_CHECK(Mtm->disabledNodeMask, MtmNodeId - 1) ||
3338
- // BIT_CHECK(SELF_CONNECTIVITY_MASK, nodeId - 1) ||
3339
- // !BIT_CHECK(Mtm->clique, nodeId - 1) ||
3340
- // !BIT_CHECK(Mtm->clique, MtmNodeId - 1) )
3341
- // {
3342
- // if (*shutdown)
3343
- // {
3344
- // MtmUnlock();
3345
- // return REPLMODE_EXIT;
3346
- // }
3347
-
3348
- // if ((Mtm->recoverySlot == 0 || Mtm->recoverySlot == nodeId) &&
3349
- // (!BIT_CHECK(SELF_CONNECTIVITY_MASK, nodeId - 1)))
3350
- // {
3351
- // /* Lock on us */
3352
- // Mtm->recoverySlot = nodeId;
3353
- // MtmPollStatusOfPreparedTransactions();
3354
- // MtmUnlock();
3355
- // return REPLMODE_RECOVERY;
3356
- // }
3357
-
3358
- // MTM_LOG1("Replication to node %d is pending: recovery node=%d, donor node=%d, connectivity mask=%llx, disabled mask=%llx",
3359
- // nodeId, Mtm->recoverySlot, Mtm->donorNodeId, SELF_CONNECTIVITY_MASK, Mtm->disabledNodeMask);
3360
-
3361
- // MtmUnlock();
3362
- // /* delay opening of other slots until recovery is completed */
3363
- // MtmSleep(STATUS_POLL_DELAY);
3364
- // MtmLock(LW_EXCLUSIVE);
3365
- // }
3366
-
3367
- // MtmUnlock();
3368
-
3369
- // return REPLMODE_RECOVERED;
3370
-
3371
3337
/* Await until node is connected and both receiver and sender are in clique */
3372
3338
while (BIT_CHECK (SELF_CONNECTIVITY_MASK , nodeId - 1 ) ||
3373
3339
!BIT_CHECK (Mtm -> clique , nodeId - 1 ) ||
0 commit comments