Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Fixed problem with distributed logs

  • Loading branch information...
commit 5c99ceea70301babd34bf8e858ba62e7a9e5c7a3 1 parent 91c3c55
@lvca lvca authored
View
36 ...er/src/main/java/com/orientechnologies/orient/server/distributed/ODistributedStorage.java
@@ -15,6 +15,22 @@
*/
package com.orientechnologies.orient.server.distributed;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.TimerTask;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicLong;
+
import com.orientechnologies.common.concur.ONeedRetryException;
import com.orientechnologies.common.concur.resource.OSharedResourceAdaptiveExternal;
import com.orientechnologies.common.exception.OException;
@@ -62,22 +78,6 @@
import com.orientechnologies.orient.server.distributed.task.OTxTask;
import com.orientechnologies.orient.server.distributed.task.OUpdateRecordTask;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.TimerTask;
-import java.util.concurrent.Callable;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.atomic.AtomicLong;
-
/**
* Distributed storage implementation that routes to the owner node the request.
*
@@ -97,8 +97,8 @@ public ODistributedStorage(final OServer iServer, final OStorageEmbedded wrapped
this.dManager = iServer.getDistributedManager();
this.wrapped = wrapped;
- ODistributedServerLog.info(this, dManager.getLocalNodeName(), null, ODistributedServerLog.DIRECTION.NONE,
- "Installing distributed storage on database '%s'", wrapped.getName());
+ ODistributedServerLog.info(this, dManager != null ? dManager.getLocalNodeName() : "?", null,
+ ODistributedServerLog.DIRECTION.NONE, "Installing distributed storage on database '%s'", wrapped.getName());
purgeDeletedRecordsTask = new TimerTask() {
@Override
Please sign in to comment.
Something went wrong with that request. Please try again.