mirror of
https://github.com/zerotier/zssp.git
synced 2026-05-22 16:28:40 -07:00
cargo fmt
This commit is contained in:
+11
-13
@@ -307,19 +307,17 @@ impl<C: CryptoLayer> Context<C> {
|
||||
if let Entry::Occupied(mut entry) = b2_map.entry(kid_recv) {
|
||||
let zeta = entry.get_mut();
|
||||
// Process recv fragmentation layer.
|
||||
let result = zeta.defrag.received_fragment::<C>(
|
||||
raw_fragment,
|
||||
app.time(),
|
||||
|n, frag_no, frag_count| {
|
||||
let (p, c) = from_nonce(n);
|
||||
log!(app, ReceivedRawFragment(p, c, frag_no, frag_count));
|
||||
if p == PACKET_TYPE_HANDSHAKE_COMPLETION && c == 0 {
|
||||
Ok(())
|
||||
} else {
|
||||
Err(byzantine_fault!(InvalidPacket, true))
|
||||
}
|
||||
},
|
||||
)?;
|
||||
let result =
|
||||
zeta.defrag
|
||||
.received_fragment::<C>(raw_fragment, app.time(), |n, frag_no, frag_count| {
|
||||
let (p, c) = from_nonce(n);
|
||||
log!(app, ReceivedRawFragment(p, c, frag_no, frag_count));
|
||||
if p == PACKET_TYPE_HANDSHAKE_COMPLETION && c == 0 {
|
||||
Ok(())
|
||||
} else {
|
||||
Err(byzantine_fault!(InvalidPacket, true))
|
||||
}
|
||||
})?;
|
||||
if let Some((_, assembled_packet)) = result {
|
||||
log!(app, ReceivedRawX3);
|
||||
let zeta = entry.remove();
|
||||
|
||||
@@ -47,12 +47,7 @@ impl AesGcmAead for AesGcmCrate {
|
||||
let key = Key::<Aes256Gcm>::from_slice(key);
|
||||
let mut cipher = Aes256Gcm::new(key);
|
||||
cipher
|
||||
.decrypt_in_place_detached(
|
||||
Nonce::from_slice(iv),
|
||||
aad.unwrap_or(&[]),
|
||||
buffer,
|
||||
Tag::from_slice(tag),
|
||||
)
|
||||
.decrypt_in_place_detached(Nonce::from_slice(iv), aad.unwrap_or(&[]), buffer, Tag::from_slice(tag))
|
||||
.is_ok()
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user