summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-12-15 01:13:32 +0300
committerValery Piashchynski <[email protected]>2021-12-15 01:13:32 +0300
commit31112495808ae37f38f7b514de1f40b8b8a75238 (patch)
treea90cb8df7c1e3f6bacddca6913c143398a5e94b9
parentff1401e97a9d1f3c059a60acbcae3f4507dcfe03 (diff)
chore(supervisor_pool): specify event in the logv2.6.2
Signed-off-by: Valery Piashchynski <[email protected]>
-rwxr-xr-xpool/supervisor_pool.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/pool/supervisor_pool.go b/pool/supervisor_pool.go
index 3dbae417..5f87c8a4 100755
--- a/pool/supervisor_pool.go
+++ b/pool/supervisor_pool.go
@@ -160,7 +160,7 @@ func (sp *supervised) control() { //nolint:gocognit
}
// just to double check
workers[i].State().Set(worker.StateInvalid)
- sp.events.Send(events.NewEvent(events.EventTTL, supervisorName, fmt.Sprintf("worker's pid: %d", workers[i].Pid())))
+ sp.events.Send(events.NewEvent(events.EventTTL, supervisorName, fmt.Sprintf("ttl reached, worker's pid: %d", workers[i].Pid())))
continue
}
@@ -180,7 +180,7 @@ func (sp *supervised) control() { //nolint:gocognit
}
// just to double check
workers[i].State().Set(worker.StateInvalid)
- sp.events.Send(events.NewEvent(events.EventMaxMemory, supervisorName, fmt.Sprintf("worker's pid: %d", workers[i].Pid())))
+ sp.events.Send(events.NewEvent(events.EventMaxMemory, supervisorName, fmt.Sprintf("max memory reached, worker's pid: %d", workers[i].Pid())))
continue
}
@@ -235,7 +235,7 @@ func (sp *supervised) control() { //nolint:gocognit
}
// just to double-check
workers[i].State().Set(worker.StateInvalid)
- sp.events.Send(events.NewEvent(events.EventIdleTTL, supervisorName, fmt.Sprintf("worker's pid: %d", workers[i].Pid())))
+ sp.events.Send(events.NewEvent(events.EventIdleTTL, supervisorName, fmt.Sprintf("idle ttl reached, worker's pid: %d", workers[i].Pid())))
}
}
}