We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a560d91 commit 0439f2fCopy full SHA for 0439f2f
internal/transports/p2p/peer/peer.go
@@ -79,7 +79,7 @@ type Peer struct {
79
quitting bool
80
// quit is a channel used to properly handle peer disconnection
81
quit chan struct{}
82
- // quitMutex is used to prevents concurrect disconnections
+ // quitMutex is used to prevents concurrent disconnections
83
quitMutex sync.Mutex
84
85
// manager is a peer manager
internal/transports/p2p/server.go
@@ -266,7 +266,7 @@ func (s *server) observeInboundPeers() {
266
}
267
268
269
-// usage MUST be preceded by `s.ctx.Wg.Add(1)`
+// usage MUST be preceded by `s.ctx.Wg.Add(1)`.
270
func (s *server) noWaitingSleep(duration time.Duration) {
271
s.ctxWg.Done() // We are sleeping -> no need to wait
272
time.Sleep(duration)
0 commit comments