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

mrossign
06.11.2009 3a9e211d36ee94ff99941943b3b51e0f768624f5
refs
author mrossign <mrossign@localhost>
Friday, November 6, 2009 10:11 +0100
committer mrossign <mrossign@localhost>
Friday, November 6, 2009 10:11 +0100
commit3a9e211d36ee94ff99941943b3b51e0f768624f5
tree c412500edcda2c68dfb53c0c7fceadff0a9bd6bd tree | zip | gz
parent 65fd707e4aefaf3c3f85774b1ca20e136b786253 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
opends/resource/schema/02-config.ldif 8 ●●●● diff | view | raw | blame | history
opends/src/admin/defn/org/opends/server/admin/std/ReplicationServerConfiguration.xml 23 ●●●●● diff | view | raw | blame | history
opends/src/messages/messages/replication.properties 2 ●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/common/DSInfo.java 18 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/common/RSInfo.java 30 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/protocol/MonitorMsg.java 18 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/protocol/MonitorRequestMsg.java 2 ●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/protocol/RoutableMsg.java 2 ●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/protocol/TopologyMsg.java 27 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/server/DataServerHandler.java 8 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/server/ReplicationServer.java 236 ●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java 378 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/server/ReplicationServerHandler.java 21 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/server/ServerHandler.java 17 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/service/ReplicationBroker.java 92 ●●●●● diff | view | raw | blame | history
opends/src/server/org/opends/server/replication/service/ReplicationDomain.java 57 ●●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ExternalChangeLogTest.java 6 ●●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/GenerationIdTest.java 89 ●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ReplicationTestCase.java 203 ●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/SchemaReplicationTest.java 6 ●●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/UpdateOperationTest.java 55 ●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/AssuredReplicationPluginTest.java 6 ●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/TopologyViewTest.java 2 ●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ProtocolCompatibilityTest.java 6 ●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/SynchronizationMsgTest.java 8 ●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/server/AssuredReplicationServerTest.java 8 ●●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ReplServerFakeConfiguration.java 18 ●●●●● diff | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ReplicationServerTest.java 6 ●●●● diff | view | raw | blame | history