diff options
| author | chrislu <chris.lu@gmail.com> | 2025-11-13 17:36:42 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-11-13 17:36:54 -0800 |
| commit | e154bfe1636d32b7e4305519c39d1c14ed8d8b1e (patch) | |
| tree | a17d07a9033e26877dc6a674b2dec78d8233c31a /weed/s3api/s3api_object_handlers_put.go | |
| parent | 4477edbcc4cd3adb43b3c42f56010388a4373c20 (diff) | |
| download | seaweedfs-e154bfe1636d32b7e4305519c39d1c14ed8d8b1e.tar.xz seaweedfs-e154bfe1636d32b7e4305519c39d1c14ed8d8b1e.zip | |
minor
Diffstat (limited to 'weed/s3api/s3api_object_handlers_put.go')
| -rw-r--r-- | weed/s3api/s3api_object_handlers_put.go | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/weed/s3api/s3api_object_handlers_put.go b/weed/s3api/s3api_object_handlers_put.go index 0f6d88f42..6ce48429f 100644 --- a/weed/s3api/s3api_object_handlers_put.go +++ b/weed/s3api/s3api_object_handlers_put.go @@ -135,7 +135,7 @@ func (s3a *S3ApiServer) PutObjectHandler(w http.ResponseWriter, r *http.Request) versioningEnabled := (versioningState == s3_constants.VersioningEnabled) versioningConfigured := (versioningState != "") - glog.V(0).Infof("PutObjectHandler: bucket=%s, object=%s, versioningState='%s', versioningEnabled=%v, versioningConfigured=%v", bucket, object, versioningState, versioningEnabled, versioningConfigured) + glog.V(2).Infof("PutObjectHandler: bucket=%s, object=%s, versioningState='%s', versioningEnabled=%v, versioningConfigured=%v", bucket, object, versioningState, versioningEnabled, versioningConfigured) // Validate object lock headers before processing if err := s3a.validateObjectLockHeaders(r, versioningEnabled); err != nil { @@ -155,7 +155,8 @@ func (s3a *S3ApiServer) PutObjectHandler(w http.ResponseWriter, r *http.Request) } } - if versioningState == s3_constants.VersioningEnabled { + switch versioningState { + case s3_constants.VersioningEnabled: // Handle enabled versioning - create new versions with real version IDs glog.V(0).Infof("PutObjectHandler: ENABLED versioning detected for %s/%s, calling putVersionedObject", bucket, object) versionId, etag, errCode := s3a.putVersionedObject(r, bucket, object, dataReader, objectContentType) @@ -177,7 +178,7 @@ func (s3a *S3ApiServer) PutObjectHandler(w http.ResponseWriter, r *http.Request) // Set ETag in response setEtag(w, etag) - } else if versioningState == s3_constants.VersioningSuspended { + case s3_constants.VersioningSuspended: // Handle suspended versioning - overwrite with "null" version ID but preserve existing versions etag, errCode := s3a.putSuspendedVersioningObject(r, bucket, object, dataReader, objectContentType) if errCode != s3err.ErrNone { @@ -190,7 +191,7 @@ func (s3a *S3ApiServer) PutObjectHandler(w http.ResponseWriter, r *http.Request) // Set ETag in response setEtag(w, etag) - } else { + default: // Handle regular PUT (never configured versioning) uploadUrl := s3a.toFilerUrl(bucket, object) if objectContentType == "" { |