diff options
author | Ade Lee <alee@redhat.com> | 2012-10-11 23:17:45 -0400 |
---|---|---|
committer | Ade Lee <alee@redhat.com> | 2012-10-11 23:55:12 -0400 |
commit | 212ab82665fae5846bb6ad97733ff9ce2c2cb675 (patch) | |
tree | 1dd80a93ca390b2b6b7da36619324877293d55e1 /base/common | |
parent | 283af4291e7ec709a2ce4e115775044175abeaf2 (diff) | |
download | pki-212ab82665fae5846bb6ad97733ff9ce2c2cb675.tar.gz pki-212ab82665fae5846bb6ad97733ff9ce2c2cb675.tar.xz pki-212ab82665fae5846bb6ad97733ff9ce2c2cb675.zip |
Return to d9 behavior for RetrieveModificationsTask
Diffstat (limited to 'base/common')
-rw-r--r-- | base/common/src/com/netscape/cmscore/dbs/CertificateRepository.java | 6 |
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 2d3dead75..97bc72ab3 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); } |