diff options
| author | Anton Evangelatov <anton.evangelatov@gmail.com> | 2019-05-06 16:58:42 +0800 |
|---|---|---|
| committer | Anton Evangelatov <anton.evangelatov@gmail.com> | 2019-05-10 18:26:55 +0800 |
| commit | 8802b9ce7fe8f9764bd50dfe072b37ebc9e84cb8 (patch) | |
| tree | 1bd8999f1aeda1f4a470bcd45ba466074ffdf42b /cmd/swarm/swarm-smoke/sliding_window.go | |
| parent | ad6c39012fc761dd02a6b1a7fbfdcf2478abe2a1 (diff) | |
| download | go-tangerine-8802b9ce7fe8f9764bd50dfe072b37ebc9e84cb8.tar go-tangerine-8802b9ce7fe8f9764bd50dfe072b37ebc9e84cb8.tar.gz go-tangerine-8802b9ce7fe8f9764bd50dfe072b37ebc9e84cb8.tar.bz2 go-tangerine-8802b9ce7fe8f9764bd50dfe072b37ebc9e84cb8.tar.lz go-tangerine-8802b9ce7fe8f9764bd50dfe072b37ebc9e84cb8.tar.xz go-tangerine-8802b9ce7fe8f9764bd50dfe072b37ebc9e84cb8.tar.zst go-tangerine-8802b9ce7fe8f9764bd50dfe072b37ebc9e84cb8.zip | |
swarm-smoke: add syncDelay flag
swarm/network: add want delay timer to syncing (#1367)
swarm/network: synchronise peer.close() (#1369)
Diffstat (limited to 'cmd/swarm/swarm-smoke/sliding_window.go')
| -rw-r--r-- | cmd/swarm/swarm-smoke/sliding_window.go | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/cmd/swarm/swarm-smoke/sliding_window.go b/cmd/swarm/swarm-smoke/sliding_window.go index ab082c543..6ca3d3947 100644 --- a/cmd/swarm/swarm-smoke/sliding_window.go +++ b/cmd/swarm/swarm-smoke/sliding_window.go @@ -81,9 +81,13 @@ outer: return err } - log.Info("uploaded successfully", "hash", hash, "digest", fmt.Sprintf("%x", fhash), "sleeping", syncDelay) + log.Info("uploaded successfully", "hash", hash, "digest", fmt.Sprintf("%x", fhash), "wait for sync", syncDelay) hashes = append(hashes, uploadResult{hash: hash, digest: fhash}) - time.Sleep(time.Duration(syncDelay) * time.Second) + + if syncDelay { + waitToSync() + } + uploadedBytes += filesize * 1000 q := make(chan struct{}, 1) d := make(chan struct{}) |