|
@@ -39,9 +39,11 @@ func (s *State) setStopped(exitCode int) {
|
|
|
s.broadcast()
|
|
|
}
|
|
|
|
|
|
-func (s *State) resetLock() {
|
|
|
- s.stateChangeLock = &sync.Mutex{}
|
|
|
- s.stateChangeCond = sync.NewCond(s.stateChangeLock)
|
|
|
+func (s *State) initLock() {
|
|
|
+ if s.stateChangeLock == nil {
|
|
|
+ s.stateChangeLock = &sync.Mutex{}
|
|
|
+ s.stateChangeCond = sync.NewCond(s.stateChangeLock)
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
func (s *State) broadcast() {
|