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

mrossign
06.11.2009 b1ab1b61b2a5cb4a09cd2e727e05f42feb8ca669
refs
author mrossign <mrossign@localhost>
Friday, November 6, 2009 10:11 +0100
committer mrossign <mrossign@localhost>
Friday, November 6, 2009 10:11 +0100
commitb1ab1b61b2a5cb4a09cd2e727e05f42feb8ca669
tree 3dae0d73e92399dd79b62b15f7d7bb382b6e9879 tree | zip | gz
parent f155e5c61d449b95eb11a375506930aa475c47a9 view | diff
In order to support a more clever algorithm for the DS to choose his RS, 
we introduce:



- a weigth, which is an integer affected to each RS that combined with
each others will define a percentage value which matches the number of
DSs (compared with total number od DSs in the topology) that can be
connected to the RS at a time in the topology. In these modif, this
configuration of the weight is added as well as dynamic changes. Also
transported in Topo messages. No modification of the connection
algorithm yet



- Also to support the future connection algorithm, these modifs
introduces a Monitoring Publisher thread which is a thread that sens
every 3 seconds a Monitoring message (unchanged format) to every DSs
that are connected to him. These information will be used by the DSs to
potentially reconnect to another RSs with a newer server state (info
included in monitoring messages)



The new connection algorithm will take into account:

- group id

- generation id

- server states

- locality (same VM)

- weight (load)

28 files modified
1352 ■■■■■ changed files
opendj-sdk/opends/resource/schema/02-config.ldif 8 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/admin/defn/org/opends/server/admin/std/ReplicationServerConfiguration.xml 23 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/messages/messages/replication.properties 2 ●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/common/DSInfo.java 18 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/common/RSInfo.java 30 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/protocol/MonitorMsg.java 18 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/protocol/MonitorRequestMsg.java 2 ●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/protocol/RoutableMsg.java 2 ●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/protocol/TopologyMsg.java 27 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/server/DataServerHandler.java 8 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServer.java 236 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java 378 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServerHandler.java 21 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/server/ServerHandler.java 17 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java 92 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java 57 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ExternalChangeLogTest.java 6 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/GenerationIdTest.java 89 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ReplicationTestCase.java 203 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/SchemaReplicationTest.java 6 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/UpdateOperationTest.java 55 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/AssuredReplicationPluginTest.java 6 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/TopologyViewTest.java 2 ●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ProtocolCompatibilityTest.java 6 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/SynchronizationMsgTest.java 8 ●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/server/AssuredReplicationServerTest.java 8 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ReplServerFakeConfiguration.java 18 ●●●●● diff | view | raw | blame | history
opendj-sdk/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ReplicationServerTest.java 6 ●●●● diff | view | raw | blame | history