|
@ -136,6 +136,7 @@ func (bs *BaseService) Reset() (bool, error) { |
|
|
// whether or not we've started, we can reset
|
|
|
// whether or not we've started, we can reset
|
|
|
atomic.CompareAndSwapUint32(&bs.started, 1, 0) |
|
|
atomic.CompareAndSwapUint32(&bs.started, 1, 0) |
|
|
|
|
|
|
|
|
|
|
|
bs.Quit = make(chan struct{}) |
|
|
return true, bs.impl.OnReset() |
|
|
return true, bs.impl.OnReset() |
|
|
} else { |
|
|
} else { |
|
|
if bs.log != nil { |
|
|
if bs.log != nil { |
|
|