/// Creates a new batch containing a single ingress message and sends it for
/// processing to the replicated state machine.
Creates a new batch containing a single ingress message and sends it for
processing to the replicated state machine.
Creates a new batch containing a single ingress message and sends it for processing to the replicated state machine .
fn send_signed_ingress(&self, msg: SignedIngress) {
        // Move the block time forward by 1 second.
        self.time.set(self.time.get() + Duration::from_secs(1));
        let batch = Batch {
            batch_number: self.message_routing.expected_batch_height(),
            requires_full_state_hash: true,
            payload: BatchPayload {
                ingress: IngressPayload::from(vec![msg]),
                xnet: XNetPayload {
                    stream_slices: Default::default(),
                },
                self_validating: SelfValidatingPayload::default(),
            },
            randomness: Randomness::from([0; 32]),
            registry_version: RegistryVersion::from(1),
            time: self.time.get(),
            consensus_responses: vec![],
        };
        self.message_routing
            .deliver_batch(batch)
            .expect("MR queue overflow")
    }
fn send_signed_ingress ( & self , msg : SignedIngress ) { // Move the block time forward by 1 second. self . time . set ( self . time . get ( ) + Duration :: from_secs ( 1 ) ) ; let batch = Batch { batch_number : self . message_routing . expected_batch_height ( ) , requires_full_state_hash : true , payload : BatchPayload { ingress : IngressPayload :: from ( vec ! [ msg ] ) , xnet : XNetPayload { stream_slices : Default :: default ( ) , } , self_validating : SelfValidatingPayload :: default ( ) , } , randomness : Randomness :: from ( [ 0 ; 32 ] ) , registry_version : RegistryVersion :: from ( 1 ) , time : self . time . get ( ) , consensus_responses : vec ! [ ] , } ; self . message_routing . deliver_batch ( batch ) . expect ( " " ) }
Creates a new batch containing a single ingress message and sends it for
processing to the replicated state machine.
Creates a new batch containing a single ingress message and sends it for processing to the replicated state machine .
&self
msg
SignedIngress