failNoPeers context support.

nanomsg · Mar 24, 2021 · ca708cb · ca708cb
1 parent c7f0d32
commit ca708cb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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