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