1 files changed, 0 insertions, 140 deletions
diff --git a/core/test/stopper.go b/core/test/stopper.go
deleted file mode 100644
index 2ba31d3..0000000
--- a/core/test/stopper.go
+++ /dev/null
@@ -1,140 +0,0 @@
-// Copyright 2018 The dexon-consensus Authors
-// This file is part of the dexon-consensus library.
-//
-// The dexon-consensus library is free software: you can redistribute it
-// and/or modify it under the terms of the GNU Lesser General Public License as
-// published by the Free Software Foundation, either version 3 of the License,
-// or (at your option) any later version.
-//
-// The dexon-consensus library is distributed in the hope that it will be
-// useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser
-// General Public License for more details.
-//
-// You should have received a copy of the GNU Lesser General Public License
-// along with the dexon-consensus library. If not, see
-// <http://www.gnu.org/licenses/>.
-
-package test
-
-import (
-	"sync"
-
-	"github.com/dexon-foundation/dexon-consensus/core/db"
-	"github.com/dexon-foundation/dexon-consensus/core/types"
-)
-
-// StopByConfirmedBlocks would make sure each nodes confirms
-// at least X blocks proposed by itself.
-type StopByConfirmedBlocks struct {
-	apps               map[types.NodeID]*App
-	dbs                map[types.NodeID]db.Database
-	lastCheckDelivered map[types.NodeID]int
-	confirmedBlocks    map[types.NodeID]int
-	blockCount         int
-	lock               sync.Mutex
-}
-
-// NewStopByConfirmedBlocks construct an StopByConfirmedBlocks instance.
-func NewStopByConfirmedBlocks(
-	blockCount int,
-	apps map[types.NodeID]*App,
-	dbs map[types.NodeID]db.Database) *StopByConfirmedBlocks {
-	confirmedBlocks := make(map[types.NodeID]int)
-	for nID := range apps {
-		confirmedBlocks[nID] = 0
-	}
-	return &StopByConfirmedBlocks{
-		apps:               apps,
-		dbs:                dbs,
-		lastCheckDelivered: make(map[types.NodeID]int),
-		confirmedBlocks:    confirmedBlocks,
-		blockCount:         blockCount,
-	}
-}
-
-// ShouldStop implements Stopper interface.
-func (s *StopByConfirmedBlocks) ShouldStop(nID types.NodeID) bool {
-	s.lock.Lock()
-	defer s.lock.Unlock()
-	// Accumulate confirmed blocks proposed by this node in this round.
-	lastChecked := s.lastCheckDelivered[nID]
-	currentConfirmedBlocks := s.confirmedBlocks[nID]
-	dbInst := s.dbs[nID]
-	s.apps[nID].WithLock(func(app *App) {
-		for _, h := range app.DeliverSequence[lastChecked:] {
-			b, err := dbInst.GetBlock(h)
-			if err != nil {
-				panic(err)
-			}
-			if b.ProposerID == nID {
-				currentConfirmedBlocks++
-			}
-		}
-		s.lastCheckDelivered[nID] = len(app.DeliverSequence)
-	})
-	s.confirmedBlocks[nID] = currentConfirmedBlocks
-	// Check if all nodes confirmed at least 'blockCount' blocks.
-	for _, v := range s.confirmedBlocks {
-		if v < s.blockCount {
-			return false
-		}
-	}
-	return true
-}
-
-// StopByRound would make sure at least one block at round R is delivered
-// at each node.
-type StopByRound struct {
-	untilRound         uint64
-	currentRounds      map[types.NodeID]uint64
-	lastCheckDelivered map[types.NodeID]int
-	apps               map[types.NodeID]*App
-	dbs                map[types.NodeID]db.Database
-	lock               sync.Mutex
-}
-
-// NewStopByRound constructs an StopByRound instance.
-func NewStopByRound(
-	round uint64,
-	apps map[types.NodeID]*App,
-	dbs map[types.NodeID]db.Database) *StopByRound {
-	return &StopByRound{
-		untilRound:         round,
-		currentRounds:      make(map[types.NodeID]uint64),
-		lastCheckDelivered: make(map[types.NodeID]int),
-		apps:               apps,
-		dbs:                dbs,
-	}
-}
-
-// ShouldStop implements Stopper interface.
-func (s *StopByRound) ShouldStop(nID types.NodeID) bool {
-	s.lock.Lock()
-	defer s.lock.Unlock()
-	// Cache latest round of this node.
-	if curRound := s.currentRounds[nID]; curRound < s.untilRound {
-		lastChecked := s.lastCheckDelivered[nID]
-		dbInst := s.dbs[nID]
-		s.apps[nID].WithLock(func(app *App) {
-			for _, h := range app.DeliverSequence[lastChecked:] {
-				b, err := dbInst.GetBlock(h)
-				if err != nil {
-					panic(err)
-				}
-				if b.Position.Round > curRound {
-					curRound = b.Position.Round
-				}
-			}
-			s.lastCheckDelivered[nID] = len(app.DeliverSequence)
-			s.currentRounds[nID] = curRound
-		})
-	}
-	// Check if latest round on each node is later than untilRound.
-	for _, round := range s.currentRounds {
-		if round < s.untilRound {
-			return false
-		}
-	}
-	return true
-}