diff options
Diffstat (limited to 'weed/operation')
| -rw-r--r-- | weed/operation/upload_content.go | 14 |
1 files changed, 8 insertions, 6 deletions
diff --git a/weed/operation/upload_content.go b/weed/operation/upload_content.go index 0c3e29a43..17e767472 100644 --- a/weed/operation/upload_content.go +++ b/weed/operation/upload_content.go @@ -5,11 +5,6 @@ import ( "context" "encoding/json" "fmt" - "github.com/seaweedfs/seaweedfs/weed/glog" - "github.com/seaweedfs/seaweedfs/weed/pb/filer_pb" - "github.com/seaweedfs/seaweedfs/weed/security" - "github.com/seaweedfs/seaweedfs/weed/stats" - "github.com/seaweedfs/seaweedfs/weed/util" "io" "mime" "mime/multipart" @@ -19,6 +14,12 @@ import ( "path/filepath" "strings" "time" + + "github.com/seaweedfs/seaweedfs/weed/glog" + "github.com/seaweedfs/seaweedfs/weed/pb/filer_pb" + "github.com/seaweedfs/seaweedfs/weed/security" + "github.com/seaweedfs/seaweedfs/weed/stats" + "github.com/seaweedfs/seaweedfs/weed/util" ) type UploadOption struct { @@ -120,7 +121,8 @@ func UploadWithRetry(filerClient filer_pb.FilerClient, assignRequest *filer_pb.A return true }) } else { - err = util.Retry("uploadWithRetry", doUploadFunc) + uploadErrList := []string{"transport", "is read only"} + err = util.MultiRetry("uploadWithRetry", uploadErrList, doUploadFunc) } return |