/// Insert a cup with the original bytes from which that cup was received.
Insert a cup with the original bytes from which that cup was received.
Insert a cup with the original bytes from which that cup was received .
fn insert_cup_with_proto(&self, cup_with_proto: CUPWithOriginalProtobuf) {
        let mut tx = self
            .db_env
            .begin_rw_txn()
            .expect("Unable to begin transation to initialize consensus pool");
        let key = ArtifactKey::from(cup_with_proto.cup.get_id());
        self.tx_insert(
            &mut tx,
            &key,
            ValidatedArtifact {
                msg: PersistedConsensusMessage::OriginalCUPBytes(cup_with_proto.protobuf),
                timestamp: cup_with_proto.cup.content.block.as_ref().context.time,
            },
        )
        .expect("Insertion of CUP into initial consensus pool failed");
        tx.commit()
            .expect("Transaction inserting initial CUP into pool failed to commit");
    }
fn insert_cup_with_proto ( & self , cup_with_proto : CUPWithOriginalProtobuf ) { let mut tx = self . db_env . begin_rw_txn ( ) . expect ( " " ) ; let key = ArtifactKey :: from ( cup_with_proto . cup . get_id ( ) ) ; self . tx_insert ( & mut tx , & key , ValidatedArtifact { msg : PersistedConsensusMessage :: OriginalCUPBytes ( cup_with_proto . protobuf ) , timestamp : cup_with_proto . cup . content . block . as_ref ( ) . context . time , } , ) . expect ( " " ) ; tx . commit ( ) . expect ( " " ) ; }
Insert a cup with the original bytes from which that cup was received.
Insert a cup with the original bytes from which that cup was received .
&self
cup_with_proto
CUPWithOriginalProtobuf