Remove unnecessary mutex when adding worker to watcherv2.0.0-alpha30

4 files changed, 2 insertions, 7 deletions

diff --git a/Makefile b/Makefile
index 1b903d6f..54744223 100755
--- a/Makefile
+++ b/Makefile
@@ -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
diff --git a/go.mod b/go.mod
index cc86f14e..82d01762 100755
--- a/go.mod
+++ b/go.mod
@@ -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
diff --git a/go.sum b/go.sum
index fb358b24..2479839d 100755
--- a/go.sum
+++ b/go.sum
@@ -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)
 	}()