public void updateReplicasForJoin ( TransactionState snapshotTransactionState ) { long [ ] replicasAdded = new long [ 0 ] ; if ( m_term != null ) { replicasAdded = ( ( SpTerm ) m_term ) . updateReplicas ( snapshotTransactionState ) ; } m_scheduler . forwardPendingTaskToRejoinNode ( replicasAdded , snapshotTransactionState . m_spHandle ) ; }
This will be called from Snapshot in elastic joining or rejoining cases .