diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-06-06 13:13:33 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-06-06 13:13:33 -0700 |
| commit | 9cba5cca0be43553f7aae1ab5477a0366765ff02 (patch) | |
| tree | 01890425e91c5a20721d0f0d84fdfcd63abe3262 /weed/server/filer_server_handlers.go | |
| parent | 21ad9a4ac29fad0794369cc05d1f29fa91340c34 (diff) | |
| download | seaweedfs-9cba5cca0be43553f7aae1ab5477a0366765ff02.tar.xz seaweedfs-9cba5cca0be43553f7aae1ab5477a0366765ff02.zip | |
optionally disable concurrent upload limit
Diffstat (limited to 'weed/server/filer_server_handlers.go')
| -rw-r--r-- | weed/server/filer_server_handlers.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/server/filer_server_handlers.go b/weed/server/filer_server_handlers.go index ed6bbb6f6..56a47c860 100644 --- a/weed/server/filer_server_handlers.go +++ b/weed/server/filer_server_handlers.go @@ -1,6 +1,7 @@ package weed_server import ( + "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/util" "net/http" "strings" @@ -53,7 +54,8 @@ func (fs *FilerServer) filerHandler(w http.ResponseWriter, r *http.Request) { // wait until in flight data is less than the limit contentLength := getContentLength(r) fs.inFlightDataLimitCond.L.Lock() - for atomic.LoadInt64(&fs.inFlightDataSize) > fs.option.ConcurrentUploadLimit { + for fs.option.ConcurrentUploadLimit != 0 && atomic.LoadInt64(&fs.inFlightDataSize) > fs.option.ConcurrentUploadLimit { + glog.V(4).Infof("wait because inflight data %d > %d", fs.inFlightDataSize, fs.option.ConcurrentUploadLimit) fs.inFlightDataLimitCond.Wait() } atomic.AddInt64(&fs.inFlightDataSize, contentLength) |