diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-08-10 14:34:13 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-08-10 14:34:13 -0700 |
| commit | f2cd753bf9ddfbf1c040c7d21ab3d9f617aec15a (patch) | |
| tree | 6456076c33418fe2c30588569495a5116166d0ee /weed/server/filer_server_handlers.go | |
| parent | 01336d71ebfe5e2d15748ae125dd452f52b5000f (diff) | |
| download | seaweedfs-f2cd753bf9ddfbf1c040c7d21ab3d9f617aec15a.tar.xz seaweedfs-f2cd753bf9ddfbf1c040c7d21ab3d9f617aec15a.zip | |
fix avoid lock error
fix https://github.com/chrislusf/seaweedfs/issues/2247
Diffstat (limited to 'weed/server/filer_server_handlers.go')
| -rw-r--r-- | weed/server/filer_server_handlers.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/server/filer_server_handlers.go b/weed/server/filer_server_handlers.go index 0389e1e18..118646a04 100644 --- a/weed/server/filer_server_handlers.go +++ b/weed/server/filer_server_handlers.go @@ -58,8 +58,8 @@ func (fs *FilerServer) filerHandler(w http.ResponseWriter, r *http.Request) { glog.V(4).Infof("wait because inflight data %d > %d", fs.inFlightDataSize, fs.option.ConcurrentUploadLimit) fs.inFlightDataLimitCond.Wait() } - atomic.AddInt64(&fs.inFlightDataSize, contentLength) fs.inFlightDataLimitCond.L.Unlock() + atomic.AddInt64(&fs.inFlightDataSize, contentLength) defer func() { atomic.AddInt64(&fs.inFlightDataSize, -contentLength) fs.inFlightDataLimitCond.Signal() |