diff options
| author | Balint Gabor <balint.g@gmail.com> | 2018-09-19 22:59:10 +0800 |
|---|---|---|
| committer | Anton Evangelatov <anton.evangelatov@gmail.com> | 2018-09-19 22:59:10 +0800 |
| commit | f5c7d1c8eb202b850541a3fcfc2e9bd4ee6f70a9 (patch) | |
| tree | 48feff3cd06cda592922204eb416c5d24b89dc1c /swarm | |
| parent | 736b45a87606e6cdfd5aecf38d259517b10e7f7e (diff) | |
| download | dexon-f5c7d1c8eb202b850541a3fcfc2e9bd4ee6f70a9.tar.gz dexon-f5c7d1c8eb202b850541a3fcfc2e9bd4ee6f70a9.tar.zst dexon-f5c7d1c8eb202b850541a3fcfc2e9bd4ee6f70a9.zip | |
swarm/storage: Implement global timeout for fetcher (#17702)
Diffstat (limited to 'swarm')
| -rw-r--r-- | swarm/storage/netstore.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/swarm/storage/netstore.go b/swarm/storage/netstore.go index de2d82d2b..80ac6f198 100644 --- a/swarm/storage/netstore.go +++ b/swarm/storage/netstore.go @@ -52,6 +52,8 @@ type NetStore struct { closeC chan struct{} } +var fetcherTimeout = 2 * time.Minute // timeout to cancel the fetcher even if requests are coming in + // NewNetStore creates a new NetStore object using the given local store. newFetchFunc is a // constructor function that can create a fetch function for a specific chunk address. func NewNetStore(store SyncChunkStore, nnf NewNetFetcherFunc) (*NetStore, error) { @@ -168,7 +170,7 @@ func (n *NetStore) getOrCreateFetcher(ref Address) *fetcher { // no fetcher for the given address, we have to create a new one key := hex.EncodeToString(ref) // create the context during which fetching is kept alive - ctx, cancel := context.WithCancel(context.Background()) + ctx, cancel := context.WithTimeout(context.Background(), fetcherTimeout) // destroy is called when all requests finish destroy := func() { // remove fetcher from fetchers |