From ca708cb3b06b4f81109735ec0d2524493e3c3cbe Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Tue, 23 Mar 2021 23:31:09 -0700 Subject: [PATCH] failNoPeers context support. --- protocol/req/req.go | 1 + 1 file changed, 1 insertion(+) diff --git a/protocol/req/req.go b/protocol/req/req.go index 142c9de..fc7e2e9 100644 --- a/protocol/req/req.go +++ b/protocol/req/req.go @@ -504,6 +504,7 @@ func (s *socket) OpenContext() (protocol.Context, error) { resendTime: s.defCtx.resendTime, sendExpire: s.defCtx.sendExpire, recvExpire: s.defCtx.recvExpire, + failNoPeers: s.defCtx.failNoPeers, } s.ctxs[c] = struct{}{} return c, nil