From 5ff87d8e65507ef6250a9b985cbd3f4fcf0b468a Mon Sep 17 00:00:00 2001 From: Anthony Laibe Date: Mon, 30 Jan 2023 10:41:14 +0100 Subject: [PATCH] fix: add lock when deleting peer --- waku/v2/node/keepalive.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/waku/v2/node/keepalive.go b/waku/v2/node/keepalive.go index e6693a62..536c7b75 100644 --- a/waku/v2/node/keepalive.go +++ b/waku/v2/node/keepalive.go @@ -86,7 +86,9 @@ func (w *WakuNode) pingPeer(ctx context.Context, wg *sync.WaitGroup, peer peer.I w.keepAliveMutex.Unlock() logger.Debug("could not ping", zap.Error(res.Error)) } else { + w.keepAliveMutex.Lock() delete(w.keepAliveFails, peer) + w.keepAliveMutex.Unlock() } case <-ctx.Done(): w.keepAliveMutex.Lock()