///
/// 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_spu_request(
        &mut self,
        req_msg: RequestMessage<UpdateSpuRequest>,
        _shared_sc_sink: Arc<ExclusiveKfSink>
    ) -> Result<(), IoError> {
        let (_, request) = req_msg.get_header_request();
        debug!("received spu update from sc: {:#?}",request);
        let _spu_actions = self.ctx.spu_localstore().apply_changes(request.spus());
        Ok(())
    }
async fn handle_update_spu_request ( & mut self , req_msg : RequestMessage < UpdateSpuRequest > , _shared_sc_sink : Arc < ExclusiveKfSink > ) -> Result < ( ) , IoError > { let ( _ , request ) = req_msg . get_header_request ( ) ; debug ! ( " " request ) ; let _spu_actions = self . ctx . spu_localstore ( ) . apply_changes ( request . spus ( ) ) ; Ok ( ( ) ) }
Follower Update Handler sent by a peer Spu
Follower Update Handler sent by a peer Spu
&mut self
req_msg
RequestMessage<UpdateSpuRequest>
_shared_sc_sink
Arc<ExclusiveKfSink>