From 33e2f7cb8b9a432f239b0e9786596b256a7776f6 Mon Sep 17 00:00:00 2001 From: Prashanth Balasubramanian Date: Sun, 5 Jul 2015 17:03:10 -0700 Subject: [PATCH] Don't leak tickers in the exec probe --- pkg/kubelet/dockertools/exec.go | 5 +++-- pkg/kubelet/dockertools/manager.go | 5 +++-- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/pkg/kubelet/dockertools/exec.go b/pkg/kubelet/dockertools/exec.go index 3f84e42f46b..c7bc583a710 100644 --- a/pkg/kubelet/dockertools/exec.go +++ b/pkg/kubelet/dockertools/exec.go @@ -123,7 +123,8 @@ func (*NativeExecHandler) ExecInContainer(client DockerInterface, container *doc if err != nil { return err } - tick := time.Tick(2 * time.Second) + ticker := time.NewTicker(2 * time.Second) + defer ticker.Stop() count := 0 for { inspect, err2 := client.InspectExec(execObj.ID) @@ -143,7 +144,7 @@ func (*NativeExecHandler) ExecInContainer(client DockerInterface, container *doc break } - <-tick + <-ticker.C } return err diff --git a/pkg/kubelet/dockertools/manager.go b/pkg/kubelet/dockertools/manager.go index 83434a0f546..8be453cb1e9 100644 --- a/pkg/kubelet/dockertools/manager.go +++ b/pkg/kubelet/dockertools/manager.go @@ -945,7 +945,8 @@ func (dm *DockerManager) RunInContainer(containerID string, cmd []string) ([]byt glog.V(2).Infof("StartExec With error: %v", err) return nil, err } - tick := time.Tick(2 * time.Second) + ticker := time.NewTicker(2 * time.Second) + defer ticker.Stop() for { inspect, err2 := dm.client.InspectExec(execObj.ID) if err2 != nil { @@ -959,7 +960,7 @@ func (dm *DockerManager) RunInContainer(containerID string, cmd []string) ([]byt } break } - <-tick + <-ticker.C } return buf.Bytes(), err