diff options
| author | Viktor Trón <viktor.tron@gmail.com> | 2018-09-28 17:04:07 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-09-28 17:04:07 +0800 |
| commit | 0da3b17a112a75b54c8b3e5a2bf65a27a1c8c999 (patch) | |
| tree | a8ff65462707ec59c340a93b0a456657b2ab46d6 /swarm/network/stream/stream.go | |
| parent | d8d86692716158f9d514dcaa06b69f129d43c3d8 (diff) | |
| parent | 86f68cf04f5166848fd44150363866d7faa72b60 (diff) | |
| download | dexon-0da3b17a112a75b54c8b3e5a2bf65a27a1c8c999.tar dexon-0da3b17a112a75b54c8b3e5a2bf65a27a1c8c999.tar.gz dexon-0da3b17a112a75b54c8b3e5a2bf65a27a1c8c999.tar.bz2 dexon-0da3b17a112a75b54c8b3e5a2bf65a27a1c8c999.tar.lz dexon-0da3b17a112a75b54c8b3e5a2bf65a27a1c8c999.tar.xz dexon-0da3b17a112a75b54c8b3e5a2bf65a27a1c8c999.tar.zst dexon-0da3b17a112a75b54c8b3e5a2bf65a27a1c8c999.zip | |
Merge pull request #17747 from ethersphere/max-stream-peer-servers
Add stream peer servers limit
Diffstat (limited to 'swarm/network/stream/stream.go')
| -rw-r--r-- | swarm/network/stream/stream.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/swarm/network/stream/stream.go b/swarm/network/stream/stream.go index 65b8dff5a..1eda06c6a 100644 --- a/swarm/network/stream/stream.go +++ b/swarm/network/stream/stream.go @@ -60,6 +60,7 @@ type Registry struct { delivery *Delivery intervalsStore state.Store doRetrieve bool + maxPeerServers int } // RegistryOptions holds optional values for NewRegistry constructor. @@ -68,6 +69,7 @@ type RegistryOptions struct { DoSync bool DoRetrieve bool SyncUpdateDelay time.Duration + MaxPeerServers int // The limit of servers for each peer in registry } // NewRegistry is Streamer constructor @@ -87,6 +89,7 @@ func NewRegistry(localID enode.ID, delivery *Delivery, syncChunkStore storage.Sy delivery: delivery, intervalsStore: intervalsStore, doRetrieve: options.DoRetrieve, + maxPeerServers: options.MaxPeerServers, } streamer.api = NewAPI(streamer) delivery.getPeer = streamer.getPeer |