@@ -3338,40 +3338,6 @@ MtmReplicationMode MtmGetReplicationMode(int nodeId, sig_atomic_t volatile* shut
33383338Mtm -> preparedTransactionsLoaded = true;
33393339}
33403340
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-
33753341/* Await until node is connected and both receiver and sender are in clique */
33763342while (BIT_CHECK (SELF_CONNECTIVITY_MASK ,nodeId - 1 )||
33773343!BIT_CHECK (Mtm -> clique ,nodeId - 1 )||