private void queueOrOfferMPTask ( TransactionTask task ) { // The pending map will only have an entry for the transaction if the first fragment is // still pending durability. Queue < TransactionTask > pendingTasks = m_mpsPendingDurability . get ( task . getTxnId ( ) ) ; if ( pendingTasks != null ) { pendingTasks . offer ( task ) ; } else { m_pendingTasks . offer ( task ) ; } }
Check if the MP task has to be queued because the first fragment is still being logged synchronously to the command log . If not offer it to the transaction task queue .