From 5183631f17a394cc1f1a6c7003c2a3b43fd6cbc2 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Fri, 3 Jun 2016 09:18:02 -0700 Subject: [PATCH] rafthttp: report error to correct chan --- rafthttp/stream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rafthttp/stream.go b/rafthttp/stream.go index 12c255440..07bc1c204 100644 --- a/rafthttp/stream.go +++ b/rafthttp/stream.go @@ -279,7 +279,7 @@ type streamReader struct { func (r *streamReader) start() { r.stopc = make(chan struct{}) r.done = make(chan struct{}) - if r.errorc != nil { + if r.errorc == nil { r.errorc = r.tr.ErrorC }