fn insert(&mut self, artifact: UnvalidatedArtifact<SignedIngress>) {
        let ingress_pool_obj = IngressPoolObject::from(artifact.message);
        let peer_id = artifact.peer_id;
        let timestamp = artifact.timestamp;
        let size = ingress_pool_obj.count_bytes();

        self.peer_index.insert(peer_id, size);
        debug!(
            self.log,
            "ingress_message_insert_unvalidated";
            ingress_message.message_id => format!("{}", ingress_pool_obj.message_id)
        );

        self.unvalidated.insert(
            IngressMessageId::from(&ingress_pool_obj),
            UnvalidatedIngressArtifact {
                message: ingress_pool_obj,
                peer_id,
                timestamp,
            },
        );
        debug!(
            self.log,
            "Ingress pool: insert {} bytes into unvalidated", size
        );
    }
/// Insert a new ingress message in the Ingress Pool and update the
/// peer_index
Insert a new ingress message in the Ingress Pool and update the
peer_index
Insert a new ingress message in the Ingress Pool and update the peer_index
fn insert(&mut self, artifact: UnvalidatedArtifact<SignedIngress>) {
        let ingress_pool_obj = IngressPoolObject::from(artifact.message);
        let peer_id = artifact.peer_id;
        let timestamp = artifact.timestamp;
        let size = ingress_pool_obj.count_bytes();
        self.peer_index.insert(peer_id, size);
        debug!(
            self.log,
            "ingress_message_insert_unvalidated";
            ingress_message.message_id => format!("{}", ingress_pool_obj.message_id)
        );
        self.unvalidated.insert(
            IngressMessageId::from(&ingress_pool_obj),
            UnvalidatedIngressArtifact {
                message: ingress_pool_obj,
                peer_id,
                timestamp,
            },
        );
        debug!(
            self.log,
            "Ingress pool: insert {} bytes into unvalidated", size
        );
    }
fn insert ( & mut self , artifact : UnvalidatedArtifact < SignedIngress > ) { let ingress_pool_obj = IngressPoolObject :: from ( artifact . message ) ; let peer_id = artifact . peer_id ; let timestamp = artifact . timestamp ; let size = ingress_pool_obj . count_bytes ( ) ; self . peer_index . insert ( peer_id , size ) ; debug ! ( self log " " ingress_message message_id format ( " " ingress_pool_obj message_id ) ) ; self . unvalidated . insert ( IngressMessageId :: from ( & ingress_pool_obj ) , UnvalidatedIngressArtifact { message : ingress_pool_obj , peer_id , timestamp , } , ) ; debug ! ( self log " " size ) ; }
Insert a new ingress message in the Ingress Pool and update the
peer_index
Insert a new ingress message in the Ingress Pool and update the peer_index
&mut self
artifact
UnvalidatedArtifact<SignedIngress>
&mut self
artifact
UnvalidatedArtifact<SignedIngress>