@@ -3334,40 +3334,6 @@ MtmReplicationMode MtmGetReplicationMode(int nodeId, sig_atomic_t volatile* shut
33343334Mtm -> preparedTransactionsLoaded = true;
33353335}
33363336
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-
33713337/* Await until node is connected and both receiver and sender are in clique */
33723338while (BIT_CHECK (SELF_CONNECTIVITY_MASK ,nodeId - 1 )||
33733339!BIT_CHECK (Mtm -> clique ,nodeId - 1 )||