diff options
Diffstat (limited to 'supervisor_pool.go')
| -rwxr-xr-x | supervisor_pool.go | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/supervisor_pool.go b/supervisor_pool.go index b354b493..6fcb71e6 100755 --- a/supervisor_pool.go +++ b/supervisor_pool.go @@ -156,10 +156,8 @@ func (sp *supervisedPool) control() { if err != nil { sp.events.Push(PoolEvent{Event: EventSupervisorError, Payload: errors.E(op, err)}) return - } else { - sp.events.Push(PoolEvent{Event: EventTTL, Payload: workers[i]}) } - + sp.events.Push(PoolEvent{Event: EventTTL, Payload: workers[i]}) continue } @@ -168,9 +166,8 @@ func (sp *supervisedPool) control() { if err != nil { sp.events.Push(PoolEvent{Event: EventSupervisorError, Payload: errors.E(op, err)}) return - } else { - sp.events.Push(PoolEvent{Event: EventMaxMemory, Payload: workers[i]}) } + sp.events.Push(PoolEvent{Event: EventMaxMemory, Payload: workers[i]}) continue } @@ -201,9 +198,8 @@ func (sp *supervisedPool) control() { if err != nil { sp.events.Push(PoolEvent{Event: EventSupervisorError, Payload: errors.E(op, err)}) return - } else { - sp.events.Push(PoolEvent{Event: EventIdleTTL, Payload: workers[i]}) } + sp.events.Push(PoolEvent{Event: EventIdleTTL, Payload: workers[i]}) } } } |