/// send messages to all live SPU
send messages to all live SPU
send messages to all live SPU
async fn send_msg_to_all_live_spus(&self, msgs: Vec<SpuMsg>) {
        let online_spus = self.spu_store.online_spus();
        debug!(
            "trying to send SPU spec to active Spu: {}",
            online_spus.len()
        );
        for live_spu in online_spus {
            if let Err(err) = self
                .send_update_spu_msg_request(&live_spu, msgs.clone())
                .await
            {
                error!("error sending msg {}", err);
            }
        }
    }
async fn send_msg_to_all_live_spus ( & self , msgs : Vec < SpuMsg > ) { let online_spus = self . spu_store . online_spus ( ) ; debug ! ( " " online_spus len ( ) ) ; for live_spu in online_spus { if let Err ( err ) = self . send_update_spu_msg_request ( & live_spu , msgs . clone ( ) ) . await { error ! ( " " err ) ; } } }
send messages to all live SPU
send messages to all live SPU
&self
msgs
Vec<SpuMsg>