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

Jean-Noel Rouvignac
26.49.2013 582344d280d24dfec999b862d8255eb077995b99
refs
author Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Tuesday, March 26, 2013 15:49 +0100
committer Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Tuesday, March 26, 2013 15:49 +0100
commit582344d280d24dfec999b862d8255eb077995b99
tree 264b1285e60436350985b7006808fc7e58b703d8 tree | zip | gz
parent fed2260bb82aee980b09668c64c9e9dea1c21825 view | diff
OPENDJ-832 Leverage the work queue for processing requests received on the HTTP connection handler 

Code cleanup: Changed code from using AbstractOperation abstract class to using Operation interface instead.



Operation.java
Now extends Runnable.

OperationWrapper.java
Consequence of the change to Operation.java.


WorkQueue.java:
In submitOperation(), used Operation interface instead of AbstractOperation abstract class.

DirectoryServer.java:
In enqueueRequest() used Operation interface instead of AbstractOperation abstract class.
Removed CLASS_NAME constant, used this class's name in getClassName().

ParallelWorkerThread.java:
Changed instance member operation from AbstractOperation abstract class to Operation interface.

ParallelWorkQueue.java:
Changed instance member opQueue from ConcurrentLinkedQueue<AbstractOperation> to ConcurrentLinkedQueue<Operation>.
In submitOperation(), nextOperation() and retryNextOperation(), used Operation interface instead of AbstractOperation abstract class.

TraditionalWorkerThread.java
Changed instance member operation from AbstractOperation abstract class to Operation interface.
In shutDown() used Operation interface instead of AbstractOperation abstract class.

TraditionalWorkQueue.java
Changed instance member opQueue from LinkedBlockingQueue<AbstractOperation> to LinkedBlockingQueue<Operation>.
In initializeWorkQueue(), submitOperation(), nextOperation(), retryNextOperation() and applyConfigurationChange(), used Operation interface instead of AbstractOperation abstract class.
In applyConfigurationChange(), remove a duplicate condition check.



All files:
Converted java comments to javadocs.
Added @Override annotations.
8 files modified
769 ■■■■■ changed files
opends/src/server/org/opends/server/api/WorkQueue.java 9 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/core/DirectoryServer.java 454 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/core/OperationWrapper.java 72 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/extensions/ParallelWorkQueue.java 50 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/extensions/ParallelWorkerThread.java 30 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/extensions/TraditionalWorkQueue.java 106 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/extensions/TraditionalWorkerThread.java 35 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/types/Operation.java 13 ●●●● diff | view | raw | blame | history