Rename distributed network manager

orientechnologies · Jan 3, 2019 · 43ce617 · 43ce617
1 parent 84a1cdf
commit 43ce617
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 56 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/...-v2/src/main/java/com/orientechnologies/orient/distributed/impl/ORemoteServerManager.java b/...-v2/src/main/java/com/orientechnologies/orient/distributed/impl/ORemoteServerManager.java