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

Jean-Noel Rouvignac
22.28.2013 269a1d06ff820c287bb21a03fa76e3314110516a
refs
author Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Monday, April 22, 2013 12:28 +0200
committer Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Monday, April 22, 2013 12:28 +0200
commit269a1d06ff820c287bb21a03fa76e3314110516a
tree 0523565549a67f32c7e2a7df74b159f944306a4b tree | zip | gz
parent 34dab7b840797f1d4ca8d269a2fbbb2f9ad2d26b view | diff
OPENDJ-832 Leverage the work queue for processing requests received on the HTTP connection handler



Limited the number of concurrent operations per client connection.



SdkConnectionAdapter.java:
Changed the queueing strategy to BoundedWorkQueueStrategy.

BoundedWorkQueueStrategy.java: ADDED

AbandonOperationWrapper.java, xtendedOperationWrapper.java, UnbindOperationWrapper.java: ADDED

DirectoryServer.java:
Extracted checkCanEnqueueRequest() from enqueueRequest().
Added tryEnqueueRequest().

WorkQueue.java:
Pulled computeNumWorkerThreads() here from sub classes.
Added abstract method trySubmitOperation().
Added abstract getter getNumWorkerThreads().

ParallelWorkQueue.java:
Implemented trySubmitOperation() and getter getNumWorkerThreads().
Renamed getNumWorkerThreads() to computeNumWorkerThreads() + moved it to WorkQueue.

TraditionalWorkQueue.java:
Implemented trySubmitOperation() and getter getNumWorkerThreads().
Renamed getNumWorkerThreads() to computeNumWorkerThreads() + moved it to WorkQueue.
Extacted overloaded method submitOperation(Operation, boolean) from submitOperation(Operation).



ClientConnection.java, JmxClientConnection.java, HTTPClientConnection.java, InternalClientConnection.java, MockClientConnection.java, LDAPClientConnection.java:
Added abstract method isConnectionValid() + implemented it in subclasses.



02-config.ldif, HTTPConnectionHandlerConfiguration.xml:
Added property max-concurrent-ops-per-connection
13 files modified
4 files added
775 ■■■■■ changed files
opends/resource/schema/02-config.ldif 3 ●●●● diff | view | raw | blame | history
opends/src/admin/defn/org/opends/server/admin/std/HTTPConnectionHandlerConfiguration.xml 27 ●●●●● diff | view | raw | blame | history
opends/src/admin/messages/HTTPConnectionHandlerCfgDefn.properties 3 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/api/ClientConnection.java 10 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/api/WorkQueue.java 55 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/core/AbandonOperationWrapper.java 58 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/core/BoundedWorkQueueStrategy.java 246 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/core/DirectoryServer.java 55 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/core/ExtendedOperationWrapper.java 94 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/core/UnbindOperationWrapper.java 50 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/extensions/ParallelWorkQueue.java 51 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/extensions/TraditionalWorkQueue.java 69 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/protocols/http/SdkConnectionAdapter.java 17 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/protocols/internal/InternalClientConnection.java 8 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/protocols/jmx/JmxClientConnection.java 9 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/protocols/ldap/LDAPClientConnection.java 7 ●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/core/networkgroups/MockClientConnection.java 13 ●●●● diff | view | raw | blame | history