diff options
| -rwxr-xr-x | Makefile | 1 | ||||
| -rwxr-xr-x | go.mod | 5 | ||||
| -rwxr-xr-x | go.sum | 1 | ||||
| -rwxr-xr-x | pkg/worker_watcher/worker_watcher.go | 2 |
4 files changed, 2 insertions, 7 deletions
@@ -24,6 +24,7 @@ uninstall: ## Uninstall locally installed RR rm -f /usr/local/bin/rr test: ## Run application tests + go clean -testcache go test -v -race -cover -tags=debug -covermode=atomic ./util go test -v -race -cover -tags=debug -covermode=atomic ./pkg/pipe go test -v -race -cover -tags=debug -covermode=atomic ./pkg/pool @@ -30,8 +30,3 @@ require ( go.uber.org/multierr v1.6.0 golang.org/x/sync v0.0.0-20201207232520-09787c993a3a ) - -//replace github.com/spiral/roadrunner-plugins/http v1.0.2 => ../roadrunner-plugins/http -//replace github.com/spiral/roadrunner-plugins/reload v1.0.0 => ../roadrunner-plugins/reload -//replace github.com/spiral/roadrunner-plugins/rpc v1.0.0 => ../roadrunner-plugins/rpc -//replace github.com/spiral/roadrunner-plugins/server v1.0.3 => ../roadrunner-plugins/server @@ -451,6 +451,7 @@ github.com/spiral/roadrunner-plugins/server v1.0.4 h1:i6QWbVM/gLnM3Tb/DDFSFpRnxc github.com/spiral/roadrunner-plugins/server v1.0.4/go.mod h1:XHfOZwvITuKyUwU79KaeMm8gU5AqzKQg0MCHJ7eBU5c= github.com/spiral/roadrunner/v2 v2.0.0-alpha26/go.mod h1:r7ojuHm9qCVbg4fKcqr4Aqk7VXqZ9YPefr1LOv7HNys= github.com/spiral/roadrunner/v2 v2.0.0-alpha28/go.mod h1:Uqtk/47S+qweVjSl4R9XVImEVZc3nMWku4yg3A+f18Q= +github.com/spiral/roadrunner/v2 v2.0.0-alpha29/go.mod h1:UgZgbE7yDce5X6rhA+Wzr6gxndtnTFBmjjZRoHbt1Zs= github.com/streadway/amqp v0.0.0-20190404075320-75d898a42a94/go.mod h1:AZpEONHx3DKn8O/DFsRAY58/XVQiIPMTMB1SddzLXVw= github.com/streadway/amqp v0.0.0-20190827072141-edfb9018d271/go.mod h1:AZpEONHx3DKn8O/DFsRAY58/XVQiIPMTMB1SddzLXVw= github.com/streadway/handy v0.0.0-20190108123426-d5acb3125c2a/go.mod h1:qNTQ5P5JnDBl6z3cMAg/SywNDC5ABu5ApDIw6lUbRmI= diff --git a/pkg/worker_watcher/worker_watcher.go b/pkg/worker_watcher/worker_watcher.go index 39d334ba..5c0882b0 100755 --- a/pkg/worker_watcher/worker_watcher.go +++ b/pkg/worker_watcher/worker_watcher.go @@ -294,8 +294,6 @@ func (ww *workerWatcher) wait(w worker.BaseProcess) { } func (ww *workerWatcher) addToWatch(wb worker.BaseProcess) { - ww.mutex.Lock() - defer ww.mutex.Unlock() go func() { ww.wait(wb) }() |