diff --git a/pkg/appsrv/workers.go b/pkg/appsrv/workers.go index 45c48b9a6e..9198ae2751 100644 --- a/pkg/appsrv/workers.go +++ b/pkg/appsrv/workers.go @@ -215,6 +215,7 @@ func (wm *SWorkerManager) DetachedWorkerCount() int { type SWorkerManagerStates struct { Name string Backlog int + QueueCnt int MaxWorkerCnt int ActiveWorkerCnt int DetachWorkerCnt int @@ -224,7 +225,8 @@ func (wm *SWorkerManager) getState() SWorkerManagerStates { state := SWorkerManagerStates{} state.Name = wm.name - state.Backlog = wm.queue.Size() + state.Backlog = wm.backlog + state.QueueCnt = wm.queue.Size() state.MaxWorkerCnt = wm.workerCount state.ActiveWorkerCnt = wm.activeWorker.size() state.DetachWorkerCnt = wm.detachedWorker.size()