)
// ClearCache clears the Keep service discovery cache.
-func ClearCache() {
+func RefreshServiceDiscovery() {
svcListCacheMtx.Lock()
defer svcListCacheMtx.Unlock()
for _, ent := range svcListCache {
// ClearCacheOnSIGHUP installs a signal handler that calls
// ClearCache when SIGHUP is received.
-func ClearCacheOnSIGHUP() {
+func RefreshServiceDiscoveryOnSIGHUP() {
svcListCacheMtx.Lock()
defer svcListCacheMtx.Unlock()
if svcListCacheSignal != nil {
signal.Notify(svcListCacheSignal, syscall.SIGHUP)
go func() {
for range svcListCacheSignal {
- ClearCache()
+ RefreshServiceDiscovery()
}
}()
}
type StandaloneSuite struct{}
func (s *StandaloneSuite) SetUpTest(c *C) {
- ClearCache()
+ RefreshServiceDiscovery()
}
func pythonDir() string {
}
func (s *ServerRequiredSuite) SetUpTest(c *C) {
- ClearCache()
+ RefreshServiceDiscovery()
}
func (s *ServerRequiredSuite) TestMakeKeepClient(c *C) {
&blobKeepService)
c.Assert(err, Equals, nil)
defer func() { arv.Delete("keep_services", blobKeepService["uuid"].(string), nil, nil) }()
- ClearCache()
+ RefreshServiceDiscovery()
// Make a keepclient and ensure that the testblobstore is included
kc, err := MakeKeepClient(arv)
func (h *handler) setup() {
h.clientPool = arvadosclient.MakeClientPool()
- keepclient.ClearCacheOnSIGHUP()
+ keepclient.RefreshServiceDiscoveryOnSIGHUP()
}
// ServeHTTP implements http.Handler.
// start api and keep servers
arvadostest.StartAPI()
arvadostest.StartKeep(2, false)
- keepclient.ClearCache()
+ keepclient.RefreshServiceDiscovery()
// make arvadosclient
arv, err := arvadosclient.MakeArvadosClient()
func (s *DoMainTestSuite) SetUpTest(c *C) {
logOutput := io.MultiWriter(&logBuffer)
log.SetOutput(logOutput)
- keepclient.ClearCache()
+ keepclient.RefreshServiceDiscovery()
}
func (s *DoMainTestSuite) TearDownTest(c *C) {
c.Assert(ttl, Equals, blobSignatureTTL)
c.Check(err, IsNil)
- keepclient.ClearCache()
+ keepclient.RefreshServiceDiscovery()
}
// Setup test data
// Start Keep servers
arvadostest.StartKeep(3, enforcePermissions)
- keepclient.ClearCache()
+ keepclient.RefreshServiceDiscovery()
// setup keepclients
var err error
// actual copying to dst will happen, but that's ok.
arvadostest.StartKeep(2, false)
defer arvadostest.StopKeep(2)
- keepclient.ClearCache()
+ keepclient.RefreshServiceDiscovery()
err := doMain()
c.Check(err, IsNil)