added pool watcher capability

2 files changed, 10 insertions, 2 deletions

diff --git a/service/http/rpc.go b/service/http/rpc.go
index 3390a93d..7b38dece 100644
--- a/service/http/rpc.go
+++ b/service/http/rpc.go
@@ -20,7 +20,7 @@ func (rpc *rpcServer) Reset(reset bool, r *string) error {
 	}
 
 	*r = "OK"
-	return rpc.svc.rr.Reset()
+	return rpc.svc.Server().Reset()
 }
 
 // Workers returns list of active workers and their stats.
@@ -29,6 +29,6 @@ func (rpc *rpcServer) Workers(list bool, r *WorkerList) (err error) {
 		return errors.New("http server is not running")
 	}
 
-	r.Workers, err = util.ServerState(rpc.svc.rr)
+	r.Workers, err = util.ServerState(rpc.svc.Server())
 	return err
 }
diff --git a/service/http/service.go b/service/http/service.go
index 1a06a76a..47175ec3 100644
--- a/service/http/service.go
+++ b/service/http/service.go
@@ -118,6 +118,14 @@ func (s *Service) Stop() {
 	go s.http.Shutdown(context.Background())
 }
 
+// Server returns associated roadrunner server (if any).
+func (s *Service) Server() *roadrunner.Server {
+	s.mu.Lock()
+	defer s.mu.Unlock()
+
+	return s.rr
+}
+
 // ServeHTTP handles connection using set of middleware and rr PSR-7 server.
 func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	if s.https != nil && r.TLS == nil && s.cfg.SSL.Redirect {