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

Jean-Noel Rouvignac
08.48.2015 a89f7014aeb71dba5c94404dfea7eb89e7eeee74
opendj-server-legacy/src/main/java/org/opends/server/extensions/ParallelWorkQueue.java
@@ -137,11 +137,10 @@
        computeNumWorkerThreads(configuration.getNumWorkerThreads());
    // Create the actual work queue.
    opQueue = new ConcurrentLinkedQueue<Operation>();
    opQueue = new ConcurrentLinkedQueue<>();
    // Create the set of worker threads that should be used to service the
    // work queue.
    workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
    // Create the set of worker threads that should be used to service the work queue.
    workerThreads = new ArrayList<>(numWorkerThreads);
    for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
    lastThreadNumber++)
    {
@@ -179,7 +178,7 @@
    // Send responses to any operations in the pending queue to indicate that
    // they won't be processed because the server is shutting down.
    CancelRequest cancelRequest = new CancelRequest(true, reason);
    ArrayList<Operation> pendingOperations = new ArrayList<Operation>();
    ArrayList<Operation> pendingOperations = new ArrayList<>();
    opQueue.removeAll(pendingOperations);
    for (Operation o : pendingOperations)