From 5eda45ece6c7597c573fdc5245f7684ba0e34025 Mon Sep 17 00:00:00 2001
From: Yicheng Qin <qycqycqycqycqyc@gmail.com>
Date: Sat, 24 Oct 2015 20:25:56 -0700
Subject: [PATCH] Revert "rafthttp: fix wrong return in pipeline.handle"

---
 rafthttp/pipeline.go      |  2 +-
 rafthttp/pipeline_test.go | 22 ----------------------
 2 files changed, 1 insertion(+), 23 deletions(-)

diff --git a/rafthttp/pipeline.go b/rafthttp/pipeline.go
index 305225fd2..90b747cdd 100644
--- a/rafthttp/pipeline.go
+++ b/rafthttp/pipeline.go
@@ -106,7 +106,7 @@ func (p *pipeline) handle() {
 			if isMsgSnap(m) {
 				p.r.ReportSnapshot(m.To, raft.SnapshotFailure)
 			}
-			continue
+			return
 		}
 
 		p.status.activate()
diff --git a/rafthttp/pipeline_test.go b/rafthttp/pipeline_test.go
index 74cdb1565..86e5bf9f7 100644
--- a/rafthttp/pipeline_test.go
+++ b/rafthttp/pipeline_test.go
@@ -52,28 +52,6 @@ func TestPipelineSend(t *testing.T) {
 	}
 }
 
-// TestPipelineKeepSending tests that pipeline could keep sending messages
-// if there are messages in msgc channel.
-func TestPipelineKeepSending(t *testing.T) {
-	tr := &roundTripperRecorder{}
-	picker := mustNewURLPicker(t, []string{"http://localhost:2380"})
-	fs := &stats.FollowerStats{}
-	p := newPipeline(tr, picker, types.ID(2), types.ID(1), types.ID(1), newPeerStatus(types.ID(1)), fs, &fakeRaft{}, nil)
-
-	for i := 0; i < 50; i++ {
-		p.msgc <- raftpb.Message{Type: raftpb.MsgApp}
-	}
-	testutil.WaitSchedule()
-	p.stop()
-
-	// check it sends all messages out successfully
-	fs.Lock()
-	defer fs.Unlock()
-	if fs.Counts.Success != 50 {
-		t.Errorf("success = %d, want 50", fs.Counts.Success)
-	}
-}
-
 func TestPipelineExceedMaximumServing(t *testing.T) {
 	tr := newRoundTripperBlocker()
 	picker := mustNewURLPicker(t, []string{"http://localhost:2380"})