From 7ac64e26628df65c0b0c033ec0263d4242f932cc Mon Sep 17 00:00:00 2001 From: Ryu Seowoong Date: Fri, 11 Jul 2025 13:52:33 +0900 Subject: [PATCH] Apply InboundTrafficLimitHandler only if max bytes > 0 --- .../io/libp2p/protocol/circuit/CircuitHopProtocol.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/libp2p/src/main/java/io/libp2p/protocol/circuit/CircuitHopProtocol.java b/libp2p/src/main/java/io/libp2p/protocol/circuit/CircuitHopProtocol.java index be2be179d..db8d73126 100644 --- a/libp2p/src/main/java/io/libp2p/protocol/circuit/CircuitHopProtocol.java +++ b/libp2p/src/main/java/io/libp2p/protocol/circuit/CircuitHopProtocol.java @@ -315,11 +315,15 @@ public void onMessage(@NotNull Stream stream, Circuit.HopMessage msg) { new CircuitStopProtocol.StopRemover()); // connect these streams with time + bytes enforcement - fromRequestor.pushHandler(new InboundTrafficLimitHandler(resv.maxBytes)); + if(resv.maxBytes > 0){ + fromRequestor.pushHandler(new InboundTrafficLimitHandler(resv.maxBytes)); + } fromRequestor.pushHandler( new TotalTimeoutHandler( Duration.of(resv.durationSeconds, ChronoUnit.SECONDS))); - toTarget.pushHandler(new InboundTrafficLimitHandler(resv.maxBytes)); + if(resv.maxBytes > 0){ + toTarget.pushHandler(new InboundTrafficLimitHandler(resv.maxBytes)); + } toTarget.pushHandler( new TotalTimeoutHandler( Duration.of(resv.durationSeconds, ChronoUnit.SECONDS)));