diff options
Diffstat (limited to 'pkg/rpcserver')
| -rw-r--r-- | pkg/rpcserver/runner.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/pkg/rpcserver/runner.go b/pkg/rpcserver/runner.go index ea45aa89a..06fa6a581 100644 --- a/pkg/rpcserver/runner.go +++ b/pkg/rpcserver/runner.go @@ -164,7 +164,10 @@ func (runner *Runner) ConnectionLoop() error { } } if len(runner.requests) == 0 { - // The runner has not requests at all, so don't wait to receive anything from it. + if !runner.Alive() { + return nil + } + // The runner has no new requests, so don't wait to receive anything from it. time.Sleep(10 * time.Millisecond) continue } |