gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(objectnode): save the ACL of the object uploaded by the non-volume owner

Browse Source 
Signed-off-by: yhjiango <jiangyunhua@oppo.com>
This commit is contained in:
yhjiango 2023-07-20 20:09:55 +08:00 committed by leonrayang
parent 7613a0fadb
commit 13dfb462f3
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
objectnode/api_handler_multipart.go
View File

@ -108,7 +108,7 @@ func (o *ObjectNode) createMultipleUploadHandler(w http.ResponseWriter, r *http.
}
// Check ACL
var acl *AccessControlPolicy
acl, err = ParseACL(r, userInfo.UserID, false, false)
acl, err = ParseACL(r, userInfo.UserID, false, vol.GetOwner() != userInfo.UserID)
if err != nil {
log.LogErrorf("createMultipleUploadHandler: parse acl fail: requestID(%v) acl(%+v) err(%v)",
GetRequestID(r), acl, err)

4
objectnode/api_handler_object.go
View File

@ -744,7 +744,7 @@ func (o *ObjectNode) copyObjectHandler(w http.ResponseWriter, r *http.Request) {
GetRequestID(r), param.Bucket(), param.AccessKey(), err)
return
}
acl, err := ParseACL(r, userInfo.UserID, false, false)
acl, err := ParseACL(r, userInfo.UserID, false, vol.GetOwner() != userInfo.UserID)
if err != nil {
log.LogErrorf("copyObjectHandler: parse acl fail: requestID(%v) volume(%v) acl(%+v) err(%v)",
GetRequestID(r), param.Bucket(), acl, err)
@ -1220,7 +1220,7 @@ func (o *ObjectNode) putObjectHandler(w http.ResponseWriter, r *http.Request) {
}
// Check ACL
acl, err := ParseACL(r, userInfo.UserID, false, false)
acl, err := ParseACL(r, userInfo.UserID, false, vol.GetOwner() != userInfo.UserID)
if err != nil {
log.LogErrorf("putObjectHandler: parse acl fail: requestID(%v) volume(%v) path(%v) acl(%+v) err(%v)",
GetRequestID(r), vol.Name(), param.Object(), acl, err)