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

gbellato
10.05.2006 26ff1f0755680cbce7b5bdb136750b2b1bc9e4ed
refs
author gbellato <gbellato@localhost>
Friday, November 10, 2006 09:05 +0100
committer gbellato <gbellato@localhost>
Friday, November 10, 2006 09:05 +0100
commit26ff1f0755680cbce7b5bdb136750b2b1bc9e4ed
tree 8787b9ce15b0655d775d83a7b11d244a7b22bd3c tree | zip | gz
parent fe962db1ca6c350a03cdff4ac6e0450909e0b56f 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
opends/resource/schema/02-config.ldif 9 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/changelog/Changelog.java 92 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/changelog/ChangelogCache.java 29 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/changelog/ChangelogDB.java 176 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/changelog/ChangelogDbEnv.java 245 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/changelog/DbHandler.java 12 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/changelog/ServerHandler.java 122 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/changelog/ServerReader.java 7 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/changelog/SocketSession.java 4 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/synchronization/ChangelogBroker.java 101 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/synchronization/ChangelogStartMessage.java 33 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/synchronization/MultimasterSynchronization.java 2 ●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/synchronization/ServerStartMessage.java 32 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/synchronization/SynchronizationDomain.java 62 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/synchronization/SynchronizationMessage.java 4 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/synchronization/SynchronizationMonitor.java 86 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/synchronization/WindowMessage.java 141 ●●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/TestCaseUtils.java 38 ●●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/ProtocolWindowTest.java 494 ●●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/StressTest.java 153 ●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/SynchronizationMsgTest.java 67 ●●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/UpdateOperationTest.java 331 ●●●● diff | view | raw | blame | history