summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-07-08 15:42:17 +0300
committerValery Piashchynski <[email protected]>2021-07-08 15:42:17 +0300
commit5f84c5d5709cff5984a5859651a0bbb1c55fcb0f (patch)
tree673a3d327cf6d19841a03014c77e5d3cd50bdcdf
parenteab69b1fdb660973b4c50387d92a79f3662a75fb (diff)
Remove duplicated test-helpers
Signed-off-by: Valery Piashchynski <[email protected]>
-rw-r--r--plugins/jobs/plugin.go20
1 files changed, 1 insertions, 19 deletions
diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go
index 9a551d71..51da9421 100644
--- a/plugins/jobs/plugin.go
+++ b/plugins/jobs/plugin.go
@@ -103,27 +103,9 @@ func (p *Plugin) Serve() chan error { //nolint:gocognit
select {
case <-tt.C:
fmt.Printf("---> rate is: %d\n", atomic.LoadUint64(&rate))
- atomic.StoreUint64(&rate, 0)
- }
- }
- }()
-
- go func() {
- tt := time.NewTicker(time.Millisecond * 1000)
- for { //nolint:gosimple
- select {
- case <-tt.C:
fmt.Printf("---> goroutines: %d\n", runtime.NumGoroutine())
- }
- }
- }()
-
- go func() {
- tt := time.NewTicker(time.Millisecond * 1000)
- for { //nolint:gosimple
- select {
- case <-tt.C:
fmt.Printf("---> curr len: %d\n", p.queue.Len())
+ atomic.StoreUint64(&rate, 0)
}
}
}()