/// Bulk Update Handler sent by Controller
///
Bulk Update Handler sent by Controller
Bulk Update Handler sent by Controller
async fn handle_sync_all_request(
        &mut self,
        req_msg: RequestMessage<UpdateAllRequest>,
        shared_sc_sink: Arc<ExclusiveKfSink>
    ) -> Result<(), IoError> {
        let (_, request) = req_msg.get_header_request();
        debug!(
            "RCVD-Req << (CTRL): UpdateAll({} spus, {} replicas)",
            request.spus.len(),
            request.replicas.len(),
        );
        let spu_actions = self.ctx.spu_localstore().sync_all(request.spus);
        trace!("all spu actions detail: {:#?}",spu_actions);
        /*
         * For now, there are nothing to do.
        for spu_action in spu_actions.into_iter() {
            match spu_action {
                SpecChange::Add(_) => {},
                SpecChange::Mod(_,_) => {},
                SpecChange::Delete(_) => {}
            }
        }
        */
        let replica_actions = self.ctx.replica_localstore().sync_all(request.replicas);
        self.apply_replica_actions(replica_actions,shared_sc_sink).await;    
        Ok(())
    }
async fn handle_sync_all_request ( & mut self , req_msg : RequestMessage < UpdateAllRequest > , shared_sc_sink : Arc < ExclusiveKfSink > ) -> Result < ( ) , IoError > { let ( _ , request ) = req_msg . get_header_request ( ) ; debug ! ( " " request spus len ( ) request replicas len ( ) ) ; let spu_actions = self . ctx . spu_localstore ( ) . sync_all ( request . spus ) ; trace ! ( " " spu_actions ) ; /*
         * For now, there are nothing to do.
        for spu_action in spu_actions.into_iter() {
            
            match spu_action {

                SpecChange::Add(_) => {},
                SpecChange::Mod(_,_) => {},
                SpecChange::Delete(_) => {}

            }
            
        }
        */ let replica_actions = self . ctx . replica_localstore ( ) . sync_all ( request . replicas ) ; self . apply_replica_actions ( replica_actions , shared_sc_sink ) . await ; Ok ( ( ) ) }
Bulk Update Handler sent by Controller
Bulk Update Handler sent by Controller
&mut self
req_msg
RequestMessage<UpdateAllRequest>
shared_sc_sink
Arc<ExclusiveKfSink>