Refactor code style

apache · Jun 19, 2024 · 608851d · 608851d
1 parent b94a618
commit 608851d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/...che/shardingsphere/mode/manager/cluster/coordinator/listener/MetaDataChangedListener.java b/...che/shardingsphere/mode/manager/cluster/coordinator/listener/MetaDataChangedListener.java
@@ -150,7 +150,7 @@ private Optional<GovernanceEvent> createStorageUnitChangedEvent(final String dat
         }
         dataSourceUnitName = DataSourceMetaDataNode.getDataSourceNameByDataSourceUnitNode(event.getKey());
         if (Type.DELETED == event.getType() && dataSourceUnitName.isPresent()) {
-            return dataSourceUnitName.map(optional -> new UnregisterStorageUnitEvent(databaseName, optional));
+            return Optional.of(new UnregisterStorageUnitEvent(databaseName, dataSourceUnitName.get()));
         }
         return Optional.empty();
     }
@@ -167,7 +167,7 @@ private Optional<GovernanceEvent> createStorageNodeChangedEvent(final String dat
         }
         dataSourceNodeName = DataSourceMetaDataNode.getDataSourceNameByDataSourceNodeNode(event.getKey());
         if (Type.DELETED == event.getType() && dataSourceNodeName.isPresent()) {
-            return dataSourceNodeName.map(optional -> new UnregisterStorageNodeEvent(databaseName, optional));
+            return Optional.of(new UnregisterStorageNodeEvent(databaseName, dataSourceNodeName.get()));
         }
         return Optional.empty();
     }

diff --git a/...ingsphere/mode/manager/cluster/coordinator/subscriber/ConfigurationChangedSubscriber.java b/...ingsphere/mode/manager/cluster/coordinator/subscriber/ConfigurationChangedSubscriber.java
@@ -42,7 +42,7 @@ public final class ConfigurationChangedSubscriber implements EventSubscriber {
      * @param event register storage unit event
      */
     @Subscribe
-    public void renew(final RegisterStorageUnitEvent event) {
+    public synchronized void renew(final RegisterStorageUnitEvent event) {
         if (!event.getActiveVersion().equals(contextManager.getPersistServiceFacade().getMetaDataPersistService().getMetaDataVersionPersistService()
                 .getActiveVersionByFullPath(event.getActiveVersionKey()))) {
             return;
@@ -57,7 +57,7 @@ public void renew(final RegisterStorageUnitEvent event) {
      * @param event register storage unit event
      */
     @Subscribe
-    public void renew(final AlterStorageUnitEvent event) {
+    public synchronized void renew(final AlterStorageUnitEvent event) {
         if (!event.getActiveVersion().equals(contextManager.getPersistServiceFacade().getMetaDataPersistService().getMetaDataVersionPersistService()
                 .getActiveVersionByFullPath(event.getActiveVersionKey()))) {
             return;
@@ -72,7 +72,7 @@ public void renew(final AlterStorageUnitEvent event) {
      * @param event register storage unit event
      */
     @Subscribe
-    public void renew(final UnregisterStorageUnitEvent event) {
+    public synchronized void renew(final UnregisterStorageUnitEvent event) {
         if (!contextManager.getMetaDataContexts().getMetaData().containsDatabase(event.getDatabaseName())) {
             return;
         }