svn commit: r1684618 - /jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/DocumentNodeStore.java

[reschke]

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();
         }