From 31112495808ae37f38f7b514de1f40b8b8a75238 Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Wed, 15 Dec 2021 01:13:32 +0300 Subject: chore(supervisor_pool): specify event in the log Signed-off-by: Valery Piashchynski --- pool/supervisor_pool.go | 6 +++--- 1 file 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()))) } } } -- cgit v1.2.3