mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

neil_a_wilson
01.18.2007 3e3246e42af6979556dec66ec10ad3d3e009217c
opendj-sdk/opends/src/server/org/opends/server/extensions/TraditionalWorkQueue.java
@@ -132,7 +132,6 @@
   */
  public TraditionalWorkQueue()
  {
    // No implementation should be performed here.
  }
@@ -144,8 +143,6 @@
  public void initializeWorkQueue(ConfigEntry configEntry)
         throws ConfigException, InitializationException
  {
    shutdownRequested = false;
    killThreads       = false;
    opsSubmitted      = new AtomicLong(0);
@@ -312,7 +309,6 @@
   */
  public void finalizeWorkQueue(String reason)
  {
    shutdownRequested = true;
@@ -372,7 +368,6 @@
   */
  public boolean shutdownRequested()
  {
    return shutdownRequested;
  }
@@ -392,7 +387,6 @@
  public void submitOperation(Operation operation)
         throws DirectoryException
  {
    if (shutdownRequested)
    {
      int    messageID = MSGID_OP_REJECTED_BY_SHUTDOWN;
@@ -427,7 +421,6 @@
   */
  public Operation nextOperation(TraditionalWorkerThread workerThread)
  {
    return retryNextOperation(workerThread, 0);
  }
@@ -452,8 +445,6 @@
  private Operation retryNextOperation(TraditionalWorkerThread workerThread,
                                       int numFailures)
  {
    // See if we should kill off this thread.  This could be necessary if the
    // number of worker threads has been decreased with the server online.  If
    // so, then return null and the thread will exit.
@@ -611,7 +602,6 @@
   */
  public boolean removeOperation(Operation operation)
  {
    return opQueue.remove(operation);
  }
@@ -628,7 +618,6 @@
   */
  public long getOpsSubmitted()
  {
    return opsSubmitted.longValue();
  }
@@ -643,7 +632,6 @@
   */
  public long getOpsRejectedDueToQueueFull()
  {
    return queueFullRejects.longValue();
  }
@@ -660,7 +648,6 @@
   */
  public int size()
  {
    return opQueue.size();
  }
@@ -675,7 +662,6 @@
   */
  public DN getConfigurableComponentEntryDN()
  {
    return configEntryDN;
  }
@@ -690,7 +676,6 @@
   */
  public List<ConfigAttribute> getConfigurationAttributes()
  {
    LinkedList<ConfigAttribute> attrList = new LinkedList<ConfigAttribute>();
@@ -732,8 +717,6 @@
  public boolean hasAcceptableConfiguration(ConfigEntry configEntry,
                                            List<String> unacceptableReasons)
  {
    boolean configIsAcceptable = true;
@@ -855,8 +838,6 @@
  public ConfigChangeResult applyNewConfiguration(ConfigEntry configEntry,
                                                  boolean detailedResults)
  {
    ArrayList<String> resultMessages = new ArrayList<String>();
    int newNumThreads;
    int newMaxCapacity;
@@ -1105,7 +1086,6 @@
   */
  public boolean isIdle()
  {
    if (opQueue.size() > 0)
    {
      return false;