X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/75c5b123e0b4cbfebed9b15364a97c2209f94740..41372eb0088174d02505f657f0fa2dabbc845791:/services/keepproxy/keepproxy.go diff --git a/services/keepproxy/keepproxy.go b/services/keepproxy/keepproxy.go index 44ecae451f..7dfd01ad41 100644 --- a/services/keepproxy/keepproxy.go +++ b/services/keepproxy/keepproxy.go @@ -104,6 +104,7 @@ func main() { if err != nil { log.Fatalf("Error setting up keep client %s", err.Error()) } + keepclient.RefreshServiceDiscoveryOnSIGHUP() if cfg.PIDFile != "" { f, err := os.Create(cfg.PIDFile) @@ -133,7 +134,6 @@ func main() { if cfg.DefaultReplicas > 0 { kc.Want_replicas = cfg.DefaultReplicas } - go kc.RefreshServices(5*time.Minute, 3*time.Second) listener, err = net.Listen("tcp", cfg.Listen) if err != nil { @@ -269,12 +269,6 @@ func MakeRESTRouter(enable_get bool, enable_put bool, kc *keepclient.KeepClient, }, } - go func(t *http.Transport) { - for range time.NewTicker(5 * time.Minute).C { - t.CloseIdleConnections() - } - }(h.transport) - if enable_get { rest.HandleFunc(`/{locator:[0-9a-f]{32}\+.*}`, h.Get).Methods("GET", "HEAD") rest.HandleFunc(`/{locator:[0-9a-f]{32}}`, h.Get).Methods("GET", "HEAD")