Skip to content

Commit 5d1b43d

Browse files
authored
HDDS-13076. Refactor OzoneManagerLock class to rename Resource class to LeveledResource (apache#8482)
1 parent bafe6d9 commit 5d1b43d

File tree

75 files changed

+191
-191
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

75 files changed

+191
-191
lines changed

hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/S3SecretLockedManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717

1818
package org.apache.hadoop.ozone.om;
1919

20-
import static org.apache.hadoop.ozone.om.lock.OzoneManagerLock.Resource.S3_SECRET_LOCK;
20+
import static org.apache.hadoop.ozone.om.lock.OzoneManagerLock.LeveledResource.S3_SECRET_LOCK;
2121

2222
import java.io.IOException;
2323
import java.util.List;

hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/lock/IOzoneManagerLock.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -25,43 +25,43 @@
2525
*/
2626
public interface IOzoneManagerLock {
2727

28-
OMLockDetails acquireReadLock(OzoneManagerLock.Resource resource,
28+
OMLockDetails acquireReadLock(OzoneManagerLock.LeveledResource resource,
2929
String... resources);
3030

31-
OMLockDetails acquireReadLocks(OzoneManagerLock.Resource resource, Collection<String[]> resources);
31+
OMLockDetails acquireReadLocks(OzoneManagerLock.LeveledResource resource, Collection<String[]> resources);
3232

33-
OMLockDetails acquireWriteLock(OzoneManagerLock.Resource resource,
33+
OMLockDetails acquireWriteLock(OzoneManagerLock.LeveledResource resource,
3434
String... resources);
3535

36-
OMLockDetails acquireWriteLocks(OzoneManagerLock.Resource resource,
36+
OMLockDetails acquireWriteLocks(OzoneManagerLock.LeveledResource resource,
3737
Collection<String[]> resources);
3838

3939
boolean acquireMultiUserLock(String firstUser, String secondUser);
4040

4141
void releaseMultiUserLock(String firstUser, String secondUser);
4242

43-
OMLockDetails releaseWriteLock(OzoneManagerLock.Resource resource,
43+
OMLockDetails releaseWriteLock(OzoneManagerLock.LeveledResource resource,
4444
String... resources);
4545

46-
OMLockDetails releaseWriteLocks(OzoneManagerLock.Resource resource,
46+
OMLockDetails releaseWriteLocks(OzoneManagerLock.LeveledResource resource,
4747
Collection<String[]> resources);
4848

49-
OMLockDetails releaseReadLock(OzoneManagerLock.Resource resource,
49+
OMLockDetails releaseReadLock(OzoneManagerLock.LeveledResource resource,
5050
String... resources);
5151

52-
OMLockDetails releaseReadLocks(OzoneManagerLock.Resource resource,
52+
OMLockDetails releaseReadLocks(OzoneManagerLock.LeveledResource resource,
5353
Collection<String[]> resources);
5454

5555
@VisibleForTesting
56-
int getReadHoldCount(OzoneManagerLock.Resource resource,
56+
int getReadHoldCount(OzoneManagerLock.LeveledResource resource,
5757
String... resources);
5858

5959
@VisibleForTesting
60-
int getWriteHoldCount(OzoneManagerLock.Resource resource,
60+
int getWriteHoldCount(OzoneManagerLock.LeveledResource resource,
6161
String... resources);
6262

6363
@VisibleForTesting
64-
boolean isWriteLockedByCurrentThread(OzoneManagerLock.Resource resource,
64+
boolean isWriteLockedByCurrentThread(OzoneManagerLock.LeveledResource resource,
6565
String... resources);
6666

6767
void cleanup();

hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/lock/OmReadOnlyLock.java

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
import static org.apache.hadoop.ozone.om.lock.OMLockDetails.EMPTY_DETAILS_LOCK_NOT_ACQUIRED;
2222

2323
import java.util.Collection;
24-
import org.apache.hadoop.ozone.om.lock.OzoneManagerLock.Resource;
24+
import org.apache.hadoop.ozone.om.lock.OzoneManagerLock.LeveledResource;
2525

2626
/**
2727
* Read only "lock" for snapshots
@@ -31,23 +31,23 @@
3131
public class OmReadOnlyLock implements IOzoneManagerLock {
3232

3333
@Override
34-
public OMLockDetails acquireReadLock(Resource resource, String... resources) {
34+
public OMLockDetails acquireReadLock(LeveledResource resource, String... resources) {
3535
return EMPTY_DETAILS_LOCK_ACQUIRED;
3636
}
3737

3838
@Override
39-
public OMLockDetails acquireReadLocks(Resource resource, Collection<String[]> resources) {
39+
public OMLockDetails acquireReadLocks(LeveledResource resource, Collection<String[]> resources) {
4040
return EMPTY_DETAILS_LOCK_ACQUIRED;
4141
}
4242

4343
@Override
44-
public OMLockDetails acquireWriteLock(Resource resource,
44+
public OMLockDetails acquireWriteLock(LeveledResource resource,
4545
String... resources) {
4646
return EMPTY_DETAILS_LOCK_NOT_ACQUIRED;
4747
}
4848

4949
@Override
50-
public OMLockDetails acquireWriteLocks(Resource resource, Collection<String[]> resources) {
50+
public OMLockDetails acquireWriteLocks(LeveledResource resource, Collection<String[]> resources) {
5151
return EMPTY_DETAILS_LOCK_NOT_ACQUIRED;
5252
}
5353

@@ -62,38 +62,38 @@ public void releaseMultiUserLock(String firstUser, String secondUser) {
6262
}
6363

6464
@Override
65-
public OMLockDetails releaseWriteLock(Resource resource,
65+
public OMLockDetails releaseWriteLock(LeveledResource resource,
6666
String... resources) {
6767
return EMPTY_DETAILS_LOCK_NOT_ACQUIRED;
6868
}
6969

7070
@Override
71-
public OMLockDetails releaseWriteLocks(Resource resource, Collection<String[]> resources) {
71+
public OMLockDetails releaseWriteLocks(LeveledResource resource, Collection<String[]> resources) {
7272
return EMPTY_DETAILS_LOCK_NOT_ACQUIRED;
7373
}
7474

7575
@Override
76-
public OMLockDetails releaseReadLock(Resource resource, String... resources) {
76+
public OMLockDetails releaseReadLock(LeveledResource resource, String... resources) {
7777
return EMPTY_DETAILS_LOCK_NOT_ACQUIRED;
7878
}
7979

8080
@Override
81-
public OMLockDetails releaseReadLocks(Resource resource, Collection<String[]> resources) {
81+
public OMLockDetails releaseReadLocks(LeveledResource resource, Collection<String[]> resources) {
8282
return EMPTY_DETAILS_LOCK_NOT_ACQUIRED;
8383
}
8484

8585
@Override
86-
public int getReadHoldCount(Resource resource, String... resources) {
86+
public int getReadHoldCount(LeveledResource resource, String... resources) {
8787
return 0;
8888
}
8989

9090
@Override
91-
public int getWriteHoldCount(Resource resource, String... resources) {
91+
public int getWriteHoldCount(LeveledResource resource, String... resources) {
9292
return 0;
9393
}
9494

9595
@Override
96-
public boolean isWriteLockedByCurrentThread(Resource resource,
96+
public boolean isWriteLockedByCurrentThread(LeveledResource resource,
9797
String... resources) {
9898
return false;
9999
}

0 commit comments

Comments
 (0)