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

Jean-Noel Rouvignac
22.28.2013 6945df4500d706d53a192c78d63e7d2c7e83258c
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
commit6945df4500d706d53a192c78d63e7d2c7e83258c
tree 803a7758f058b065693046d96f406aef0d0d27c5 tree | zip | gz
parent 6e36fd07b01a41ae72d06c84de64158f31d2f3bb 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
4 files added
13 files modified
775 ■■■■■ changed files
opendj-sdk/opends/resource/schema/02-config.ldif 3 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/admin/defn/org/opends/server/admin/std/HTTPConnectionHandlerConfiguration.xml 27 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/admin/messages/HTTPConnectionHandlerCfgDefn.properties 3 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/api/ClientConnection.java 10 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/api/WorkQueue.java 55 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/core/AbandonOperationWrapper.java 58 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/core/BoundedWorkQueueStrategy.java 246 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/core/DirectoryServer.java 55 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/core/ExtendedOperationWrapper.java 94 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/core/UnbindOperationWrapper.java 50 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/extensions/ParallelWorkQueue.java 51 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/extensions/TraditionalWorkQueue.java 69 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/protocols/http/SdkConnectionAdapter.java 17 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/protocols/internal/InternalClientConnection.java 8 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/protocols/jmx/JmxClientConnection.java 9 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/protocols/ldap/LDAPClientConnection.java 7 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/core/networkgroups/MockClientConnection.java 13 ●●●● diff | view | raw | blame | history