/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | MonitoringPublisher.java | 33 import org.opends.server.replication.protocol.MonitorMsg; 97 final MonitorMsg monitorMsg =
|
H A D | ReplicationServerDomain.java | 63 import org.opends.server.replication.protocol.MonitorMsg; 208 private final Map<Integer, MonitorMsg> pendingDSMonitorMsgs = 209 new HashMap<Integer, MonitorMsg>(1); 210 private final Map<Integer, MonitorMsg> pendingRSMonitorMsgs = 211 new HashMap<Integer, MonitorMsg>(1); 261 private void enqueueDSMonitorMsg(int dsServerId, MonitorMsg msg) 266 private void enqueueRSMonitorMsg(int rsServerId, MonitorMsg msg) 1464 void processMonitorMsg(MonitorMsg msg, ServerHandler sender) 1575 * @return The newly created and filled MonitorMsg. Null if a problem occurred 1580 public MonitorMsg createGlobalTopologyMonitorMs [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | MonitoringPublisher.java | 33 import org.opends.server.replication.protocol.MonitorMsg; 97 final MonitorMsg monitorMsg =
|
H A D | ReplicationServerDomain.java | 63 import org.opends.server.replication.protocol.MonitorMsg; 208 private final Map<Integer, MonitorMsg> pendingDSMonitorMsgs = 209 new HashMap<Integer, MonitorMsg>(1); 210 private final Map<Integer, MonitorMsg> pendingRSMonitorMsgs = 211 new HashMap<Integer, MonitorMsg>(1); 261 private void enqueueDSMonitorMsg(int dsServerId, MonitorMsg msg) 266 private void enqueueRSMonitorMsg(int rsServerId, MonitorMsg msg) 1464 void processMonitorMsg(MonitorMsg msg, ServerHandler sender) 1575 * @return The newly created and filled MonitorMsg. Null if a problem occurred 1580 public MonitorMsg createGlobalTopologyMonitorMs [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | MonitoringPublisher.java | 33 import org.opends.server.replication.protocol.MonitorMsg; 91 final MonitorMsg monitorMsg =
|
H A D | ReplicationServerDomain.java | 61 import org.opends.server.replication.protocol.MonitorMsg; 198 private final Map<Integer, MonitorMsg> pendingDSMonitorMsgs = new HashMap<>(1); 199 private final Map<Integer, MonitorMsg> pendingRSMonitorMsgs = new HashMap<>(1); 249 private void enqueueDSMonitorMsg(int dsServerId, MonitorMsg msg) 254 private void enqueueRSMonitorMsg(int rsServerId, MonitorMsg msg) 1425 void processMonitorMsg(MonitorMsg msg, ServerHandler sender) 1529 * @return The newly created and filled MonitorMsg. Null if a problem occurred 1534 public MonitorMsg createGlobalTopologyMonitorMsg(int sender, int destination) 1541 private MonitorMsg createGlobalTopologyMonitorMsg(int sender, 1544 final MonitorMsg returnMs [all...] |
H A D | ServerReader.java | 124 else if (msg instanceof MonitorMsg) 126 handler.processMonitorMsg((MonitorMsg) msg);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | MonitoringPublisher.java | 36 import org.opends.server.replication.protocol.MonitorMsg; 103 MonitorMsg monitorMsg =
|
H A D | ReplicationServerDomain.java | 215 private final Map<Integer, MonitorMsg> pendingDSMonitorMsgs = 216 new HashMap<Integer, MonitorMsg>(1); 217 private final Map<Integer, MonitorMsg> pendingRSMonitorMsgs = 218 new HashMap<Integer, MonitorMsg>(1); 268 private void enqueueDSMonitorMsg(int dsServerId, MonitorMsg msg) 273 private void enqueueRSMonitorMsg(int rsServerId, MonitorMsg msg) 1670 * list of all servers in the topology and send back a MonitorMsg with the 1675 MonitorMsg monitorMsg = 1686 MonitorMsg monitorMsg = 1705 void processMonitorMsg(MonitorMsg ms [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | MonitoringPublisher.java | 36 import org.opends.server.replication.protocol.MonitorMsg; 114 MonitorMsg monitorMsg = replicationServerDomain
|
H A D | ServerReader.java | 250 } else if (msg instanceof MonitorMsg) 252 MonitorMsg replServerMonitorMsg = (MonitorMsg) msg;
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | MonitoringPublisher.java | 36 import org.opends.server.replication.protocol.MonitorMsg; 114 MonitorMsg monitorMsg = replicationServerDomain
|
H A D | ServerReader.java | 250 } else if (msg instanceof MonitorMsg) 252 MonitorMsg replServerMonitorMsg = (MonitorMsg) msg;
|
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | MonitorMsg.java | 46 * MonitorMsg. 48 public class MonitorMsg extends ReplicationMsg class in inherits:ReplicationMsg 92 * Creates a new MonitorMsg. 97 public MonitorMsg(int sender, int destination) method in class:MonitorMsg 186 MonitorMsg(byte[] in, short version) throws DataFormatException method in class:MonitorMsg
|
H A D | ReplicationMsg.java | 188 return new MonitorMsg(buffer, protocolVersion);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | MonitorMsg.java | 46 * MonitorMsg. 48 public class MonitorMsg extends ReplicationMsg class in inherits:ReplicationMsg 92 * Creates a new MonitorMsg. 97 public MonitorMsg(int sender, int destination) method in class:MonitorMsg 186 MonitorMsg(byte[] in, short version) throws DataFormatException method in class:MonitorMsg
|
H A D | ReplicationMsg.java | 188 return new MonitorMsg(buffer, protocolVersion);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | MonitorMsg.java | 46 * MonitorMsg. 48 public class MonitorMsg extends ReplicationMsg class in inherits:ReplicationMsg 90 * Creates a new MonitorMsg. 95 public MonitorMsg(int sender, int destination) method in class:MonitorMsg 184 MonitorMsg(byte[] in, short version) throws DataFormatException method in class:MonitorMsg
|
H A D | ReplicationMsg.java | 188 return new MonitorMsg(buffer, protocolVersion);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | MonitorMsg.java | 51 * MonitorMsg. 53 public class MonitorMsg extends RoutableMsg class in inherits:RoutableMsg 86 * Creates a new MonitorMsg. 91 public MonitorMsg(int sender, int destination) method in class:MonitorMsg 202 public MonitorMsg(byte[] in, short version) throws DataFormatException method in class:MonitorMsg
|
H A D | ReplicationMsg.java | 193 return new MonitorMsg(buffer, protocolVersion);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | MonitorMsg.java | 51 * MonitorMsg. 53 public class MonitorMsg extends ReplicationMsg class in inherits:ReplicationMsg 98 * Creates a new MonitorMsg. 103 public MonitorMsg(int sender, int destination) method in class:MonitorMsg 197 public MonitorMsg(byte[] in, short version) throws DataFormatException method in class:MonitorMsg
|
H A D | ReplicationMsg.java | 193 return new MonitorMsg(buffer, protocolVersion);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | MonitorMsg.java | 51 * MonitorMsg. 53 public class MonitorMsg extends RoutableMsg class in inherits:RoutableMsg 86 * Creates a new MonitorMsg. 91 public MonitorMsg(int sender, int destination) method in class:MonitorMsg 202 public MonitorMsg(byte[] in, short version) throws DataFormatException method in class:MonitorMsg
|
H A D | ReplicationMsg.java | 193 return new MonitorMsg(buffer, protocolVersion);
|