code: 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);
          }
      }
docs: 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.
  
  @param task    A fragment task or a complete transaction task