diff options
| author | famosss <zzq09494@ly.com> | 2022-09-07 14:56:29 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-09-06 23:56:29 -0700 |
| commit | 5ff33eb558fda658175c86f48cf7a203b8a78fde (patch) | |
| tree | b15c1e5740323d1f3c78878aef0778401fd2f8a3 /weed/server/volume_server_handlers.go | |
| parent | b324a6536c07ff57340ff62b5d5318d05ff5666c (diff) | |
| download | seaweedfs-5ff33eb558fda658175c86f48cf7a203b8a78fde.tar.xz seaweedfs-5ff33eb558fda658175c86f48cf7a203b8a78fde.zip | |
fix: volume Deadlock when exception is thrown (#3613)
* fix: volume Deadlock when exception is thrown
* adjust log level
Diffstat (limited to 'weed/server/volume_server_handlers.go')
| -rw-r--r-- | weed/server/volume_server_handlers.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/server/volume_server_handlers.go b/weed/server/volume_server_handlers.go index eec78a7db..dcb92aa6b 100644 --- a/weed/server/volume_server_handlers.go +++ b/weed/server/volume_server_handlers.go @@ -50,6 +50,8 @@ func (vs *VolumeServer) privateStoreHandler(w http.ResponseWriter, r *http.Reque select { case <-r.Context().Done(): glog.V(4).Infof("request cancelled from %s: %v", r.RemoteAddr, r.Context().Err()) + w.WriteHeader(http.StatusInternalServerError) + vs.inFlightDownloadDataLimitCond.L.Unlock() return default: glog.V(4).Infof("wait because inflight download data %d > %d", inFlightDownloadSize, vs.concurrentDownloadLimit) |