From 263d085885df024dca9250cc03c807912b0a7662 Mon Sep 17 00:00:00 2001
From: Matthew Swift <matthew.swift@forgerock.com>
Date: Tue, 24 Apr 2012 22:33:21 +0000
Subject: [PATCH] Reformat to comply with new Checkstyle rules.
---
opendj3/opendj-ldap-sdk/src/main/java/com/forgerock/opendj/ldap/TimeoutChecker.java | 189 ++++++++++++++++++----------------------------
1 files changed, 75 insertions(+), 114 deletions(-)
diff --git a/opendj3/opendj-ldap-sdk/src/main/java/com/forgerock/opendj/ldap/TimeoutChecker.java b/opendj3/opendj-ldap-sdk/src/main/java/com/forgerock/opendj/ldap/TimeoutChecker.java
index cde7969..207a014 100644
--- a/opendj3/opendj-ldap-sdk/src/main/java/com/forgerock/opendj/ldap/TimeoutChecker.java
+++ b/opendj3/opendj-ldap-sdk/src/main/java/com/forgerock/opendj/ldap/TimeoutChecker.java
@@ -6,17 +6,16 @@
* (the "License"). You may not use this file except in compliance
* with the License.
*
- * You can obtain a copy of the license at
- * trunk/opendj3/legal-notices/CDDLv1_0.txt
+ * You can obtain a copy of the license at legal-notices/CDDLv1_0.txt
* or http://forgerock.org/license/CDDLv1.0.html.
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
- * file and include the License file at
- * trunk/opendj3/legal-notices/CDDLv1_0.txt. If applicable,
- * add the following below this CDDL HEADER, with the fields enclosed
- * by brackets "[]" replaced with your own identifying information:
+ * file and include the License file at legal-notices/CDDLv1_0.txt.
+ * If applicable, add the following below this CDDL HEADER, with the
+ * fields enclosed by brackets "[]" replaced with your own identifying
+ * information:
* Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
@@ -27,8 +26,6 @@
package com.forgerock.opendj.ldap;
-
-
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
@@ -37,122 +34,86 @@
import com.forgerock.opendj.util.StaticUtils;
-
-
/**
* Checks connection for pending requests that have timed out.
*/
-final class TimeoutChecker
-{
- static final TimeoutChecker INSTANCE = new TimeoutChecker();
+final class TimeoutChecker {
+ static final TimeoutChecker INSTANCE = new TimeoutChecker();
- private final LinkedTransferQueue<LDAPConnection> connections;
- private transient final ReentrantLock lock;
- private transient final Condition available;
+ private final LinkedTransferQueue<LDAPConnection> connections;
+ private transient final ReentrantLock lock;
+ private transient final Condition available;
+ private TimeoutChecker() {
+ this.connections = new LinkedTransferQueue<LDAPConnection>();
+ this.lock = new ReentrantLock();
+ this.available = lock.newCondition();
+ final Thread checkerThread = new Thread("Timeout Checker") {
+ @Override
+ public void run() {
+ StaticUtils.DEBUG_LOG.fine("Timeout Checker Starting");
+ final ReentrantLock lock = TimeoutChecker.this.lock;
+ lock.lock();
+ try {
+ while (true) {
+ final long currentTime = System.currentTimeMillis();
+ long delay = 0;
- private TimeoutChecker()
- {
- this.connections = new LinkedTransferQueue<LDAPConnection>();
- this.lock = new ReentrantLock();
- this.available = lock.newCondition();
+ for (final LDAPConnection connection : connections) {
+ StaticUtils.DEBUG_LOG.finer("Checking connection " + connection
+ + " delay = " + delay);
+ final long newDelay = connection.cancelExpiredRequests(currentTime);
+ if (newDelay > 0) {
+ if (delay > 0) {
+ delay = Math.min(newDelay, delay);
+ } else {
+ delay = newDelay;
+ }
+ }
+ }
- final Thread checkerThread = new Thread("Timeout Checker")
- {
- @Override
- public void run()
- {
- StaticUtils.DEBUG_LOG.fine("Timeout Checker Starting");
- final ReentrantLock lock = TimeoutChecker.this.lock;
+ try {
+ if (delay <= 0) {
+ StaticUtils.DEBUG_LOG.finer("There are no connections with "
+ + "timeout specified. Sleeping");
+ available.await();
+ } else {
+ StaticUtils.DEBUG_LOG.finer("Sleeping for " + delay + "ms");
+ available.await(delay, TimeUnit.MILLISECONDS);
+ }
+ } catch (final InterruptedException e) {
+ // Just go around again.
+ }
+ }
+ } finally {
+ lock.unlock();
+ }
+ }
+ };
+
+ checkerThread.setDaemon(true);
+ checkerThread.start();
+ }
+
+ void addConnection(final LDAPConnection connection) {
+ final ReentrantLock lock = this.lock;
lock.lock();
- try
- {
- while (true)
- {
- final long currentTime = System.currentTimeMillis();
- long delay = 0;
-
- for (final LDAPConnection connection : connections)
- {
- StaticUtils.DEBUG_LOG.finer("Checking connection " + connection
- + " delay = " + delay);
- final long newDelay = connection
- .cancelExpiredRequests(currentTime);
- if (newDelay > 0)
- {
- if (delay > 0)
- {
- delay = Math.min(newDelay, delay);
- }
- else
- {
- delay = newDelay;
- }
- }
- }
-
- try
- {
- if (delay <= 0)
- {
- StaticUtils.DEBUG_LOG.finer("There are no connections with "
- + "timeout specified. Sleeping");
- available.await();
- }
- else
- {
- StaticUtils.DEBUG_LOG.finer("Sleeping for " + delay + "ms");
- available.await(delay, TimeUnit.MILLISECONDS);
- }
- }
- catch (final InterruptedException e)
- {
- // Just go around again.
- }
- }
+ try {
+ connections.add(connection);
+ available.signalAll();
+ } finally {
+ lock.unlock();
}
- finally
- {
- lock.unlock();
+ }
+
+ void removeConnection(final LDAPConnection connection) {
+ final ReentrantLock lock = this.lock;
+ lock.lock();
+ try {
+ connections.remove(connection);
+ } finally {
+ lock.unlock();
}
- }
- };
-
- checkerThread.setDaemon(true);
- checkerThread.start();
- }
-
-
-
- void addConnection(final LDAPConnection connection)
- {
- final ReentrantLock lock = this.lock;
- lock.lock();
- try
- {
- connections.add(connection);
- available.signalAll();
}
- finally
- {
- lock.unlock();
- }
- }
-
-
-
- void removeConnection(final LDAPConnection connection)
- {
- final ReentrantLock lock = this.lock;
- lock.lock();
- try
- {
- connections.remove(connection);
- }
- finally
- {
- lock.unlock();
- }
- }
}
--
Gitblit v1.10.0