Merge pull request #19 from libp2p/fix/can-hop-reset

handleCanHop: reset stream on errors
libp2p · Sep 13, 2017 · 5813d21 · 5813d21
2 parents 56c1643 + 5253314
commit 5813d21
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/p2p/protocol/internal/circuitv1-deprecated/relay.go b/p2p/protocol/internal/circuitv1-deprecated/relay.go
@@ -346,10 +346,11 @@ func (r *Relay) handleCanHop(s inet.Stream, msg *pb.CircuitRelay) {
 	}
 
 	if err != nil {
+		s.Reset()
 		log.Debugf("error writing relay response: %s", err.Error())
+	} else {
+		s.Close()
 	}
-
-	s.Close()
 }
 
 func (r *Relay) handleError(s inet.Stream, code pb.CircuitRelay_Status) {