blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Move repeated logic into common function (#24373)

This commit is contained in:
steviez 2022-04-18 00:16:06 -05:00 committed by GitHub
parent 6a5a540b39
commit 38f0d60b00
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
core/src/serve_repair.rs
View File

@ -1148,6 +1148,10 @@ mod tests {
#[test]
fn test_run_ancestor_hashes() {
fn deserialize_ancestor_hashes_response(packet: &Packet) -> AncestorHashesResponseVersion {
limited_deserialize(&packet.data[..packet.meta.size - SIZE_OF_NONCE]).unwrap()
}
solana_logger::setup();
let recycler = PacketBatchRecycler::default();
let ledger_path = get_tmp_ledger_path!();
@ -1177,8 +1181,7 @@ mod tests {
.packets;
assert_eq!(rv.len(), 1);
let packet = &rv[0];
let ancestor_hashes_response: AncestorHashesResponseVersion =
limited_deserialize(&packet.data[..packet.meta.size - SIZE_OF_NONCE]).unwrap();
let ancestor_hashes_response = deserialize_ancestor_hashes_response(packet);
assert!(ancestor_hashes_response.into_slot_hashes().is_empty());
// `slot + num_slots - 1` is not marked duplicate confirmed so nothing should return
@ -1194,8 +1197,7 @@ mod tests {
.packets;
assert_eq!(rv.len(), 1);
let packet = &rv[0];
let ancestor_hashes_response: AncestorHashesResponseVersion =
limited_deserialize(&packet.data[..packet.meta.size - SIZE_OF_NONCE]).unwrap();
let ancestor_hashes_response = deserialize_ancestor_hashes_response(packet);
assert!(ancestor_hashes_response.into_slot_hashes().is_empty());
// Set duplicate confirmed
@ -1218,8 +1220,7 @@ mod tests {
.packets;
assert_eq!(rv.len(), 1);
let packet = &rv[0];
let ancestor_hashes_response: AncestorHashesResponseVersion =
limited_deserialize(&packet.data[..packet.meta.size - SIZE_OF_NONCE]).unwrap();
let ancestor_hashes_response = deserialize_ancestor_hashes_response(packet);
assert_eq!(
ancestor_hashes_response.into_slot_hashes(),
expected_ancestors