From bd450c1ba34a62b81dc92e244854cd8631d5136c Mon Sep 17 00:00:00 2001 From: Gyu-Ho Lee Date: Mon, 15 Aug 2016 10:40:12 -0700 Subject: [PATCH] rafthttp: use reportCriticalError, fix typo --- rafthttp/stream.go | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/rafthttp/stream.go b/rafthttp/stream.go index 79de4f53c..5eb68a90c 100644 --- a/rafthttp/stream.go +++ b/rafthttp/stream.go @@ -443,18 +443,14 @@ func (cr *streamReader) dial(t streamType) (io.ReadCloser, error) { case http.StatusGone: httputil.GracefulClose(resp) cr.picker.unreachable(u) - err := fmt.Errorf("the member has been permanently removed from the cluster") - select { - case cr.errorc <- err: - default: - } - return nil, err + reportCriticalError(errMemberRemoved, cr.errorc) + return nil, errMemberRemoved case http.StatusOK: return resp.Body, nil case http.StatusNotFound: httputil.GracefulClose(resp) cr.picker.unreachable(u) - return nil, fmt.Errorf("peer %s faild to fine local node %s", cr.peerID, cr.tr.ID) + return nil, fmt.Errorf("peer %s failed to find local node %s", cr.peerID, cr.tr.ID) case http.StatusPreconditionFailed: b, err := ioutil.ReadAll(resp.Body) if err != nil {