diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2022-03-09 20:59:53 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-03-09 20:59:53 -0800 |
| commit | fc0a583a4d2ffdc0d44ac640620bb4e09b31f9f5 (patch) | |
| tree | 2f5f43b27ce319ef03e420fecdfc7987af234ef7 | |
| parent | e2b07737da41337c782941723866d54c6d5a8153 (diff) | |
| parent | f28dbbe5c5d07402605832d7fb4b2cb71e2c274a (diff) | |
| download | seaweedfs-fc0a583a4d2ffdc0d44ac640620bb4e09b31f9f5.tar.xz seaweedfs-fc0a583a4d2ffdc0d44ac640620bb4e09b31f9f5.zip | |
Merge pull request #2740 from banjiaojuhao/filer-bugfix-handle_upload_interruption
[bugfix] filer: upload files error
| -rw-r--r-- | weed/server/filer_server_handlers_write_upload.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/server/filer_server_handlers_write_upload.go b/weed/server/filer_server_handlers_write_upload.go index 15a4bac33..6ee378819 100644 --- a/weed/server/filer_server_handlers_write_upload.go +++ b/weed/server/filer_server_handlers_write_upload.go @@ -79,6 +79,7 @@ func (fs *FilerServer) uploadReaderToChunks(w http.ResponseWriter, r *http.Reque bufPool.Put(bytesBuffer) atomic.AddInt64(&bytesBufferCounter, -1) bytesBufferLimitCond.Signal() + uploadErr = err break } if chunkOffset == 0 && !isAppend { @@ -126,6 +127,7 @@ func (fs *FilerServer) uploadReaderToChunks(w http.ResponseWriter, r *http.Reque wg.Wait() if uploadErr != nil { + fs.filer.DeleteChunks(fileChunks) return nil, md5Hash, 0, uploadErr, nil } |