Merge "services/xproxyd: Make reconnectDelay a const."
diff --git a/runtime/internal/flow/manager/manager.go b/runtime/internal/flow/manager/manager.go
index c951916..d6d7ca1 100644
--- a/runtime/internal/flow/manager/manager.go
+++ b/runtime/internal/flow/manager/manager.go
@@ -26,6 +26,8 @@
"v.io/x/ref/runtime/internal/rpc/version"
)
+const reconnectDelay = 50 * time.Millisecond
+
type manager struct {
rid naming.RoutingID
closed chan struct{}
@@ -116,7 +118,6 @@
func (m *manager) connectToProxy(ctx *context.T, address string, ep naming.Endpoint) {
defer m.wg.Done()
- reconnectDelay := 50 * time.Millisecond
for delay := reconnectDelay; ; delay *= 2 {
time.Sleep(delay - reconnectDelay)
select {
diff --git a/services/xproxyd/proxyd.go b/services/xproxyd/proxyd.go
index 83225d2..85d66f7 100644
--- a/services/xproxyd/proxyd.go
+++ b/services/xproxyd/proxyd.go
@@ -16,7 +16,7 @@
"v.io/v23/naming"
)
-// TODO(suharshs): Make sure that we don't leak any goroutines.
+const reconnectDelay = 50 * time.Millisecond
type proxy struct {
m flow.Manager
@@ -200,7 +200,6 @@
}
func (p *proxy) connectToProxy(ctx *context.T, address string, ep naming.Endpoint) {
- reconnectDelay := 50 * time.Millisecond
for delay := reconnectDelay; ; delay *= 2 {
time.Sleep(delay - reconnectDelay)
select {
