From b99f52832da8494db3e0fb9983b8ff6b58ec3ccf Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Tue, 20 Sep 2016 13:09:18 +0200 Subject: [PATCH] Removed unused state functions This removes the SetStoppedLocking, and SetRestartingLocking functions, which were not used anywhere. Signed-off-by: Sebastiaan van Stijn Upstream-commit: a28c389da109808c5b39da02fdfd24b9e36137fe Component: engine --- components/engine/container/state.go | 19 ++----------------- components/engine/container/state_test.go | 8 ++++++-- 2 files changed, 8 insertions(+), 19 deletions(-) diff --git a/components/engine/container/state.go b/components/engine/container/state.go index 12b22a4026..2628fc5b43 100644 --- a/components/engine/container/state.go +++ b/components/engine/container/state.go @@ -156,7 +156,7 @@ func wait(waitChan <-chan struct{}, timeout time.Duration) error { // WaitStop waits until state is stopped. If state already stopped it returns // immediately. If you want wait forever you must supply negative timeout. -// Returns exit code, that was passed to SetStoppedLocking +// Returns exit code, that was passed to SetStopped func (s *State) WaitStop(timeout time.Duration) (int, error) { s.Lock() if !s.Running { @@ -243,13 +243,6 @@ func (s *State) SetRunning(pid int, initial bool) { } } -// SetStoppedLocking locks the container state and sets it to "stopped". -func (s *State) SetStoppedLocking(exitStatus *ExitStatus) { - s.Lock() - s.SetStopped(exitStatus) - s.Unlock() -} - // SetStopped sets the container state to "stopped" without locking. func (s *State) SetStopped(exitStatus *ExitStatus) { s.Running = false @@ -262,15 +255,7 @@ func (s *State) SetStopped(exitStatus *ExitStatus) { s.waitChan = make(chan struct{}) } -// SetRestartingLocking is when docker handles the auto restart of containers when they are -// in the middle of a stop and being restarted again -func (s *State) SetRestartingLocking(exitStatus *ExitStatus) { - s.Lock() - s.SetRestarting(exitStatus) - s.Unlock() -} - -// SetRestarting sets the container state to "restarting". +// SetRestarting sets the container state to "restarting" without locking. // It also sets the container PID to 0. func (s *State) SetRestarting(exitStatus *ExitStatus) { // we should consider the container running when it is restarting because of diff --git a/components/engine/container/state_test.go b/components/engine/container/state_test.go index f10de12f2a..2e15bd7f41 100644 --- a/components/engine/container/state_test.go +++ b/components/engine/container/state_test.go @@ -30,7 +30,9 @@ func TestStateRunStop(t *testing.T) { atomic.StoreInt64(&exit, int64(exitCode)) close(stopped) }() - s.SetStoppedLocking(&ExitStatus{ExitCode: i}) + s.Lock() + s.SetStopped(&ExitStatus{ExitCode: i}) + s.Unlock() if s.IsRunning() { t.Fatal("State is running") } @@ -70,7 +72,9 @@ func TestStateTimeoutWait(t *testing.T) { t.Log("Stop callback fired") } - s.SetStoppedLocking(&ExitStatus{ExitCode: 1}) + s.Lock() + s.SetStopped(&ExitStatus{ExitCode: 1}) + s.Unlock() stopped = make(chan struct{}) go func() {