From 80151f0dc7eeff12b0316f55fd1dbd78bada4724 Mon Sep 17 00:00:00 2001 From: Adam Ierymenko Date: Fri, 23 Sep 2022 16:52:21 -0400 Subject: [PATCH] debug code removal and comments --- network-hypervisor/src/vl1/node.rs | 68 +++++++++++++++--------------- 1 file changed, 34 insertions(+), 34 deletions(-) diff --git a/network-hypervisor/src/vl1/node.rs b/network-hypervisor/src/vl1/node.rs index 36e58c948..5115f97db 100644 --- a/network-hypervisor/src/vl1/node.rs +++ b/network-hypervisor/src/vl1/node.rs @@ -645,6 +645,8 @@ impl Node { // Legacy ZeroTier V1 packet handling if let Ok(fragment_header) = data.struct_mut_at::(0) { if let Some(dest) = Address::from_bytes_fixed(&fragment_header.dest) { + // Packet is addressed to this node. + if dest == self.identity.address { let fragment_header = &*fragment_header; // discard mut let path = self.canonical_path(source_endpoint, source_local_socket, source_local_interface, time_ticks); @@ -706,24 +708,24 @@ impl Node { } } } - } else { - if let Ok(packet_header) = data.struct_at::(0) { - debug_event!( - host_system, - "[vl1] [v1] #{:0>16x} is unfragmented", - u64::from_be_bytes(packet_header.id) - ); + } else if let Ok(packet_header) = data.struct_at::(0) { + debug_event!( + host_system, + "[vl1] [v1] #{:0>16x} is unfragmented", + u64::from_be_bytes(packet_header.id) + ); - if let Some(source) = Address::from_bytes(&packet_header.src) { - if let Some(peer) = self.peer(source) { - peer.receive(self, host_system, inner, time_ticks, &path, packet_header, data.as_ref(), &[]); - } else { - self.whois(host_system, source, Some((Arc::downgrade(&path), data)), time_ticks); - } + if let Some(source) = Address::from_bytes(&packet_header.src) { + if let Some(peer) = self.peer(source) { + peer.receive(self, host_system, inner, time_ticks, &path, packet_header, data.as_ref(), &[]); + } else { + self.whois(host_system, source, Some((Arc::downgrade(&path), data)), time_ticks); } } } } else { + // Packet is addressed somewhere else. + #[cfg(debug_assertions)] let debug_packet_id; @@ -743,30 +745,28 @@ impl Node { debug_event!(host_system, "[vl1] [v1] #{:0>16x} discarded: max hops exceeded!", debug_packet_id); return; } - } else { - if let Ok(packet_header) = data.struct_mut_at::(0) { + } else if let Ok(packet_header) = data.struct_mut_at::(0) { + #[cfg(debug_assertions)] + { + debug_packet_id = u64::from_be_bytes(packet_header.id); + debug_event!( + host_system, + "[vl1] [v1] #{:0>16x} forwarding packet to {}", + debug_packet_id, + dest.to_string() + ); + } + if packet_header.increment_hops() > v1::FORWARD_MAX_HOPS { #[cfg(debug_assertions)] - { - debug_packet_id = u64::from_be_bytes(packet_header.id); - debug_event!( - host_system, - "[vl1] [v1] #{:0>16x} forwarding packet to {}", - debug_packet_id, - dest.to_string() - ); - } - if packet_header.increment_hops() > v1::FORWARD_MAX_HOPS { - #[cfg(debug_assertions)] - debug_event!( - host_system, - "[vl1] [v1] #{:0>16x} discarded: max hops exceeded!", - u64::from_be_bytes(packet_header.id) - ); - return; - } - } else { + debug_event!( + host_system, + "[vl1] [v1] #{:0>16x} discarded: max hops exceeded!", + u64::from_be_bytes(packet_header.id) + ); return; } + } else { + return; } if let Some(peer) = self.peer(dest) {