X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/743680ab176697218aa41839149e02a160786bdf..9992a8816837bd03a1beecd0c0e8082bd913319a:/sdk/go/keepclient/discover.go diff --git a/sdk/go/keepclient/discover.go b/sdk/go/keepclient/discover.go index 62936e7183..726c3fb30c 100644 --- a/sdk/go/keepclient/discover.go +++ b/sdk/go/keepclient/discover.go @@ -16,10 +16,10 @@ import ( "syscall" "time" - "git.curoverse.com/arvados.git/sdk/go/arvadosclient" + "git.arvados.org/arvados.git/sdk/go/arvadosclient" ) -// ClearCache clears the Keep service discovery cache. +// RefreshServiceDiscovery clears the Keep service discovery cache. func RefreshServiceDiscovery() { var wg sync.WaitGroup defer wg.Wait() @@ -27,15 +27,16 @@ func RefreshServiceDiscovery() { defer svcListCacheMtx.Unlock() for _, ent := range svcListCache { wg.Add(1) + clear := ent.clear go func() { - ent.clear <- struct{}{} + clear <- struct{}{} wg.Done() }() } } -// ClearCacheOnSIGHUP installs a signal handler that calls -// ClearCache when SIGHUP is received. +// RefreshServiceDiscoveryOnSIGHUP installs a signal handler that calls +// RefreshServiceDiscovery when SIGHUP is received. func RefreshServiceDiscoveryOnSIGHUP() { svcListCacheMtx.Lock() defer svcListCacheMtx.Unlock()