From 2ec1e20dacc4606317fc9e38890117df638a1fff Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Mon, 11 Feb 2008 13:42:42 +0000
Subject: [PATCH]
---
opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplayThread.java | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplayThread.java b/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplayThread.java
index 3774933..3ff5c08 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplayThread.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplayThread.java
@@ -56,6 +56,7 @@
private BlockingQueue<UpdateToReplay> updateToReplayQueue = null;
private boolean shutdown = false;
private boolean done = false;
+ private static int count = 0;
/**
* Constructor for the ReplayThread.
@@ -64,7 +65,7 @@
*/
public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue)
{
- super("Replication Replay thread");
+ super("Replication Replay thread " + count++);
this.updateToReplayQueue = updateToReplayQueue;
}
@@ -130,7 +131,7 @@
{
try
{
- while (done == false)
+ while ((done == false) && (this.isAlive()))
{
Thread.sleep(50);
}
--
Gitblit v1.10.0