diff options
| author | chrislu <chris.lu@gmail.com> | 2022-03-23 23:16:54 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-03-23 23:16:54 -0700 |
| commit | 0b5faef612b47726ef0862478294523681dc6742 (patch) | |
| tree | 9ecb57b041e0eeaa9536c868b5ebfbdf1be8e30e | |
| parent | 0562fceb9925f6c2cd13b68f24d29dd1fd4c3e5e (diff) | |
| download | seaweedfs-0b5faef612b47726ef0862478294523681dc6742.tar.xz seaweedfs-0b5faef612b47726ef0862478294523681dc6742.zip | |
fix
| -rw-r--r-- | weed/server/volume_server_handlers.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/server/volume_server_handlers.go b/weed/server/volume_server_handlers.go index 751d3596b..cba2a7601 100644 --- a/weed/server/volume_server_handlers.go +++ b/weed/server/volume_server_handlers.go @@ -52,7 +52,7 @@ func (vs *VolumeServer) privateStoreHandler(w http.ResponseWriter, r *http.Reque // wait until in flight data is less than the limit contentLength := getContentLength(r) - for vs.concurrentUploadLimit != 0 && atomic.LoadInt64(&vs.inFlightUploadDataSize) > vs.concurrentUploadLimit { + if vs.concurrentUploadLimit != 0 && atomic.LoadInt64(&vs.inFlightUploadDataSize) > vs.concurrentUploadLimit { err := fmt.Errorf("reject because inflight upload data %d > %d", vs.inFlightUploadDataSize, vs.concurrentUploadLimit) glog.V(1).Infof("too many requests: %v", err) writeJsonError(w, r, http.StatusTooManyRequests, err) |