Skip to content

Commit db40ff8

Browse files
author
Fabian Morgan
committed
pr review updates for ChenSammi
1 parent 9c1665b commit db40ff8

2 files changed

Lines changed: 1 addition & 23 deletions

File tree

hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3977,7 +3977,7 @@ public OmMultipartUploadList listMultipartUploads(String volumeName,
39773977
auditMap.put(OzoneConsts.PREFIX, prefix);
39783978

39793979
try {
3980-
if (getAclsEnabled() && isStsS3Request()) {
3980+
if (getAclsEnabled()) {
39813981
omMetadataReader.checkAcls(
39823982
ResourceType.BUCKET, StoreType.OZONE, ACLType.READ, realVolumeName, realBucketName, null);
39833983
omMetadataReader.checkAcls(

hadoop-ozone/ozone-manager/src/test/java/org/apache/hadoop/ozone/om/TestOzoneManagerListMultipartUploadsAcls.java

Lines changed: 0 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -137,17 +137,6 @@ void testSkipsAclChecksWhenAclsAreDisabledEvenForStsRequest() throws Exception {
137137
eq(REAL_VOLUME), eq(REAL_BUCKET), eq(PREFIX), eq(""), eq(""), eq(10), eq(false));
138138
}
139139

140-
@Test
141-
void testSkipsAclChecksWhenNotStsRequestEvenIfAclsAreEnabled() throws Exception {
142-
OzoneManager.setS3Auth(null);
143-
OzoneManager.setStsTokenIdentifier(null);
144-
when(omSpy.getAclsEnabled()).thenReturn(true);
145-
146-
omSpy.listMultipartUploads(REQUESTED_VOLUME, REQUESTED_BUCKET, PREFIX, "", "", 10, false);
147-
148-
verify(omMetadataReader, never()).checkAcls(any(), any(), any(), any(), any(), any());
149-
}
150-
151140
@Test
152141
void testAclsEnabledAndStsRequestChecksBucketReadThenListUsingResolvedNames() throws Exception {
153142
setupStsS3Request();
@@ -204,17 +193,6 @@ void testListAclAccessDeniedSkipsKeyManagerAndIncrementsFailMetric() throws Exce
204193
verify(metrics, never()).incNumListMultipartUploads();
205194
}
206195

207-
@Test
208-
void testNonStsRequestSkipsAclChecks() throws Exception {
209-
OzoneManager.setS3Auth(S3Authentication.newBuilder().setAccessId(STS_ACCESS_ID).build());
210-
OzoneManager.setStsTokenIdentifier(null);
211-
when(omSpy.getAclsEnabled()).thenReturn(true);
212-
213-
omSpy.listMultipartUploads(REQUESTED_VOLUME, REQUESTED_BUCKET, PREFIX, "", "", 10, false);
214-
215-
verify(omMetadataReader, never()).checkAcls(any(), any(), any(), any(), any(), any());
216-
}
217-
218196
private void setupStsS3Request() {
219197
OzoneManager.setS3Auth(S3Authentication.newBuilder().setAccessId(STS_ACCESS_ID).build());
220198
OzoneManager.setStsTokenIdentifier(mock(STSTokenIdentifier.class));

0 commit comments

Comments
 (0)