add condition when inFlightUploadDataLimitCond signal

3 years ago · df0ce31a2e
1 changed files with 3 additions and 1 deletions
--- a/weed/server/volume_server_handlers.go
+++ b/weed/server/volume_server_handlers.go
@ -79,7 +79,9 @@ func (vs *VolumeServer) privateStoreHandler(w http.ResponseWriter, r *http.Reque
 		atomic.AddInt64(&vs.inFlightUploadDataSize, contentLength)
 		defer func() {
 			atomic.AddInt64(&vs.inFlightUploadDataSize, -contentLength)
+			if vs.concurrentUploadLimit != 0 {
 				vs.inFlightUploadDataLimitCond.Signal()
+			}
 		}()

 		// processs uploads