Rename distributed network manager

orientechnologies · Jan 3, 2019 · 1fbc4c0 · 1fbc4c0
1 parent aed9cc6
commit 1fbc4c0
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/...c/main/java/com/orientechnologies/orient/distributed/impl/ODistributedAbstractPlugin.java b/...c/main/java/com/orientechnologies/orient/distributed/impl/ODistributedAbstractPlugin.java
@@ -108,12 +108,12 @@ public abstract class ODistributedAbstractPlugin extends OServerPluginAbstract
   protected          File                                       defaultDatabaseConfigFile;
   protected final    ConcurrentMap<String, ODistributedStorage> storages  = new ConcurrentHashMap<String, ODistributedStorage>();
   protected volatile NODE_STATUS                                status    = NODE_STATUS.OFFLINE;
-  protected long                                lastClusterChangeOn;
+  protected          long                                       lastClusterChangeOn;
-  protected List<ODistributedLifecycleListener> listeners                         = new ArrayList<ODistributedLifecycleListener>();
+  protected          List<ODistributedLifecycleListener>        listeners                         = new ArrayList<ODistributedLifecycleListener>();
-  protected ORemoteServerManager                remoteServerManager;
+  protected          ODistributedNetworkManager                 remoteServerManager;
-  protected TimerTask                           publishLocalNodeConfigurationTask = null;
+  protected          TimerTask                                  publishLocalNodeConfigurationTask = null;
-  protected TimerTask                           haStatsTask                       = null;
+  protected          TimerTask                                  haStatsTask                       = null;
-  protected OClusterHealthChecker               healthCheckerTask                 = null;
+  protected          OClusterHealthChecker                      healthCheckerTask                 = null;
 
   // LOCAL MSG COUNTER
   protected AtomicLong                          localMessageIdCounter     = new AtomicLong();
@@ -190,7 +190,7 @@ public void config(OServer oServer, OServerParameterConfiguration[] iParams) {
       throw OException.wrapException(new OConfigurationException("Error on deleting 'replicator' user"), e);
     }
 
-    this.remoteServerManager = new ORemoteServerManager(nodeName, new ORemoteServerAvailabilityCheck() {
+    this.remoteServerManager = new ODistributedNetworkManager(nodeName, new ORemoteServerAvailabilityCheck() {
       @Override
       public boolean isNodeAvailable(String node) {
         return ODistributedAbstractPlugin.this.isNodeAvailable(node);

diff --git a/...istributed/impl/ORemoteServerManager.java → ...uted/impl/ODistributedNetworkManager.java b/...istributed/impl/ORemoteServerManager.java → ...uted/impl/ODistributedNetworkManager.java
@@ -7,13 +7,13 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 
-public class ORemoteServerManager {
+public class ODistributedNetworkManager {
 
   private final ConcurrentMap<String, ORemoteServerController> remoteServers = new ConcurrentHashMap<String, ORemoteServerController>();
   private final String                                         localNodeName;
   private final ORemoteServerAvailabilityCheck                 check;
 
-  public ORemoteServerManager(String localNodeName, ORemoteServerAvailabilityCheck check) {
+  public ODistributedNetworkManager(String localNodeName, ORemoteServerAvailabilityCheck check) {
     this.localNodeName = localNodeName;
     this.check = check;
   }