diff options
Diffstat (limited to 'cmd/rr/http')
| -rw-r--r-- | cmd/rr/http/reload.go | 29 | ||||
| -rw-r--r-- | cmd/rr/http/workers.go | 12 |
2 files changed, 21 insertions, 20 deletions
diff --git a/cmd/rr/http/reload.go b/cmd/rr/http/reload.go index 5814cc4a..06149065 100644 --- a/cmd/rr/http/reload.go +++ b/cmd/rr/http/reload.go @@ -24,7 +24,6 @@ import ( "errors" "github.com/spf13/cobra" rr "github.com/spiral/roadrunner/cmd/rr/cmd" - "github.com/spiral/roadrunner/rpc" ) func init() { @@ -39,18 +38,20 @@ func reloadHandler(cmd *cobra.Command, args []string) error { if !rr.Container.Has("rpc") { return errors.New("RPC service is not configured") } - - client, err := rr.Container.Get("rpc").(*rpc.Service).Client() - if err != nil { - return err - } - defer client.Close() - - var r string - if err := client.Call("http.Reset", true, &r); err != nil { - return err - } - - rr.Logger.Info("http.service: restarting worker pool") return nil + + //todo: change + //client, err := rr.Container.Get("rpc").(*rpc.Service).Client() + //if err != nil { + // return err + //} + //defer client.Close() + // + //var r string + //if err := client.Call("http.Reset", true, &r); err != nil { + // return err + //} + // + //rr.Logger.Info("http.service: restarting worker pool") + //return nil } diff --git a/cmd/rr/http/workers.go b/cmd/rr/http/workers.go index 6d74a412..c9aa5b04 100644 --- a/cmd/rr/http/workers.go +++ b/cmd/rr/http/workers.go @@ -24,7 +24,6 @@ import ( "errors" "github.com/spf13/cobra" rr "github.com/spiral/roadrunner/cmd/rr/cmd" - "github.com/spiral/roadrunner/rpc" ) func init() { @@ -40,11 +39,12 @@ func workersHandler(cmd *cobra.Command, args []string) error { return errors.New("RPC service is not configured") } - client, err := rr.Container.Get("rpc").(*rpc.Service).Client() - if err != nil { - return err - } - defer client.Close() + //todo: change + //client, err := rr.Container.Get("rpc").(*rpc.Service).Client() + //if err != nil { + // return err + //} + //defer client.Close() //var r http.WorkerList //if err := client.Call("http.Workers", true, &r); err != nil { |