From dd3e89474777b39b7bea646796de594449ea2304 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jano=C5=A1=20Gulja=C5=A1?= Date: Wed, 16 Jan 2019 14:31:32 +0100 Subject: swarm/storage: fix mockNetFetcher data races (#18462) fixes: ethersphere/go-ethereum#1117 (cherry picked from commit f728837ee6b48a2413437f54057b4552b7e77494) --- swarm/storage/netstore_test.go | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'swarm/storage') diff --git a/swarm/storage/netstore_test.go b/swarm/storage/netstore_test.go index 2ed3e0752..a6a9f551a 100644 --- a/swarm/storage/netstore_test.go +++ b/swarm/storage/netstore_test.go @@ -43,6 +43,7 @@ type mockNetFetcher struct { quit <-chan struct{} ctx context.Context hopCounts []uint8 + mu sync.Mutex } func (m *mockNetFetcher) Offer(ctx context.Context, source *enode.ID) { @@ -51,6 +52,9 @@ func (m *mockNetFetcher) Offer(ctx context.Context, source *enode.ID) { } func (m *mockNetFetcher) Request(ctx context.Context, hopCount uint8) { + m.mu.Lock() + defer m.mu.Unlock() + m.requestCalled = true var peers []Address m.peers.Range(func(key interface{}, _ interface{}) bool { -- cgit v1.2.3