We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 64b397f commit a27cf1bCopy full SHA for a27cf1b
p2p/message.go
@@ -156,7 +156,7 @@ func MsgPipe() (*MsgPipeRW, *MsgPipeRW) {
156
var (
157
c1, c2 = make(chan Msg), make(chan Msg)
158
closing = make(chan struct{})
159
- closed atomic.Int32
+ closed = new(atomic.Int32)
160
rw1 = &MsgPipeRW{c1, c2, closing, closed}
161
rw2 = &MsgPipeRW{c2, c1, closing, closed}
162
)
@@ -172,7 +172,7 @@ type MsgPipeRW struct {
172
w chan<- Msg
173
r <-chan Msg
174
closing chan struct{}
175
+ closed *atomic.Int32
176
}
177
178
// WriteMsg sends a message on the pipe.
0 commit comments