[shardingsphere] branch master updated: Init lock ack node (#9827)

[zhangyonglun]

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

zhangyonglun 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 64d2131  Init lock ack node (#9827)
64d2131 is described below

commit 64d2131e6ce7dcf14082e1484ff990adf4c39be4
Author: Haoran Meng <menghaora...@gmail.com>
AuthorDate: Fri Mar 26 14:09:00 2021 +0800

    Init lock ack node (#9827)
---
 .../shardingsphere/governance/core/lock/node/LockNode.java       | 9 +++++++++
 .../shardingsphere/governance/core/registry/RegistryCenter.java  | 1 +
 .../shardingsphere/governance/core/lock/node/LockNodeTest.java   | 5 +++++
 3 files changed, 15 insertions(+)

diff --git 
a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/lock/node/LockNode.java
 
b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/lock/node/LockNode.java
index 662b9b0..8983539 100644
--- 
a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/lock/node/LockNode.java
+++ 
b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/lock/node/LockNode.java
@@ -54,6 +54,15 @@ public final class LockNode {
     }
     
     /**
+     * Get locked ack root node path.
+     * 
+     * @return locked ack root node path
+     */
+    public String getLockedAckRootNodePah() {
+        return Joiner.on("/").join("", LOCK_NODE_ROOT, LOCKED_ACK_NODE);
+    }
+    
+    /**
      * Get locked ack node path.
      * 
      * @param ackLockName ack lock name
diff --git 
a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/RegistryCenter.java
 
b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/RegistryCenter.java
index d11d7b1..f6c2ea5 100644
--- 
a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/RegistryCenter.java
+++ 
b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/registry/RegistryCenter.java
@@ -544,6 +544,7 @@ public final class RegistryCenter {
     
     private void initLockNode() {
         repository.persist(lockNode.getLockRootNodePath(), "");
+        repository.persist(lockNode.getLockedAckRootNodePah(), "");
     }
     
     /**
diff --git 
a/shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/lock/node/LockNodeTest.java
 
b/shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/lock/node/LockNodeTest.java
index af785ab..689ddf2 100644
--- 
a/shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/lock/node/LockNodeTest.java
+++ 
b/shardingsphere-governance/shardingsphere-governance-core/src/test/java/org/apache/shardingsphere/governance/core/lock/node/LockNodeTest.java
@@ -46,4 +46,9 @@ public final class LockNodeTest {
     public void assertGetLockAckNodePath() {
         assertThat(lockNode.getLockedAckNodePath("test"), 
is("/lock/ack/test"));
     }
+    
+    @Test
+    public void assertGetLockedAckRootNodePah() {
+        assertThat(lockNode.getLockedAckRootNodePah(), is("/lock/ack"));
+    }
 }