Merge pull request #2740 from banjiaojuhao/filer-bugfix-handle_upload_interruption

[bugfix] filer: upload files error
This commit is contained in:
Chris Lu 2022-03-09 20:59:53 -08:00 committed by GitHub
commit fc0a583a4d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -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
}