summaryrefslogtreecommitdiff
path: root/rpc/service.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-06-07 17:56:24 +0300
committerWolfy-J <[email protected]>2018-06-07 17:56:24 +0300
commit5a2dff38591c90cb1501dc09fea14e1a59d0cb52 (patch)
tree9a52dc0309d1f30b20560ae9f796712fb6337d73 /rpc/service.go
parentef78372ec1570571a1af6b1dc9847f7cc72fdc37 (diff)
rcp tests
Diffstat (limited to 'rpc/service.go')
-rw-r--r--rpc/service.go4
1 files changed, 3 insertions, 1 deletions
diff --git a/rpc/service.go b/rpc/service.go
index ff5b85c8..d6e1bfa1 100644
--- a/rpc/service.go
+++ b/rpc/service.go
@@ -21,6 +21,8 @@ type Service struct {
// WithConfig must return Service instance configured with the given environment. Must return error in case of
// misconfiguration, might return nil as Service if Service is not enabled.
func (s *Service) WithConfig(cfg service.Config, reg service.Registry) (service.Service, error) {
+ // todo: logging ?
+
config := &config{}
if err := cfg.Unmarshal(config); err != nil {
return nil, err
@@ -57,10 +59,10 @@ func (s *Service) Serve() error {
default:
conn, err := ln.Accept()
if err != nil {
+ conn.Close()
continue
}
- s.rpc.Accept(ln)
go s.rpc.ServeCodec(goridge.NewCodec(conn))
}
}