|
|
@ -19,11 +19,9 @@ package bloombits |
|
|
|
import ( |
|
|
|
import ( |
|
|
|
"bytes" |
|
|
|
"bytes" |
|
|
|
"math/big" |
|
|
|
"math/big" |
|
|
|
"math/rand" |
|
|
|
|
|
|
|
"sync" |
|
|
|
"sync" |
|
|
|
"sync/atomic" |
|
|
|
"sync/atomic" |
|
|
|
"testing" |
|
|
|
"testing" |
|
|
|
"time" |
|
|
|
|
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
// Tests that the scheduler can deduplicate and forward retrieval requests to
|
|
|
|
// Tests that the scheduler can deduplicate and forward retrieval requests to
|
|
|
@ -53,7 +51,6 @@ func testScheduler(t *testing.T, clients int, fetchers int, requests int) { |
|
|
|
defer fetchPend.Done() |
|
|
|
defer fetchPend.Done() |
|
|
|
|
|
|
|
|
|
|
|
for req := range fetch { |
|
|
|
for req := range fetch { |
|
|
|
time.Sleep(time.Duration(rand.Intn(int(100 * time.Microsecond)))) |
|
|
|
|
|
|
|
atomic.AddUint32(&delivered, 1) |
|
|
|
atomic.AddUint32(&delivered, 1) |
|
|
|
|
|
|
|
|
|
|
|
f.deliver([]uint64{ |
|
|
|
f.deliver([]uint64{ |
|
|
|