shorter peer queue test
Juan Batiz-Benet committed
Dec 10, 2014 at 21:03 UTC
0f12f4b2453989fb0eb3142e7aaac4b185dade26
1 file changed
+9
-6
peer/queue/queue_test.go
+9
-6
@@ -74,7 +74,15 @@ func newPeerTime(t time.Time) peer.Peer {
74
}
75
76
func TestSyncQueue(t *testing.T) {
77
+ tickT := time.Microsecond * 100
78
+ max := 10000
79
+ consumerN := 10
80
+ countsIn := make([]int, consumerN*2)
81
+ countsOut := make([]int, consumerN)
82
+
83
if testing.Short() {
84
+ tickT = time.Microsecond * 50
85
+ max = 1000
86
t.SkipNow()
87
}
88
ctx := context.Background()
@@ -83,15 +91,10 @@ func TestSyncQueue(t *testing.T) {
91
cq := NewChanQueue(ctx, pq)
92
wg := sync.WaitGroup{}
93
86
- max := 10000
87
- consumerN := 10
88
- countsIn := make([]int, consumerN*2)
89
- countsOut := make([]int, consumerN)
90
-
94
produce := func(p int) {
95
defer wg.Done()
96
94
- tick := time.Tick(time.Microsecond * 100)
97
+ tick := time.Tick(tickT)
98
for i := 0; i < max; i++ {
99
select {
100
case tim := <-tick: