From d00ae6eb8ebca2516ab0543ee5d5b37d17befee3 Mon Sep 17 00:00:00 2001
From: coulbeck <coulbeck@localhost>
Date: Thu, 18 Jan 2007 23:35:45 +0000
Subject: [PATCH] Add a unit test case for the synchronization provider receive status. The test case fails so it is currently disabled.
---
opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java | 9 ++++++++-
1 files changed, 8 insertions(+), 1 deletions(-)
diff --git a/opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java b/opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java
index cfcde54..487d38d 100644
--- a/opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java
+++ b/opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java
@@ -431,6 +431,13 @@
{
/* was enabled and moved to disabled */
broker.suspendReceive();
+ // FIXME Need a way to stop these threads.
+ // Setting the shutdown flag does not stop them until they have
+ // consumed and discarded one more message each.
+// for (ListenerThread thread : synchroThreads)
+// {
+// thread.shutdown();
+// }
synchroThreads.clear();
}
receiveStatus = newReceiveStatus;
@@ -1012,7 +1019,7 @@
* TODO : need to make number of thread configurable
* TODO : need to handle operation dependencies
*/
- for (int i=0; i<10; i++)
+ for (int i=0; i<listenerThreadNumber; i++)
{
ListenerThread myThread = new ListenerThread(this);
myThread.start();
--
Gitblit v1.10.0