package/go-service
1
0
Fork 0
mirror of https://github.com/rynbrd/go-service.git synced 2024-07-22 16:58:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

Don't send Running before Backoff.

Browse Source
This commit is contained in:
Ryan Bourgeois 2013-12-02 14:45:56 -08:00
parent 937468306f
commit 8eb140540f
1 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
service/service.go
View File

@ -196,26 +196,27 @@ func (s *Service) Run(commands <-chan Command, events chan<- Event) {
sendEvent(Starting, nil)
go func() {
s.command = s.makeCommand()
startTime := time.Now()
if err := s.command.Start(); err == nil {
states <- ProcessState{Running, nil}
exitErr := s.command.Wait()
time.Sleep(s.StartTimeout)
msg := ""
if time.Now().Sub(startTime) < s.StartTimeout {
if exitErr == nil {
msg = "process exited prematurely with success"
} else {
msg = fmt.Sprintf("process exited prematurely with failure: %s", exitErr)
}
states <- ProcessState{Backoff, ExitError(msg)}
} else {
if s.Pid() > 0 {
states <- ProcessState{Running, nil}
exitErr := s.command.Wait()
if exitErr == nil {
msg = "process exited normally with success"
} else {
msg = fmt.Sprintf("process exited normally with failure: %s", exitErr)
}
states <- ProcessState{Exited, ExitError(msg)}
} else {
exitErr := s.command.Wait()
if exitErr == nil {
msg = "process exited prematurely with success"
} else {
msg = fmt.Sprintf("process exited prematurely with failure: %s", exitErr)
}
states <- ProcessState{Backoff, ExitError(msg)}
}
} else {
states <- ProcessState{Exited, err}