|
@ -228,8 +228,8 @@ func (s3a *S3ApiServer) PutObjectPartHandler(w http.ResponseWriter, r *http.Requ |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
dataReader := r.Body |
|
|
dataReader := r.Body |
|
|
if s3a.iam.isEnabled() { |
|
|
|
|
|
rAuthType := getRequestAuthType(r) |
|
|
rAuthType := getRequestAuthType(r) |
|
|
|
|
|
if s3a.iam.isEnabled() { |
|
|
var s3ErrCode s3err.ErrorCode |
|
|
var s3ErrCode s3err.ErrorCode |
|
|
switch rAuthType { |
|
|
switch rAuthType { |
|
|
case authTypeStreamingSigned: |
|
|
case authTypeStreamingSigned: |
|
@ -243,6 +243,11 @@ func (s3a *S3ApiServer) PutObjectPartHandler(w http.ResponseWriter, r *http.Requ |
|
|
s3err.WriteErrorResponse(w, r, s3ErrCode) |
|
|
s3err.WriteErrorResponse(w, r, s3ErrCode) |
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
|
|
|
|
} else { |
|
|
|
|
|
if authTypeStreamingSigned == rAuthType { |
|
|
|
|
|
s3err.WriteErrorResponse(w, r, s3err.ErrAuthNotSetup) |
|
|
|
|
|
return |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
defer dataReader.Close() |
|
|
defer dataReader.Close() |
|
|
|
|
|
|
|
|