1 files changed, 0 insertions, 176 deletions
diff --git a/core/test/scheduler_test.go b/core/test/scheduler_test.go
deleted file mode 100644
index 4c39f95..0000000
--- a/core/test/scheduler_test.go
+++ /dev/null
@@ -1,176 +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"
-	"testing"
-	"time"
-
-	"github.com/dexon-foundation/dexon-consensus/common"
-	"github.com/dexon-foundation/dexon-consensus/core/types"
-	"github.com/stretchr/testify/suite"
-)
-
-type SchedulerTestSuite struct {
-	suite.Suite
-}
-
-type simpleStopper struct {
-	lock         sync.Mutex
-	touched      map[types.NodeID]int
-	touchedCount int
-}
-
-func newSimpleStopper(
-	nodes []types.NodeID, touchedCount int) *simpleStopper {
-
-	touched := make(map[types.NodeID]int)
-	for _, nID := range nodes {
-		touched[nID] = 0
-	}
-	return &simpleStopper{
-		touched:      touched,
-		touchedCount: touchedCount,
-	}
-}
-
-func (stopper *simpleStopper) ShouldStop(nID types.NodeID) bool {
-	stopper.lock.Lock()
-	defer stopper.lock.Unlock()
-
-	stopper.touched[nID] = stopper.touched[nID] + 1
-	for _, count := range stopper.touched {
-		if count < stopper.touchedCount {
-			return false
-		}
-	}
-	return true
-}
-
-type simpleHandler struct {
-	count int
-	nID   types.NodeID
-}
-
-func (handler *simpleHandler) Handle(e *Event) (events []*Event) {
-	if e.NodeID == handler.nID {
-		handler.count++
-	}
-	return
-}
-
-type fixedLatencyHandler struct {
-	nID types.NodeID
-}
-
-func (handler *fixedLatencyHandler) Handle(e *Event) (events []*Event) {
-	// Simulate execution time.
-	time.Sleep(500 * time.Millisecond)
-	return []*Event{&Event{
-		NodeID: handler.nID,
-		Time:   e.Time.Add(800 * time.Millisecond),
-	}}
-}
-
-func (s *SchedulerTestSuite) TestEventSequence() {
-	// This test case makes sure the event sequence is correctly increment
-	// by their timestamps in 'Time' field.
-	var (
-		sch = NewScheduler(nil)
-		req = s.Require()
-	)
-
-	req.NotNil(sch)
-	now := time.Now()
-	req.Nil(sch.Seed(&Event{Time: now.Add(100 * time.Second), Payload: 1}))
-	req.Nil(sch.Seed(&Event{Time: now.Add(99 * time.Second), Payload: 2}))
-	req.Nil(sch.Seed(&Event{Time: now.Add(98 * time.Second), Payload: 3}))
-	req.Nil(sch.Seed(&Event{Time: now.Add(97 * time.Second), Payload: 4}))
-	req.Nil(sch.Seed(&Event{Time: now.Add(96 * time.Second), Payload: 5}))
-
-	req.Equal(sch.nextTick().Payload.(int), 5)
-	req.Equal(sch.nextTick().Payload.(int), 4)
-	req.Equal(sch.nextTick().Payload.(int), 3)
-	req.Equal(sch.nextTick().Payload.(int), 2)
-	req.Equal(sch.nextTick().Payload.(int), 1)
-	req.Nil(sch.nextTick())
-}
-
-func (s *SchedulerTestSuite) TestBasicRound() {
-	// This test case makes sure these facts:
-	//  - event is dispatched by NodeID attached to each handler.
-	//  - stopper can stop the execution when condition is met.
-	var (
-		req      = s.Require()
-		nodes    = GenerateRandomNodeIDs(3)
-		stopper  = newSimpleStopper(nodes, 2)
-		sch      = NewScheduler(stopper)
-		handlers = make(map[types.NodeID]*simpleHandler)
-	)
-
-	for _, nID := range nodes {
-		handler := &simpleHandler{nID: nID}
-		handlers[nID] = handler
-		sch.RegisterEventHandler(nID, handler)
-		req.Nil(sch.Seed(&Event{NodeID: nID}))
-		req.Nil(sch.Seed(&Event{NodeID: nID}))
-	}
-	sch.Run(10)
-	// Verify result.
-	for _, h := range handlers {
-		req.Equal(h.count, 2)
-	}
-}
-
-func (s *SchedulerTestSuite) TestChildEvent() {
-	// This test case makes sure these fields of child events are
-	// assigned correctly.
-	var (
-		req     = s.Require()
-		nID     = types.NodeID{Hash: common.NewRandomHash()}
-		stopper = newSimpleStopper(types.NodeIDs{nID}, 3)
-		handler = &fixedLatencyHandler{nID: nID}
-		sch     = NewScheduler(stopper)
-	)
-
-	sch.RegisterEventHandler(nID, handler)
-	req.Nil(sch.Seed(&Event{
-		NodeID: nID,
-		Time:   time.Now().UTC(),
-	}))
-	sch.Run(1)
-	// Verify result.
-	history := sch.CloneExecutionHistory()
-	req.Len(history, 3)
-	curEvent := history[0]
-	for _, e := range history[1:] {
-		// Make sure the time difference between events are more than
-		// 1.3 second.
-		req.True(e.Time.Sub(curEvent.Time) >= 1300*time.Millisecond)
-		// Make sure ParentTime field is set and is equal to parent event's
-		// time.
-		req.NotEqual(-1, e.ParentHistoryIndex)
-		req.Equal(e.ParentHistoryIndex, curEvent.HistoryIndex)
-		curEvent = e
-	}
-}
-
-func TestScheduler(t *testing.T) {
-	suite.Run(t, new(SchedulerTestSuite))
-}