admin.stopRPC support added which stops the RPC HTTP listener

This commit is contained in:
Bas van Kervel
2015-04-16 12:56:51 +02:00
parent 205378016f
commit 57f93d25bd
3 changed files with 94 additions and 2 deletions

View File

@ -5,7 +5,6 @@ import (
"fmt"
"io"
"io/ioutil"
"net"
"net/http"
"github.com/ethereum/go-ethereum/logger"
@ -15,6 +14,7 @@ import (
)
var rpclogger = logger.NewLogger("RPC")
var rpclistener *ControllableTCPListener
const (
jsonrpcver = "2.0"
@ -22,11 +22,17 @@ const (
)
func Start(pipe *xeth.XEth, config RpcConfig) error {
l, err := net.Listen("tcp", fmt.Sprintf("%s:%d", config.ListenAddress, config.ListenPort))
if rpclistener != nil { // listener already running
glog.Infoln("RPC listener already running")
return fmt.Errorf("RPC already running on %s", rpclistener.Addr().String())
}
l, err := NewControllableTCPListener(fmt.Sprintf("%s:%d", config.ListenAddress, config.ListenPort))
if err != nil {
rpclogger.Errorf("Can't listen on %s:%d: %v", config.ListenAddress, config.ListenPort, err)
return err
}
rpclistener = l
var handler http.Handler
if len(config.CorsDomain) > 0 {
@ -45,6 +51,17 @@ func Start(pipe *xeth.XEth, config RpcConfig) error {
return nil
}
func Stop() error {
if rpclistener == nil { // listener not running
glog.Infoln("RPC listener not running")
return nil
}
rpclistener.Stop()
rpclistener = nil
return nil
}
// JSONRPC returns a handler that implements the Ethereum JSON-RPC API.
func JSONRPC(pipe *xeth.XEth) http.Handler {
api := NewEthereumApi(pipe)