Searched refs:MonitorMsg (Results 1 - 25 of 49) sorted by relevance

12

/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DMonitoringPublisher.java33 import org.opends.server.replication.protocol.MonitorMsg;
97 final MonitorMsg monitorMsg =
H A DReplicationServerDomain.java63 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 DMonitoringPublisher.java33 import org.opends.server.replication.protocol.MonitorMsg;
97 final MonitorMsg monitorMsg =
H A DReplicationServerDomain.java63 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 DMonitoringPublisher.java33 import org.opends.server.replication.protocol.MonitorMsg;
91 final MonitorMsg monitorMsg =
H A DReplicationServerDomain.java61 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 DServerReader.java124 else if (msg instanceof MonitorMsg)
126 handler.processMonitorMsg((MonitorMsg) msg);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DMonitoringPublisher.java36 import org.opends.server.replication.protocol.MonitorMsg;
103 MonitorMsg monitorMsg =
H A DReplicationServerDomain.java215 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 DMonitoringPublisher.java36 import org.opends.server.replication.protocol.MonitorMsg;
114 MonitorMsg monitorMsg = replicationServerDomain
H A DServerReader.java250 } else if (msg instanceof MonitorMsg)
252 MonitorMsg replServerMonitorMsg = (MonitorMsg) msg;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DMonitoringPublisher.java36 import org.opends.server.replication.protocol.MonitorMsg;
114 MonitorMsg monitorMsg = replicationServerDomain
H A DServerReader.java250 } else if (msg instanceof MonitorMsg)
252 MonitorMsg replServerMonitorMsg = (MonitorMsg) msg;
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DMonitorMsg.java46 * 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 DReplicationMsg.java188 return new MonitorMsg(buffer, protocolVersion);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DMonitorMsg.java46 * 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 DReplicationMsg.java188 return new MonitorMsg(buffer, protocolVersion);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DMonitorMsg.java46 * 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 DReplicationMsg.java188 return new MonitorMsg(buffer, protocolVersion);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DMonitorMsg.java51 * 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 DReplicationMsg.java193 return new MonitorMsg(buffer, protocolVersion);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DMonitorMsg.java51 * 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 DReplicationMsg.java193 return new MonitorMsg(buffer, protocolVersion);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DMonitorMsg.java51 * 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 DReplicationMsg.java193 return new MonitorMsg(buffer, protocolVersion);

Completed in 100 milliseconds

12