diff options
| author | holisticode <holistic.computing@gmail.com> | 2018-11-16 06:41:19 +0800 |
|---|---|---|
| committer | Viktor Trón <viktor.tron@gmail.com> | 2018-11-16 06:41:19 +0800 |
| commit | ffe2fc3bc4d77ad3f503d2bc1cdd62eac8d03c5b (patch) | |
| tree | 5746d3737127f79b7fdb4cc58f72c6bb984b6b88 /swarm/network/stream/delivery_test.go | |
| parent | 324027640bcaf137b8c9e96bc26f0833711497af (diff) | |
| download | go-tangerine-ffe2fc3bc4d77ad3f503d2bc1cdd62eac8d03c5b.tar go-tangerine-ffe2fc3bc4d77ad3f503d2bc1cdd62eac8d03c5b.tar.gz go-tangerine-ffe2fc3bc4d77ad3f503d2bc1cdd62eac8d03c5b.tar.bz2 go-tangerine-ffe2fc3bc4d77ad3f503d2bc1cdd62eac8d03c5b.tar.lz go-tangerine-ffe2fc3bc4d77ad3f503d2bc1cdd62eac8d03c5b.tar.xz go-tangerine-ffe2fc3bc4d77ad3f503d2bc1cdd62eac8d03c5b.tar.zst go-tangerine-ffe2fc3bc4d77ad3f503d2bc1cdd62eac8d03c5b.zip | |
Swarm accounting (#18050)
* swarm: completed 1st phase of swap accounting
* swarm: swap accounting for swarm with p2p accounting
* swarm/swap: addressed PR comments
* swarm/swap: ignore ErrNotFound on stateStore.Get()
* swarm/swap: GetPeerBalance test; add TODO for chequebook API check
* swarm/network/stream: fix NewRegistry calls with new arguments
* swarm/swap: address @justelad's PR comments
Diffstat (limited to 'swarm/network/stream/delivery_test.go')
| -rw-r--r-- | swarm/network/stream/delivery_test.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/swarm/network/stream/delivery_test.go b/swarm/network/stream/delivery_test.go index 6b6025115..a6173a389 100644 --- a/swarm/network/stream/delivery_test.go +++ b/swarm/network/stream/delivery_test.go @@ -290,7 +290,7 @@ func TestRequestFromPeers(t *testing.T) { Peer: protocolsPeer, }, to) to.On(peer) - r := NewRegistry(addr.ID(), delivery, nil, nil, nil) + r := NewRegistry(addr.ID(), delivery, nil, nil, nil, nil) // an empty priorityQueue has to be created to prevent a goroutine being called after the test has finished sp := &Peer{ @@ -331,7 +331,7 @@ func TestRequestFromPeersWithLightNode(t *testing.T) { Peer: protocolsPeer, }, to) to.On(peer) - r := NewRegistry(addr.ID(), delivery, nil, nil, nil) + r := NewRegistry(addr.ID(), delivery, nil, nil, nil, nil) // an empty priorityQueue has to be created to prevent a goroutine being called after the test has finished sp := &Peer{ Peer: protocolsPeer, @@ -480,7 +480,7 @@ func testDeliveryFromNodes(t *testing.T, nodes, conns, chunkCount int, skipCheck SkipCheck: skipCheck, Syncing: SyncingDisabled, Retrieval: RetrievalEnabled, - }) + }, nil) bucket.Store(bucketKeyRegistry, r) fileStore := storage.NewFileStore(netStore, storage.NewFileStoreParams()) @@ -655,7 +655,7 @@ func benchmarkDeliveryFromNodes(b *testing.B, nodes, conns, chunkCount int, skip Syncing: SyncingDisabled, Retrieval: RetrievalDisabled, SyncUpdateDelay: 0, - }) + }, nil) fileStore := storage.NewFileStore(netStore, storage.NewFileStoreParams()) bucket.Store(bucketKeyFileStore, fileStore) |