summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAde Lee <alee@redhat.com>2012-10-11 23:17:45 -0400
committerAde Lee <alee@redhat.com>2012-10-11 23:55:12 -0400
commit212ab82665fae5846bb6ad97733ff9ce2c2cb675 (patch)
tree1dd80a93ca390b2b6b7da36619324877293d55e1
parent283af4291e7ec709a2ce4e115775044175abeaf2 (diff)
downloadpki-212ab82665fae5846bb6ad97733ff9ce2c2cb675.zip
pki-212ab82665fae5846bb6ad97733ff9ce2c2cb675.tar.gz
pki-212ab82665fae5846bb6ad97733ff9ce2c2cb675.tar.xz
Return to d9 behavior for RetrieveModificationsTask
-rw-r--r--base/common/src/com/netscape/cmscore/dbs/CertificateRepository.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/base/common/src/com/netscape/cmscore/dbs/CertificateRepository.java b/base/common/src/com/netscape/cmscore/dbs/CertificateRepository.java
index 2d3dead..97bc72a 100644
--- a/base/common/src/com/netscape/cmscore/dbs/CertificateRepository.java
+++ b/base/common/src/com/netscape/cmscore/dbs/CertificateRepository.java
@@ -1995,13 +1995,13 @@ class RetrieveModificationsTask implements Runnable {
throw e;
}
- // schedule task to run immediately and repeat without delay
+ // schedule task to run immediately
executorService = Executors.newSingleThreadScheduledExecutor(new ThreadFactory() {
public Thread newThread(Runnable r) {
return new Thread(r, "RetrieveModificationsTask");
}
});
- executorService.scheduleWithFixedDelay(this, 0, 1, TimeUnit.MICROSECONDS);
+ executorService.schedule(this, 0, TimeUnit.MICROSECONDS);
}
public void run() {
@@ -2010,7 +2010,7 @@ class RetrieveModificationsTask implements Runnable {
try {
// results.hasMoreElements() will block until next element becomes available
// or return false if the search is abandoned or connection is closed
- if (results.hasMoreElements()) {
+ while (results.hasMoreElements()) {
LDAPEntry entry = results.next();
repository.getModifications(entry);
}