Searched refs:connectedRS (Results 1 - 3 of 3) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java139 sb.append("no connectedRS");
143 sb.append("connectedRS(serverId=").append(rsInfo.getServerId())
177 private final AtomicReference<ConnectedRS> connectedRS = field in class:ReplicationBroker
298 return connectedRS.get().getGroupId();
307 return connectedRS.get().getServerId();
829 // connectedRS has been updated by calls above, reload it
830 final ConnectedRS rs = connectedRS.get();
2162 reStart(connectedRS.get().session, infiniteTry);
2179 ConnectedRS rs = connectedRS.get();
2198 rs = connectedRS
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java139 sb.append("no connectedRS");
143 sb.append("connectedRS(serverId=").append(rsInfo.getServerId())
177 private final AtomicReference<ConnectedRS> connectedRS = field in class:ReplicationBroker
298 return connectedRS.get().getGroupId();
307 return connectedRS.get().getServerId();
829 // connectedRS has been updated by calls above, reload it
830 final ConnectedRS rs = connectedRS.get();
2162 reStart(connectedRS.get().session, infiniteTry);
2179 ConnectedRS rs = connectedRS.get();
2198 rs = connectedRS
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java136 sb.append("no connectedRS");
140 sb.append("connectedRS(serverId=").append(rsInfo.getServerId())
170 private final AtomicReference<ConnectedRS> connectedRS = new AtomicReference<>(ConnectedRS.noConnectedRS()); field in class:ReplicationBroker
289 return connectedRS.get().getGroupId();
298 return connectedRS.get().getServerId();
821 // connectedRS has been updated by calls above, reload it
822 final ConnectedRS rs = connectedRS.get();
2139 reStart(connectedRS.get().session, infiniteTry);
2156 ConnectedRS rs = connectedRS.get();
2175 rs = connectedRS
[all...]

Completed in 45 milliseconds