TrueCloudLab/neoneo-go
7
0
Fork 2
Code Issues Pull requests Projects Releases Packages Wiki Activity

[Stall]

Browse source 
Change seconds to milliseconds in test
This commit is contained in:
BlockChainDev 2019-03-18 21:33:07 +00:00
parent a2bdc076d2
commit 9951f04099
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
pkg/peer/stall/stall_test.go
View file

@ -12,8 +12,8 @@ import (
func TestAddRemoveMessage(t *testing.T) { func TestAddRemoveMessage(t *testing.T) {
responseTime := 2 * time.Second responseTime := 2 * time.Millisecond
tickerInterval := 1 * time.Second tickerInterval := 1 * time.Millisecond
d := NewDetector(responseTime, tickerInterval) d := NewDetector(responseTime, tickerInterval)
d.AddMessage(command.GetAddr) d.AddMessage(command.GetAddr)
@ -51,15 +51,15 @@ loop:
} }
func TestDeadlineWorks(t *testing.T) { func TestDeadlineWorks(t *testing.T) {
responseTime := 2 * time.Second responseTime := 2 * time.Millisecond
tickerInterval := 1 * time.Second tickerInterval := 1 * time.Millisecond
d := NewDetector(responseTime, tickerInterval) d := NewDetector(responseTime, tickerInterval)
mp := mockPeer{online: true, detector: d, lock: new(sync.RWMutex)} mp := mockPeer{online: true, detector: d, lock: new(sync.RWMutex)}
go mp.loop() go mp.loop()
d.AddMessage(command.GetAddr) d.AddMessage(command.GetAddr)
time.Sleep(responseTime + 1*time.Second) time.Sleep(responseTime + 1*time.Millisecond)
k := make(map[command.Type]time.Time) k := make(map[command.Type]time.Time)
d.lock.RLock() d.lock.RLock()
@ -70,12 +70,12 @@ func TestDeadlineWorks(t *testing.T) {
mp.lock.RUnlock() mp.lock.RUnlock()
} }
func TestDeadlineShouldNotBeEmpty(t *testing.T) { func TestDeadlineShouldNotBeEmpty(t *testing.T) {
responseTime := 10 * time.Second responseTime := 10 * time.Millisecond
tickerInterval := 1 * time.Second tickerInterval := 1 * time.Millisecond
d := NewDetector(responseTime, tickerInterval) d := NewDetector(responseTime, tickerInterval)
d.AddMessage(command.GetAddr) d.AddMessage(command.GetAddr)
time.Sleep(1 * time.Second) time.Sleep(1 * time.Millisecond)
k := make(map[command.Type]time.Time) k := make(map[command.Type]time.Time)
d.lock.RLock() d.lock.RLock()