Removed unused state functions
This removes the SetStoppedLocking, and SetRestartingLocking functions, which were not used anywhere. Signed-off-by: Sebastiaan van Stijn <github@gone.nl> Upstream-commit: a28c389da109808c5b39da02fdfd24b9e36137fe Component: engine
This commit is contained in:
@ -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
|
||||
|
||||
@ -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() {
|
||||
|
||||
Reference in New Issue
Block a user