There was an error while loading. Please reload this page.
1 parent bd031f0 commit d48c89fCopy full SHA for d48c89f
1 file changed
net_polldesc.go
@@ -52,22 +52,21 @@ func (pd *pollDesc) WaitWrite(ctx context.Context) (err error) {
52
}
53
54
select {
55
+ case <-pd.writeTrigger: // triggered by poller
56
case <-pd.closeTrigger: // triggered by poller
57
// no need to detach, since poller has done it in OnHup.
58
return Exception(ErrConnClosed, "by peer")
- case <-pd.writeTrigger: // triggered by poller
59
- err = nil
60
case <-ctx.Done(): // triggered by ctx
61
// deregister from poller, upper caller function will close fd
62
pd.detach()
63
- err = mapErr(ctx.Err())
+ return mapErr(ctx.Err())
64
65
// double check close trigger
66
67
case <-pd.closeTrigger:
68
69
default:
70
- return err
+ return nil
71
72
73
0 commit comments