private void initializeDRProducer ( ) { try { if ( m_producerDRGateway != null ) { m_producerDRGateway . startAndWaitForGlobalAgreement ( ) ; for ( Initiator iv2init : m_iv2Initiators . values ( ) ) { iv2init . initDRGateway ( m_config . m_startAction , m_producerDRGateway , isLowestSiteId ( iv2init ) ) ; } m_producerDRGateway . completeInitialization ( ) ; } } catch ( Exception ex ) { CoreUtils . printPortsInUse ( hostLog ) ; VoltDB . crashLocalVoltDB ( "Failed to initialize DR producer" , false , ex ) ; } }
Initialize the DR producer so that any binary log generated on recover will be queued . This does NOT open the DR port . That will happen after command log replay finishes .