diff options
| author | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-03-15 18:52:59 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-03-15 18:52:59 +0500 |
| commit | 7194a5e7bf38ec136ea8ec8f6b50960d598a4d95 (patch) | |
| tree | 2592df165f200937740f712a09743cda9445028a /weed/replication | |
| parent | 9f00f95bfb8dcf118ade083c66122725f25fdd45 (diff) | |
| download | seaweedfs-7194a5e7bf38ec136ea8ec8f6b50960d598a4d95.tar.xz seaweedfs-7194a5e7bf38ec136ea8ec8f6b50960d598a4d95.zip | |
avoid http error: superfluous response.WriteHeader
https://github.com/chrislusf/seaweedfs/issues/1838
Diffstat (limited to 'weed/replication')
| -rw-r--r-- | weed/replication/repl_util/replication_util.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/replication/repl_util/replication_util.go b/weed/replication/repl_util/replication_util.go index f642bb801..23fbe3292 100644 --- a/weed/replication/repl_util/replication_util.go +++ b/weed/replication/repl_util/replication_util.go @@ -20,7 +20,7 @@ func CopyFromChunkViews(chunkViews []*filer.ChunkView, filerSource *source.Filer var shouldRetry bool for _, fileUrl := range fileUrls { - shouldRetry, err = util.FastReadUrlAsStream(fileUrl, nil, false, chunk.IsFullChunk(), chunk.Offset, int(chunk.Size), func(data []byte) { + shouldRetry, err = util.FastReadUrlAsStream(fileUrl, nil, false, chunk.IsFullChunk(), false, chunk.Offset, int(chunk.Size), func(data []byte) { writeErr = writeFunc(data) }) if err != nil { |