this repo has no description
improve timeouts on event streams a bit (#404)
authored by
Whyrusleeping
and committed by
GitHub
54020841
9e0e90f5
+13
-1
+3
-1
bgs/fedmgr.go
+3
-1
bgs/fedmgr.go
+10
events/consumer.go
+10
events/consumer.go
···
90
90
defer t.Stop()
91
91
92
92
for {
93
+
93
94
select {
94
95
case <-t.C:
95
96
if err := con.WriteControl(websocket.PingMessage, []byte{}, time.Now().Add(time.Second*10)); err != nil {
···
112
113
return err
113
114
})
114
115
116
+
con.SetPongHandler(func(_ string) error {
117
+
if err := con.SetReadDeadline(time.Now().Add(time.Minute)); err != nil {
118
+
log.Errorf("failed to set read deadline: %s", err)
119
+
}
120
+
121
+
return nil
122
+
})
123
+
115
124
lastSeq := int64(-1)
116
125
for {
117
126
select {
···
119
128
return ctx.Err()
120
129
default:
121
130
}
131
+
122
132
mt, rawReader, err := con.NextReader()
123
133
if err != nil {
124
134
return err