kylefang/stacks-puppet-node
1
0
Fork 0
mirror of https://github.com/alexgo-io/stacks-puppet-node.git synced 2026-05-18 18:10:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: MemPoolSyncData codec lives in the mempool modules

Browse Source
This commit is contained in:
Jude Nelson
2023-10-02 15:53:24 -04:00
parent e663ebd94b
commit 4efec5d5ae
1 changed files with 0 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
stackslib/src/net/codec.rs
View File

@@ -717,41 +717,6 @@ impl StacksMessageCodec for NatPunchData {
}
}
impl StacksMessageCodec for MemPoolSyncData {
fn consensus_serialize<W: Write>(&self, fd: &mut W) -> Result<(), codec_error> {
match *self {
MemPoolSyncData::BloomFilter(ref bloom_filter) => {
write_next(fd, &MemPoolSyncDataID::BloomFilter.to_u8())?;
write_next(fd, bloom_filter)?;
}
MemPoolSyncData::TxTags(ref seed, ref tags) => {
write_next(fd, &MemPoolSyncDataID::TxTags.to_u8())?;
write_next(fd, seed)?;
write_next(fd, tags)?;
}
}
Ok(())
}
fn consensus_deserialize<R: Read>(fd: &mut R) -> Result<MemPoolSyncData, codec_error> {
let data_id: u8 = read_next(fd)?;
match MemPoolSyncDataID::from_u8(data_id).ok_or(codec_error::DeserializeError(format!(
"Unrecognized MemPoolSyncDataID {}",
&data_id
)))? {
MemPoolSyncDataID::BloomFilter => {
let bloom_filter: BloomFilter<BloomNodeHasher> = read_next(fd)?;
Ok(MemPoolSyncData::BloomFilter(bloom_filter))
}
MemPoolSyncDataID::TxTags => {
let seed: [u8; 32] = read_next(fd)?;
let txtags: Vec<TxTag> = read_next(fd)?;
Ok(MemPoolSyncData::TxTags(seed, txtags))
}
}
}
}
fn contract_id_consensus_serialize<W: Write>(
fd: &mut W,
cid: &QualifiedContractIdentifier,