fix strict egress detetermination
This commit is contained in:
@@ -123,7 +123,7 @@ def _bridge_af_packet_observation_path(
|
|||||||
(
|
(
|
||||||
item
|
item
|
||||||
for item in egress_candidates
|
for item in egress_candidates
|
||||||
if item.get("iface") != ingress_iface and _parse_observation_timestamp(item.get("timestamp")) >= ingress_ts
|
if item.get("iface") != ingress_iface
|
||||||
),
|
),
|
||||||
None,
|
None,
|
||||||
)
|
)
|
||||||
@@ -138,8 +138,19 @@ def _bridge_af_packet_observation_path(
|
|||||||
),
|
),
|
||||||
None,
|
None,
|
||||||
)
|
)
|
||||||
|
if fallback_egress is not None:
|
||||||
return ingress_observation, fallback_egress
|
return ingress_observation, fallback_egress
|
||||||
|
|
||||||
|
last_resort_egress = next(
|
||||||
|
(
|
||||||
|
item
|
||||||
|
for item in observations
|
||||||
|
if item.get("iface") != ingress_iface
|
||||||
|
),
|
||||||
|
None,
|
||||||
|
)
|
||||||
|
return ingress_observation, last_resort_egress
|
||||||
|
|
||||||
|
|
||||||
class PacketTracker:
|
class PacketTracker:
|
||||||
"""Deduplicate packet observations and persist one upserted row per packet."""
|
"""Deduplicate packet observations and persist one upserted row per packet."""
|
||||||
|
|||||||
Reference in New Issue
Block a user