Rename global lock's key from /lock/exclusive/locks to /lock/global/l…

…ocks (#34142)
apache · Dec 24, 2024 · f4c1815 · f4c1815
1 parent 91d84ad
commit f4c1815
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/mode/core/src/main/java/org/apache/shardingsphere/mode/lock/global/GlobalLockDefinition.java b/mode/core/src/main/java/org/apache/shardingsphere/mode/lock/global/GlobalLockDefinition.java
@@ -26,7 +26,7 @@
 @Getter
 public final class GlobalLockDefinition implements LockDefinition {
 
-    private static final String KEY_PATTERN = "/lock/exclusive/locks/%s";
+    private static final String KEY_PATTERN = "/lock/global/locks/%s";
 
     private final String lockKey;
 

diff --git a/...re/src/test/java/org/apache/shardingsphere/mode/lock/global/GlobalLockDefinitionTest.java b/...re/src/test/java/org/apache/shardingsphere/mode/lock/global/GlobalLockDefinitionTest.java
@@ -30,6 +30,6 @@ class GlobalLockDefinitionTest {
     void assertGetLockKey() {
         GlobalLock globalLock = mock(GlobalLock.class);
         when(globalLock.getName()).thenReturn("foo_lock");
-        assertThat(new GlobalLockDefinition(globalLock).getLockKey(), is("/lock/exclusive/locks/foo_lock"));
+        assertThat(new GlobalLockDefinition(globalLock).getLockKey(), is("/lock/global/locks/foo_lock"));
     }
 }
diff --git a/...che/shardingsphere/mode/manager/cluster/persist/service/GlobalLockPersistServiceTest.java b/...che/shardingsphere/mode/manager/cluster/persist/service/GlobalLockPersistServiceTest.java
@@ -47,7 +47,7 @@ void setUp() {
 
     @Test
     void assertTryLock() {
-        when(repository.getDistributedLockHolder().getDistributedLock("/lock/exclusive/locks/foo_lock").tryLock(1000L)).thenReturn(true);
+        when(repository.getDistributedLockHolder().getDistributedLock("/lock/global/locks/foo_lock").tryLock(1000L)).thenReturn(true);
         GlobalLockDefinition lockDefinition = new GlobalLockDefinition(globalLock);
         assertTrue(new GlobalLockPersistService(repository).tryLock(lockDefinition, 1000L));
     }
@@ -56,6 +56,6 @@ void assertTryLock() {
     void assertUnlock() {
         GlobalLockDefinition lockDefinition = new GlobalLockDefinition(globalLock);
         new GlobalLockPersistService(repository).unlock(lockDefinition);
-        verify(repository.getDistributedLockHolder().getDistributedLock("/lock/exclusive/locks/foo_lock")).unlock();
+        verify(repository.getDistributedLockHolder().getDistributedLock("/lock/global/locks/foo_lock")).unlock();
     }
 }