(root string, now time.Time)
| 199 | } |
| 200 | |
| 201 | func shouldRestartDaemon(root string, now time.Time) bool { |
| 202 | if !watch.IsRunning(root) { |
| 203 | return false |
| 204 | } |
| 205 | if !isOwnedDaemonProcess(root) { |
| 206 | return false |
| 207 | } |
| 208 | |
| 209 | state := watch.ReadState(root) |
| 210 | if state == nil { |
| 211 | return true |
| 212 | } |
| 213 | |
| 214 | return now.Sub(state.UpdatedAt) > daemonRestartStaleAfter |
| 215 | } |
| 216 | |
| 217 | func waitForDaemonState(root string, timeout time.Duration) *watch.State { |
| 218 | deadline := time.Now().Add(timeout) |