From 693421b38b25cf570415fbb205a78948c32afeb9 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Tue, 26 Mar 2013 16:57:29 +0000
Subject: [PATCH] OPENDJ-832 Leverage the work queue for processing requests received on the HTTP connection handler
---
opends/src/server/org/opends/server/protocols/internal/InternalClientConnection.java | 15 +++++++--------
1 files changed, 7 insertions(+), 8 deletions(-)
diff --git a/opends/src/server/org/opends/server/protocols/internal/InternalClientConnection.java b/opends/src/server/org/opends/server/protocols/internal/InternalClientConnection.java
index e276619..4a424e3 100644
--- a/opends/src/server/org/opends/server/protocols/internal/InternalClientConnection.java
+++ b/opends/src/server/org/opends/server/protocols/internal/InternalClientConnection.java
@@ -55,7 +55,7 @@
import static org.opends.messages.ProtocolMessages.*;
import static org.opends.server.config.ConfigConstants.*;
-import static org.opends.server.loggers.ErrorLogger.logError;
+import static org.opends.server.loggers.ErrorLogger.*;
import static org.opends.server.loggers.debug.DebugLogger.*;
import static org.opends.server.util.ServerConstants.*;
import static org.opends.server.util.StaticUtils.*;
@@ -88,20 +88,19 @@
- // The message ID counter to use for internal connections.
+ /** The message ID counter to use for internal connections. */
private static AtomicInteger nextMessageID;
- // The connection ID counter to use for internal connections.
+ /** The connection ID counter to use for internal connections. */
private static AtomicLong nextConnectionID;
- // The operation ID counter to use for operations on this
- // connection.
+ /** The operation ID counter to use for operations on this connection. */
private static AtomicLong nextOperationID;
- // The static connection for root-based connections.
+ /** The static connection for root-based connections. */
private static InternalClientConnection rootConnection;
- // The connection ID for this client connection.
+ /** The connection ID for this client connection. */
private final long connectionID;
@@ -2648,7 +2647,7 @@
mayExtend=false,
mayInvoke=false)
@Override()
- public AbstractOperation getOperationInProgress(int messageID)
+ public Operation getOperationInProgress(int messageID)
{
// Internal operations will not be tracked.
return null;
--
Gitblit v1.10.0