Mirrors/sftpgo
1
0
Fork 0
mirror of https://github.com/drakkan/sftpgo.git synced 2025-12-06 06:10:54 +03:00
Code Issues Packages Projects Releases Wiki Activity

cloud backends: update part size limits

Browse Source 
Signed-off-by: Nicola Murino <nicola.murino@gmail.com>
This commit is contained in:
Nicola Murino
2025-11-23 12:56:59 +01:00
parent 32cc426cb9
commit 90821ffc23
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
internal/vfs/vfs.go
View File

@@ -444,9 +444,9 @@ func (c *S3FsConfig) ValidateAndEncryptCredentials(additionalData string) error
} }
func (c *S3FsConfig) checkPartSizeAndConcurrency() error { func (c *S3FsConfig) checkPartSizeAndConcurrency() error {
if c.UploadPartSize != 0 && (c.UploadPartSize < 5 || c.UploadPartSize > 5000) { if c.UploadPartSize != 0 && (c.UploadPartSize < 5 || c.UploadPartSize > 2000) {
return util.NewI18nError( return util.NewI18nError(
errors.New("upload_part_size cannot be != 0, lower than 5 (MB) or greater than 5000 (MB)"), errors.New("upload_part_size cannot be != 0, lower than 5 (MB) or greater than 2000 (MB)"),
util.I18nErrorULPartSizeInvalid, util.I18nErrorULPartSizeInvalid,
) )
} }
@@ -456,9 +456,9 @@ func (c *S3FsConfig) checkPartSizeAndConcurrency() error {
util.I18nErrorULConcurrencyInvalid, util.I18nErrorULConcurrencyInvalid,
) )
} }
if c.DownloadPartSize != 0 && (c.DownloadPartSize < 5 || c.DownloadPartSize > 5000) { if c.DownloadPartSize != 0 && (c.DownloadPartSize < 5 || c.DownloadPartSize > 2000) {
return util.NewI18nError( return util.NewI18nError(
errors.New("download_part_size cannot be != 0, lower than 5 (MB) or greater than 5000 (MB)"), errors.New("download_part_size cannot be != 0, lower than 5 (MB) or greater than 2000 (MB)"),
util.I18nErrorDLPartSizeInvalid, util.I18nErrorDLPartSizeInvalid,
) )
} }
@@ -586,7 +586,7 @@ func (c *GCSFsConfig) isSameResource(other GCSFsConfig) bool {
} }
// validate returns an error if the configuration is not valid // validate returns an error if the configuration is not valid
func (c *GCSFsConfig) validate() error { func (c *GCSFsConfig) validate() error { //nolint:gocyclo
if c.Credentials == nil || c.AutomaticCredentials == 1 { if c.Credentials == nil || c.AutomaticCredentials == 1 {
c.Credentials = kms.NewEmptySecret() c.Credentials = kms.NewEmptySecret()
} }
@@ -610,7 +610,7 @@ func (c *GCSFsConfig) validate() error {
} }
c.StorageClass = strings.TrimSpace(c.StorageClass) c.StorageClass = strings.TrimSpace(c.StorageClass)
c.ACL = strings.TrimSpace(c.ACL) c.ACL = strings.TrimSpace(c.ACL)
if c.UploadPartSize < 0 { if c.UploadPartSize < 0 || c.UploadPartSize > 2000 {
c.UploadPartSize = 0 c.UploadPartSize = 0
} }
if c.UploadPartMaxTime < 0 { if c.UploadPartMaxTime < 0 {
@@ -747,7 +747,7 @@ func (c *AzBlobFsConfig) checkCredentials() error {
} }
func (c *AzBlobFsConfig) checkPartSizeAndConcurrency() error { func (c *AzBlobFsConfig) checkPartSizeAndConcurrency() error {
if c.UploadPartSize < 0 || c.UploadPartSize > 100 { if c.UploadPartSize < 0 || c.UploadPartSize > 2000 {
return util.NewI18nError( return util.NewI18nError(
fmt.Errorf("invalid upload part size: %v", c.UploadPartSize), fmt.Errorf("invalid upload part size: %v", c.UploadPartSize),
util.I18nErrorULPartSizeInvalid, util.I18nErrorULPartSizeInvalid,
@@ -759,7 +759,7 @@ func (c *AzBlobFsConfig) checkPartSizeAndConcurrency() error {
util.I18nErrorULConcurrencyInvalid, util.I18nErrorULConcurrencyInvalid,
) )
} }
if c.DownloadPartSize < 0 || c.DownloadPartSize > 100 { if c.DownloadPartSize < 0 || c.DownloadPartSize > 2000 {
return util.NewI18nError( return util.NewI18nError(
fmt.Errorf("invalid download part size: %v", c.DownloadPartSize), fmt.Errorf("invalid download part size: %v", c.DownloadPartSize),
util.I18nErrorDLPartSizeInvalid, util.I18nErrorDLPartSizeInvalid,