///
/// Follower Update Handler sent by a peer Spu
///
Follower Update Handler sent by a peer Spu
Follower Update Handler sent by a peer Spu
async fn handle_update_replica_request(
        &mut self,
        req_msg: RequestMessage<UpdateReplicaRequest>,
        shared_sc_sink: Arc<ExclusiveKfSink>
    ) -> Result<(), IoError> {
        let (_, request) = req_msg.get_header_request();
        debug!("received replica update from sc: {:#?}",request);
        let replica_actions = self.ctx.replica_localstore().apply_changes(request.replicas().messages);
        self.apply_replica_actions(replica_actions,shared_sc_sink).await;    
        Ok(())
    }
async fn handle_update_replica_request ( & mut self , req_msg : RequestMessage < UpdateReplicaRequest > , shared_sc_sink : Arc < ExclusiveKfSink > ) -> Result < ( ) , IoError > { let ( _ , request ) = req_msg . get_header_request ( ) ; debug ! ( " " request ) ; let replica_actions = self . ctx . replica_localstore ( ) . apply_changes ( request . replicas ( ) . messages ) ; self . apply_replica_actions ( replica_actions , shared_sc_sink ) . await ; Ok ( ( ) ) }
Follower Update Handler sent by a peer Spu
Follower Update Handler sent by a peer Spu
&mut self
req_msg
RequestMessage<UpdateReplicaRequest>
shared_sc_sink
Arc<ExclusiveKfSink>