From 3ff3a54564e8bd5fc158201b025b1d3a5336f460 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期六, 01 六月 2019 16:56:59 +0800
Subject: [PATCH] set ErrRecvTimeout to ErrProtoState
---
server.go | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/server.go b/server.go
index e864a22..94c6a24 100644
--- a/server.go
+++ b/server.go
@@ -19,7 +19,7 @@
// responses
SurveyTime time.Duration
// RecvDeadline is the time until the next recived of the SURVEY times out.
- RecvDeadline time.Duration
+ //RecvDeadline time.Duration
// PollTime is minimal time between SURVEYS (The time between SURVEYS could be greater than this time
// if the SURVEY process takes longer than that time)
PollTime time.Duration
@@ -85,10 +85,10 @@
if err != nil {
return nil, err
}
- err = sock.SetOption(mangos.OptionRecvDeadline, opt.RecvDeadline)
- if err != nil {
- return nil, err
- }
+ //err = sock.SetOption(mangos.OptionRecvDeadline, opt.RecvDeadline)
+ //if err != nil {
+ // return nil, err
+ //}
pubCtx, pubCancel := context.WithCancel(ctx)
publisher, err = NewPublisher(pubCtx, urlPubSub)
@@ -150,7 +150,7 @@
for {
msg, err = d.sock.Recv()
if err != nil {
- if err == mangos.ErrRecvTimeout {
+ if err == mangos.ErrProtoState {
// Timeout means I can add the current responses to the SET
d.services.Add(responses)
return
--
Gitblit v1.8.0