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

Matthew Swift
25.02.2014 fe00a5949e3a06a8b20c5a84249594133e320226
refs
author Matthew Swift <matthew.swift@forgerock.com>
Tuesday, March 25, 2014 16:02 +0100
committer Matthew Swift <matthew.swift@forgerock.com>
Tuesday, March 25, 2014 16:02 +0100
commitfe00a5949e3a06a8b20c5a84249594133e320226
tree 146c3ba0c74e42a388e9eb60b1effe67635fb9af tree | zip | gz
parent 2857f2c02995e51deb3b0ccfe43e9ef554084791 view | diff
Fix OPENDJ-1354 - replication threads BLOCKED in pendingChanges queue

Decouple writing of status messages (change time heartbeats, monitor, and topology msgs) from RS reader threads through the use of a simple event service. It is now the responsibility of the StatusAnalyzer thread to send status messages when notified to do so by the ReplicationServerDomain. In addition, the Monitor*Msgs are no longer routable since they were only ever sent directly between peers. This simplifies some of the request processing in ReplicationServerDomain.

This change does not attempt to solve potential deadlocks arising from transmission of assured replication acks, status changes, generation ID updates, windowing messages (which are deprecated), total update messages, and error messages.
9 files modified
1076 ■■■■■ changed files
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/protocol/MonitorMsg.java 65 ●●●●● diff | view | raw | blame | history
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/protocol/MonitorRequestMsg.java 101 ●●●● diff | view | raw | blame | history
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/protocol/RoutableMsg.java 14 ●●●● diff | view | raw | blame | history
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/MonitoringPublisher.java 1 ●●●● diff | view | raw | blame | history
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServer.java 11 ●●●●● diff | view | raw | blame | history
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/ReplicationServerDomain.java 695 ●●●●● diff | view | raw | blame | history
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/ServerHandler.java 46 ●●●●● diff | view | raw | blame | history
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/ServerReader.java 14 ●●●●● diff | view | raw | blame | history
opendj-sdk/opendj3-server-dev/src/server/org/opends/server/replication/server/StatusAnalyzer.java 129 ●●●●● diff | view | raw | blame | history