add inFlightUploadDataLimitCond signal

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

 		// processs uploads