diff options
| author | Maran <maran.hidskes@gmail.com> | 2014-05-05 21:15:14 +0800 |
|---|---|---|
| committer | Maran <maran.hidskes@gmail.com> | 2014-05-05 21:15:14 +0800 |
| commit | a4ca9927abc774fe524635a38d2f3bf2c4831278 (patch) | |
| tree | 50f576980d53087e951b93a1cb4acfd8a41b2082 /etherpc/server.go | |
| parent | 9b1f11695d544b99ba0b7ddedc4ac561a68d8197 (diff) | |
| download | dexon-a4ca9927abc774fe524635a38d2f3bf2c4831278.tar dexon-a4ca9927abc774fe524635a38d2f3bf2c4831278.tar.gz dexon-a4ca9927abc774fe524635a38d2f3bf2c4831278.tar.bz2 dexon-a4ca9927abc774fe524635a38d2f3bf2c4831278.tar.lz dexon-a4ca9927abc774fe524635a38d2f3bf2c4831278.tar.xz dexon-a4ca9927abc774fe524635a38d2f3bf2c4831278.tar.zst dexon-a4ca9927abc774fe524635a38d2f3bf2c4831278.zip | |
Renamed etherpc to ethrpc
Diffstat (limited to 'etherpc/server.go')
| -rw-r--r-- | etherpc/server.go | 62 |
1 files changed, 0 insertions, 62 deletions
diff --git a/etherpc/server.go b/etherpc/server.go deleted file mode 100644 index 0eb229536..000000000 --- a/etherpc/server.go +++ /dev/null @@ -1,62 +0,0 @@ -package etherpc - -import ( - "github.com/ethereum/eth-go/ethpub" - "github.com/ethereum/eth-go/ethutil" - "net" - "net/rpc" - "net/rpc/jsonrpc" -) - -type JsonRpcServer struct { - quit chan bool - listener net.Listener - ethp *ethpub.PEthereum -} - -func (s *JsonRpcServer) exitHandler() { -out: - for { - select { - case <-s.quit: - s.listener.Close() - break out - } - } - - ethutil.Config.Log.Infoln("[JSON] Shutdown JSON-RPC server") -} - -func (s *JsonRpcServer) Stop() { - close(s.quit) -} - -func (s *JsonRpcServer) Start() { - ethutil.Config.Log.Infoln("[JSON] Starting JSON-RPC server") - go s.exitHandler() - rpc.Register(&EthereumApi{ethp: s.ethp}) - rpc.HandleHTTP() - - for { - conn, err := s.listener.Accept() - if err != nil { - ethutil.Config.Log.Infoln("[JSON] Error starting JSON-RPC:", err) - break - } - ethutil.Config.Log.Debugln("[JSON] Incoming request.") - go jsonrpc.ServeConn(conn) - } -} - -func NewJsonRpcServer(ethp *ethpub.PEthereum) *JsonRpcServer { - l, err := net.Listen("tcp", ":30304") - if err != nil { - ethutil.Config.Log.Infoln("Error starting JSON-RPC") - } - - return &JsonRpcServer{ - listener: l, - quit: make(chan bool), - ethp: ethp, - } -} |