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