diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-10-08 18:33:06 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-10-08 18:33:06 -0700 |
| commit | bd8b9b0c2e40db186505ccce231f771bbf90e829 (patch) | |
| tree | c8a82d0e953b74eab698ee72840c059bb29c9323 /weed/server | |
| parent | 78859e35fcd20c0aa8d8f60887c5b52c8cce84b5 (diff) | |
| download | seaweedfs-bd8b9b0c2e40db186505ccce231f771bbf90e829.tar.xz seaweedfs-bd8b9b0c2e40db186505ccce231f771bbf90e829.zip | |
some changes to prepare fix after failed reads
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/volume_server_handlers_read.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/server/volume_server_handlers_read.go b/weed/server/volume_server_handlers_read.go index bb04678d6..6f146cb55 100644 --- a/weed/server/volume_server_handlers_read.go +++ b/weed/server/volume_server_handlers_read.go @@ -93,6 +93,10 @@ func (vs *VolumeServer) GetOrHeadHandler(w http.ResponseWriter, r *http.Request) } else if hasEcVolume { count, err = vs.store.ReadEcShardNeedle(volumeId, n) } + if err != nil && err != storage.ErrorDeleted && r.FormValue("type") != "replicate" && hasVolume { + glog.V(4).Infoln("read needle: %v", err) + // start to fix it from other replicas, if not deleted and hasVolume and is not a replicated request + } // glog.V(4).Infoln("read bytes", count, "error", err) if err != nil || count < 0 { glog.V(3).Infof("read %s isNormalVolume %v error: %v", r.URL.Path, hasVolume, err) |