(shardingsphere) branch master updated: Refactor ClusterLockContext (#34118)

[zhangliang]

This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new e65efa34577 Refactor ClusterLockContext (#34118)
e65efa34577 is described below

commit e65efa3457769afe163cb96aff745d807f83f679
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sun Dec 22 11:59:16 2024 +0800

    Refactor ClusterLockContext (#34118)
---
 .../mode/manager/cluster/lock/ClusterLockContext.java       | 13 +++++++------
 .../mode/manager/standalone/lock/StandaloneLockContext.java |  2 +-
 2 files changed, 8 insertions(+), 7 deletions(-)

diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/lock/ClusterLockContext.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/lock/ClusterLockContext.java
index 533642f862d..10e978989b8 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/lock/ClusterLockContext.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/lock/ClusterLockContext.java
@@ -19,24 +19,25 @@ package org.apache.shardingsphere.mode.manager.cluster.lock;
 
 import lombok.RequiredArgsConstructor;
 import org.apache.shardingsphere.infra.lock.LockContext;
+import org.apache.shardingsphere.infra.lock.LockDefinition;
 import org.apache.shardingsphere.mode.lock.LockPersistService;
 import org.apache.shardingsphere.mode.lock.global.GlobalLockDefinition;
 
 /**
- * Cluster global lock context.
+ * Cluster lock context.
  */
 @RequiredArgsConstructor
-public final class ClusterLockContext implements 
LockContext<GlobalLockDefinition> {
+public final class ClusterLockContext implements LockContext<LockDefinition> {
     
     private final LockPersistService<GlobalLockDefinition> 
globalLockPersistService;
     
     @Override
-    public boolean tryLock(final GlobalLockDefinition lockDefinition, final 
long timeoutMillis) {
-        return globalLockPersistService.tryLock(lockDefinition, timeoutMillis);
+    public boolean tryLock(final LockDefinition lockDefinition, final long 
timeoutMillis) {
+        return globalLockPersistService.tryLock((GlobalLockDefinition) 
lockDefinition, timeoutMillis);
     }
     
     @Override
-    public void unlock(final GlobalLockDefinition lockDefinition) {
-        globalLockPersistService.unlock(lockDefinition);
+    public void unlock(final LockDefinition lockDefinition) {
+        globalLockPersistService.unlock((GlobalLockDefinition) lockDefinition);
     }
 }
diff --git 
a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/lock/StandaloneLockContext.java
 
b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/lock/StandaloneLockContext.java
index f790342744e..6b5e5a603df 100644
--- 
a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/lock/StandaloneLockContext.java
+++ 
b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/lock/StandaloneLockContext.java
@@ -21,7 +21,7 @@ import org.apache.shardingsphere.infra.lock.LockContext;
 import org.apache.shardingsphere.infra.lock.LockDefinition;
 
 /**
- * Standalone global lock context.
+ * Standalone lock context.
  */
 public final class StandaloneLockContext implements 
LockContext<LockDefinition> {