sbft: don't act as primary if we're not active in view

Change-Id: Icab2222cae589f22e7e63050fe043ae56d5ea737
Signed-off-by: Simon Schubert <[email protected]>

Author: corecode

orderer/sbft/simplebft/request.go

@@ -24,7 +24,7 @@ func (s *SBFT) Request(req []byte) {
 }
 
 func (s *SBFT) handleRequest(req *Request, src uint64) {
-	if s.isPrimary() {
+	if s.isPrimary() && s.activeView {
 		s.batch = append(s.batch, req)
 		if s.batchSize() >= s.config.BatchSizeBytes {
 			s.maybeSendNextBatch()
@@ -56,7 +56,7 @@ func (s *SBFT) maybeSendNextBatch() {
 		s.batchTimer = nil
 	}
 
-	if !s.isPrimary() {
+	if !s.isPrimary() || !s.activeView {
 		return
 	}
 

orderer/sbft/simplebft/simplebft_test.go

@@ -352,6 +352,7 @@ func TestRestart(t *testing.T) {
 	for _, r := range repls {
 		r.sendViewChange()
 	}
+	sys.Run()
 
 	r1 := []byte{1, 2, 3}
 	repls[0].Request(r1)
@@ -429,6 +430,7 @@ func TestRestartAfterPrepare(t *testing.T) {
 	for _, r := range repls {
 		r.sendViewChange()
 	}
+	sys.Run()
 
 	r1 := []byte{1, 2, 3}
 	repls[0].Request(r1)
@@ -497,6 +499,7 @@ func TestRestartAfterCommit(t *testing.T) {
 	for _, r := range repls {
 		r.sendViewChange()
 	}
+	sys.Run()
 
 	r1 := []byte{1, 2, 3}
 	repls[0].Request(r1)
@@ -565,6 +568,7 @@ func TestRestartAfterCheckpoint(t *testing.T) {
 	for _, r := range repls {
 		r.sendViewChange()
 	}
+	sys.Run()
 
 	r1 := []byte{1, 2, 3}
 	repls[0].Request(r1)
@@ -653,6 +657,7 @@ func TestErroneousViewChange(t *testing.T) {
 	for _, r := range repls {
 		r.sendViewChange()
 	}
+	sys.Run()
 
 	r1 := []byte{1, 2, 3}
 	repls[0].Request(r1)
@@ -717,6 +722,7 @@ func TestRestartMissedViewChange(t *testing.T) {
 			r.sendViewChange()
 		}
 	}
+	sys.Run()
 
 	r2 := []byte{3, 1, 2}
 	repls[1].Request(r2)