You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by re...@apache.org on 2015/06/10 11:34:24 UTC
svn commit: r1684618 -
/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java
Author: reschke
Date: Wed Jun 10 09:34:23 2015
New Revision: 1684618
URL: http://svn.apache.org/r1684618
Log:
OAK-2971: DocumentNodeStore: include cluster node id in background thread names
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java
Modified: jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java?rev=1684618&r1=1684617&r2=1684618&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java (original)
+++ jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java Wed Jun 10 09:34:23 2015
@@ -459,14 +459,15 @@ public final class DocumentNodeStore
return DocumentNodeStore.this.newRevision();
}
};
+ String threadNamePostfix = "(" + clusterId + ")";
batchCommitQueue = new BatchCommitQueue(store, revisionComparator);
backgroundReadThread = new Thread(
new BackgroundReadOperation(this, isDisposed),
- "DocumentNodeStore background read thread");
+ "DocumentNodeStore background read thread " + threadNamePostfix);
backgroundReadThread.setDaemon(true);
backgroundUpdateThread = new Thread(
new BackgroundOperation(this, isDisposed),
- "DocumentNodeStore background update thread");
+ "DocumentNodeStore background update thread " + threadNamePostfix);
backgroundUpdateThread.setDaemon(true);
checkLastRevRecovery();
// Renew the lease because it may have been stale
@@ -478,7 +479,7 @@ public final class DocumentNodeStore
if (clusterNodeInfo != null) {
leaseUpdateThread = new Thread(
new BackgroundLeaseUpdate(this, isDisposed),
- "DocumentNodeStore lease update thread");
+ "DocumentNodeStore lease update thread " + threadNamePostfix);
leaseUpdateThread.setDaemon(true);
leaseUpdateThread.start();
}