diff options
| author | Wolfy-J <[email protected]> | 2020-10-25 16:20:21 +0300 |
|---|---|---|
| committer | Wolfy-J <[email protected]> | 2020-10-25 16:20:21 +0300 |
| commit | ee873d283ceb3d4aae3479e3db67efb133d320b5 (patch) | |
| tree | a8b44b74d99fca8957dde1e714cd53b6b4812c98 /plugins | |
| parent | 7d01ccafa5fe698a776aceb1511294283cededec (diff) | |
- massive update in roadrunner 2.0 abstractions
Diffstat (limited to 'plugins')
| -rw-r--r-- | plugins/rpc/rpc.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/plugins/rpc/rpc.go b/plugins/rpc/rpc.go index 294eeb7a..ad19df17 100644 --- a/plugins/rpc/rpc.go +++ b/plugins/rpc/rpc.go @@ -74,7 +74,10 @@ func (s *Service) Serve() chan error { select { case <-s.close: // log error - errCh <- ln.Close() + err := ln.Close() + if err != nil { + errCh <- errors.E(errors.Op("close RPC socket"), err) + } return default: conn, err := ln.Accept() |