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

gbellato
10.05.2006 988ec833bcc9d5dcca7ea59611102a39f08b025c
refs
author gbellato <gbellato@localhost>
Friday, November 10, 2006 09:05 +0100
committer gbellato <gbellato@localhost>
Friday, November 10, 2006 09:05 +0100
commit988ec833bcc9d5dcca7ea59611102a39f08b025c
tree fcffe64f183bf6eae150454fb00bfa7e936912c8 tree | zip | gz
parent 9137826c0afd4a59154444bfd0ec115f131b9c9a view | diff
issue 508 
These changes implement a window mechanism in the sycnhronization protocol.

Up to now the flow control mechanism used by the synchronization
was the TCP flow control mechanism. However, since TCP is not aware about
the type of the synchronization mechanism this was not allowing sending
of ACK messages when the TCP connection was saturated.
This was also preventing the implementation of the prioritized synchronization.

With these changes the TCP windows are set to a very large value and the
flow control is based on a configurable window size on the changelog servers
and on the LDAP servers.

These changes also add monitoring informations for the current and max window sizes.

I also took the opportunity to remove most the static variables and methods that were
preventing multi instantiation of the Changelog class.

I have also added tests for the incoding/decoding of ServerStartMessage and
ChangelogStartMessage, WindowMessage and for testing the window mechanism.

Also add the possibility to choose the port number used by the LDAP server when running
the unit test using property : org.opends.server.LdapPort
This can be usefull for debugging purpose.

reviewed by Daniel
3 files added
19 files modified
2240 ■■■■ changed files
opendj-sdk/opends/resource/schema/02-config.ldif 9 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/changelog/Changelog.java 92 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/changelog/ChangelogCache.java 29 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/changelog/ChangelogDB.java 176 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/changelog/ChangelogDbEnv.java 245 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/changelog/DbHandler.java 12 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/changelog/ServerHandler.java 122 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/changelog/ServerReader.java 7 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/changelog/SocketSession.java 4 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/synchronization/ChangelogBroker.java 101 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/synchronization/ChangelogStartMessage.java 33 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/synchronization/MultimasterSynchronization.java 2 ●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/synchronization/ServerStartMessage.java 32 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/synchronization/SynchronizationDomain.java 62 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/synchronization/SynchronizationMessage.java 4 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/synchronization/SynchronizationMonitor.java 86 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/synchronization/WindowMessage.java 141 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/TestCaseUtils.java 38 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/ProtocolWindowTest.java 494 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/StressTest.java 153 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/SynchronizationMsgTest.java 67 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/UpdateOperationTest.java 331 ●●●● diff | view | raw | blame | history