OPENDJ-832 Leverage the work queue for processing requests received on the ...

Jean-Noel Rouvignac

26.49.2013 582344d280d24dfec999b862d8255eb077995b99

 opends/src/server/org/opends/server/extensions/ParallelWorkerThread.java

@@ -23,24 +23,24 @@
 *
 *
 *      Copyright 2006-2009 Sun Microsystems, Inc.
 *      Portions copyright 2013 ForgeRock AS.
 */
package org.opends.server.extensions;
import org.opends.messages.Message;



import java.util.Map;

import org.opends.messages.Message;
import org.opends.server.api.DirectoryThread;
import org.opends.server.core.DirectoryServer;
import org.opends.server.types.AbstractOperation;
import org.opends.server.loggers.debug.DebugTracer;
import org.opends.server.types.CancelRequest;
import org.opends.server.types.DebugLogLevel;
import org.opends.server.types.DisconnectReason;
import org.opends.server.types.Operation;

import static org.opends.server.loggers.ErrorLogger.*;
import static org.opends.server.loggers.debug.DebugLogger.*;
import org.opends.server.loggers.debug.DebugTracer;
import static org.opends.messages.CoreMessages.*;
import static org.opends.server.util.StaticUtils.*;

@@ -57,24 +57,28 @@
   */
  private static final DebugTracer TRACER = getTracer();

  // Indicates whether the Directory Server is shutting down and this thread
  // should stop running.
  /**
   * Indicates whether the Directory Server is shutting down and this thread
   * should stop running.
   */
  private boolean shutdownRequested;

  // Indicates whether this thread was stopped because the server threadnumber
  // was reduced.
  /**
   * Indicates whether this thread was stopped because the server threadnumber
   * was reduced.
   */
  private boolean stoppedByReducedThreadNumber;

  // Indicates whether this thread is currently waiting for work.
  /** Indicates whether this thread is currently waiting for work. */
  private boolean waitingForWork;

  // The operation that this worker thread is currently processing.
  private AbstractOperation operation;
  /** The operation that this worker thread is currently processing. */
  private Operation operation;

  // The handle to the actual thread for this worker thread.
  /** The handle to the actual thread for this worker thread. */
  private Thread workerThread;

  // The work queue that this worker thread will service.
  /** The work queue that this worker thread will service. */
  private ParallelWorkQueue workQueue;