Searched defs:pendingStatusMessages (Results 1 - 4 of 4) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java288 private PendingStatusMessages pendingStatusMessages = new PendingStatusMessages(); field in class:ReplicationServerDomain
1152 pendingStatusMessages.enqueueTopoInfoToAllRSs();
1156 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(null);
2058 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(dsHandler);
2059 pendingStatusMessages.enqueueTopoInfoToAllRSs();
2182 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(null);
2449 pendingStatusMessages.enqueueChangeTimeHeartbeatMsg(msg);
2616 savedState = pendingStatusMessages;
2617 pendingStatusMessages = new PendingStatusMessages();
2738 pendingStatusMessages
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java288 private PendingStatusMessages pendingStatusMessages = new PendingStatusMessages(); field in class:ReplicationServerDomain
1152 pendingStatusMessages.enqueueTopoInfoToAllRSs();
1156 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(null);
2058 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(dsHandler);
2059 pendingStatusMessages.enqueueTopoInfoToAllRSs();
2182 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(null);
2449 pendingStatusMessages.enqueueChangeTimeHeartbeatMsg(msg);
2616 savedState = pendingStatusMessages;
2617 pendingStatusMessages = new PendingStatusMessages();
2738 pendingStatusMessages
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationServerDomain.java276 private PendingStatusMessages pendingStatusMessages = new PendingStatusMessages(); field in class:ReplicationServerDomain
1126 pendingStatusMessages.enqueueTopoInfoToAllRSs();
1130 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(null);
1998 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(dsHandler);
1999 pendingStatusMessages.enqueueTopoInfoToAllRSs();
2117 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(null);
2378 pendingStatusMessages.enqueueChangeTimeHeartbeatMsg(msg);
2545 savedState = pendingStatusMessages;
2546 pendingStatusMessages = new PendingStatusMessages();
2666 pendingStatusMessages
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java282 private PendingStatusMessages pendingStatusMessages = field in class:ReplicationServerDomain
1191 pendingStatusMessages.enqueueTopoInfoToAllRSs();
1195 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(null);
1680 pendingStatusMessages.enqueueDSMonitorMsg(sender.getServerId(),
1690 pendingStatusMessages.enqueueRSMonitorMsg(sender.getServerId(),
2346 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(dsHandler);
2347 pendingStatusMessages.enqueueTopoInfoToAllRSs();
2511 pendingStatusMessages.enqueueTopoInfoToAllDSsExcept(null);
3252 pendingStatusMessages.enqueueChangeTimeHeartbeatMsg(msg);
3419 savedState = pendingStatusMessages;
[all...]

Completed in 52 milliseconds