Skip to content

Commit 59eae27

Browse files
timwtglman
authored andcommitted
Detect when distributed plugin startup is complete.
1 parent fc5235a commit 59eae27

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

distributed/src/main/java/com/orientechnologies/orient/distributed/db/OrientDBDistributed.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@
2525
import com.orientechnologies.orient.core.db.OrientDBEmbedded;
2626
import com.orientechnologies.orient.core.db.document.ODatabaseDocumentEmbedded;
2727
import com.orientechnologies.orient.core.exception.ODatabaseException;
28-
import com.orientechnologies.orient.core.metadata.security.auth.OAuthenticationInfo;
2928
import com.orientechnologies.orient.core.storage.OStorage;
3029
import com.orientechnologies.orient.core.storage.disk.OLocalPaginatedStorage;
3130
import com.orientechnologies.orient.core.storage.impl.local.OAbstractPaginatedStorage;
@@ -112,7 +111,8 @@ private void waitForPluginStartup() {
112111
try {
113112
OLogManager.instance().info(this, "Waiting for plugin startup");
114113
if (!pluginStartupLatch.await(10, TimeUnit.SECONDS)) {
115-
throw new OOfflineNodeException("Distributed manager is offline on " + server.getServerId());
114+
throw new OOfflineNodeException(
115+
"Distributed manager is offline on " + server.getServerId());
116116
}
117117
OLogManager.instance().info(this, "Plugin startup complete");
118118
} catch (InterruptedException ignored) {
@@ -124,7 +124,7 @@ public void setPlugin(ODistributedPlugin plugin) {
124124
OLogManager.instance().info(this, "Setting plugin");
125125
this.plugin = plugin;
126126
this.pluginStartupLatch.countDown();
127-
}
127+
}
128128

129129
public ODistributedPlugin getPlugin() {
130130
OLogManager.instance()

0 commit comments

Comments
 (0)