public void handleEOLMessage ( ) { Iv2EndOfLogMessage msg = new Iv2EndOfLogMessage ( m_partitionId ) ; MPIEndOfLogTransactionState txnState = new MPIEndOfLogTransactionState ( msg ) ; MPIEndOfLogTask task = new MPIEndOfLogTask ( m_mailbox , m_pendingTasks , txnState , m_iv2Masters ) ; m_pendingTasks . offer ( task ) ; }
Inject a task into the transaction task queue to flush it . When it executes it will send out MPI end of log messages to all partition initiators .