summaryrefslogtreecommitdiff
path: root/pkg
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-04-29 10:25:45 +0300
committerGitHub <[email protected]>2021-04-29 10:25:45 +0300
commit7297e5f2fad841466024f8622da3e14b7874f989 (patch)
tree6c982f5ace059292ec7f748bd32fa6d1ca7719f0 /pkg
parenta6b755e344324505ea0d327ff12fb9eeae7d6dab (diff)
parent2812157be7a9c1411d02872f0b9fa567bcf7a9b7 (diff)
#646 feat(static): completely rework `static` plugin
#646 feat(static): completely rework `static` plugin
Diffstat (limited to 'pkg')
-rwxr-xr-xpkg/worker_watcher/worker_watcher.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/worker_watcher/worker_watcher.go b/pkg/worker_watcher/worker_watcher.go
index a6dfe43e..5aec4ee6 100755
--- a/pkg/worker_watcher/worker_watcher.go
+++ b/pkg/worker_watcher/worker_watcher.go
@@ -153,7 +153,7 @@ func (ww *workerWatcher) Allocate() error {
return nil
}
-// Remove
+// Remove worker
func (ww *workerWatcher) Remove(wb worker.BaseProcess) {
ww.Lock()
defer ww.Unlock()
@@ -172,7 +172,7 @@ func (ww *workerWatcher) Remove(wb worker.BaseProcess) {
}
}
-// O(1) operation
+// Push O(1) operation
func (ww *workerWatcher) Push(w worker.BaseProcess) {
if w.State().Value() != worker.StateReady {
_ = w.Kill()