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/snapshot_sync_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/snapshot_sync_test.go')
| -rw-r--r-- | swarm/network/stream/snapshot_sync_test.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/swarm/network/stream/snapshot_sync_test.go b/swarm/network/stream/snapshot_sync_test.go index 96c37bddc..6b92c32ae 100644 --- a/swarm/network/stream/snapshot_sync_test.go +++ b/swarm/network/stream/snapshot_sync_test.go @@ -166,7 +166,7 @@ func streamerFunc(ctx *adapters.ServiceContext, bucket *sync.Map) (s node.Servic Retrieval: RetrievalDisabled, Syncing: SyncingAutoSubscribe, SyncUpdateDelay: 3 * time.Second, - }) + }, nil) bucket.Store(bucketKeyRegistry, r) @@ -360,7 +360,7 @@ func testSyncingViaDirectSubscribe(t *testing.T, chunkCount int, nodeCount int) r := NewRegistry(addr.ID(), delivery, netStore, state.NewInmemoryStore(), &RegistryOptions{ Retrieval: RetrievalDisabled, Syncing: SyncingRegisterOnly, - }) + }, nil) bucket.Store(bucketKeyRegistry, r) fileStore := storage.NewFileStore(netStore, storage.NewFileStoreParams()) |