diff options
| author | Attila Gazso <attila.gazso@prezi.com> | 2018-10-18 01:22:37 +0800 |
|---|---|---|
| committer | Viktor Trón <viktor.tron@gmail.com> | 2018-10-18 01:22:37 +0800 |
| commit | cdf5982cfca2cd7d5fea85c226af5e48fde837df (patch) | |
| tree | adcd4a5b24d285ca72174c085bd17a898b628721 /swarm/network/stream/snapshot_sync_test.go | |
| parent | 4e693ad5a6f118dcf4f3586938c17fc8ef5822b5 (diff) | |
| download | dexon-cdf5982cfca2cd7d5fea85c226af5e48fde837df.tar dexon-cdf5982cfca2cd7d5fea85c226af5e48fde837df.tar.gz dexon-cdf5982cfca2cd7d5fea85c226af5e48fde837df.tar.bz2 dexon-cdf5982cfca2cd7d5fea85c226af5e48fde837df.tar.lz dexon-cdf5982cfca2cd7d5fea85c226af5e48fde837df.tar.xz dexon-cdf5982cfca2cd7d5fea85c226af5e48fde837df.tar.zst dexon-cdf5982cfca2cd7d5fea85c226af5e48fde837df.zip | |
swarm: Lightnode mode: disable sync, retrieve, subscription (#17899)
* swarm: Lightnode mode: disable sync, retrieve, subscription
* swarm/network/stream: assign error and check in one line
* swarm: restructured RegistryOption initializing
* swarm: empty commit to retrigger CI build
* swarm/network/stream: Added comments explaining RegistryOptions
Diffstat (limited to 'swarm/network/stream/snapshot_sync_test.go')
| -rw-r--r-- | swarm/network/stream/snapshot_sync_test.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/swarm/network/stream/snapshot_sync_test.go b/swarm/network/stream/snapshot_sync_test.go index 0d5849487..96e92c5cf 100644 --- a/swarm/network/stream/snapshot_sync_test.go +++ b/swarm/network/stream/snapshot_sync_test.go @@ -166,6 +166,7 @@ func streamerFunc(ctx *adapters.ServiceContext, bucket *sync.Map) (s node.Servic r := NewRegistry(addr.ID(), delivery, netStore, state.NewInmemoryStore(), &RegistryOptions{ DoSync: true, + DoServeRetrieve: true, SyncUpdateDelay: 3 * time.Second, }) @@ -358,7 +359,10 @@ func testSyncingViaDirectSubscribe(t *testing.T, chunkCount int, nodeCount int) delivery := NewDelivery(kad, netStore) netStore.NewNetFetcherFunc = network.NewFetcherFactory(dummyRequestFromPeers, true).New - r := NewRegistry(addr.ID(), delivery, netStore, state.NewInmemoryStore(), nil) + r := NewRegistry(addr.ID(), delivery, netStore, state.NewInmemoryStore(), &RegistryOptions{ + DoServeRetrieve: true, + DoSync: true, + }) bucket.Store(bucketKeyRegistry, r) fileStore := storage.NewFileStore(netStore, storage.NewFileStoreParams()) |