X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/75e00445b6de230493e9ee37483dd4c469db29b1..8d73164d5ca50e7af1b3752b4251eaf9f11a9fc8:/sdk/go/keepclient/discover.go diff --git a/sdk/go/keepclient/discover.go b/sdk/go/keepclient/discover.go index e2cd329fc4..4377c19515 100644 --- a/sdk/go/keepclient/discover.go +++ b/sdk/go/keepclient/discover.go @@ -1,3 +1,7 @@ +// Copyright (C) The Arvados Authors. All rights reserved. +// +// SPDX-License-Identifier: Apache-2.0 + package keepclient import ( @@ -18,9 +22,15 @@ import ( func RefreshServiceDiscovery() { svcListCacheMtx.Lock() defer svcListCacheMtx.Unlock() + var wg sync.WaitGroup for _, ent := range svcListCache { - ent.clear <- struct{}{} + wg.Add(1) + go func() { + ent.clear <- struct{}{} + wg.Done() + }() } + wg.Wait() } // ClearCacheOnSIGHUP installs a signal handler that calls