/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | MonitoringPublisher.java | 58 private final ReplicationServerDomain replicationServerDomain; field in class:MonitoringPublisher 70 * @param replicationServerDomain The ReplicationServerDomain the monitoring 74 public MonitoringPublisher(ReplicationServerDomain replicationServerDomain, argument 78 + replicationServerDomain.getReplicationServer() 80 + replicationServerDomain.getBaseDn() + "\""); 82 this.replicationServerDomain = replicationServerDomain; 95 + replicationServerDomain.getBaseDn()); 111 MonitorData monitorData = replicationServerDomain 114 MonitorMsg monitorMsg = replicationServerDomain [all...] |
H A D | ServerWriter.java | 60 private final ReplicationServerDomain replicationServerDomain; field in class:ServerWriter 72 * @param replicationServerDomain 76 ReplicationServerDomain replicationServerDomain) 89 this.replicationServerDomain = replicationServerDomain; 108 UpdateMsg update = replicationServerDomain.take(this.handler); 136 replicationServerDomain.getGenerationId(); 160 replicationServerDomain.getGenerationId(); 181 "In " + replicationServerDomain.getReplicationServer(). 250 replicationServerDomain 75 ServerWriter(Session session, ServerHandler handler, ReplicationServerDomain replicationServerDomain) argument [all...] |
H A D | StatusAnalyzer.java | 59 private final ReplicationServerDomain replicationServerDomain; field in class:StatusAnalyzer 71 * @param replicationServerDomain The ReplicationServerDomain the status 76 public StatusAnalyzer(ReplicationServerDomain replicationServerDomain, argument 80 + replicationServerDomain.getReplicationServer() 82 + replicationServerDomain.getBaseDn() + "\""); 84 this.replicationServerDomain = replicationServerDomain; 98 replicationServerDomain.getBaseDn()); 129 replicationServerDomain.getConnectedDSs(). values()) 136 replicationServerDomain [all...] |
H A D | ECLServerWriter.java | 66 private ReplicationServerDomain replicationServerDomain; field in class:ECLServerWriter 76 * @param replicationServerDomain the ReplicationServerDomain of this 80 ReplicationServerDomain replicationServerDomain) 82 super(session, handler, replicationServerDomain); 89 this.replicationServerDomain = replicationServerDomain; 207 if (replicationServerDomain!=null) 208 replicationServerDomain.stopServer(handler, false); 79 ECLServerWriter(Session session, ECLServerHandler handler, ReplicationServerDomain replicationServerDomain) argument
|
H A D | MessageHandler.java | 95 protected ReplicationServerDomain replicationServerDomain = null; field in class:MessageHandler 209 if (replicationServerDomain==null) 211 replicationServerDomain = 215 return replicationServerDomain; 314 for (int serverId : replicationServerDomain.getServers()) 318 ReplicationIterator iterator = replicationServerDomain 497 for (int serverId : replicationServerDomain.getServers()) 503 replicationServerDomain.getChangelogIterator(serverId, lastCsn); 576 ServerState dbState = replicationServerDomain.getDbServerState(); 679 this.replicationServerDomain [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ServerWriter.java | 59 private final ReplicationServerDomain replicationServerDomain; field in class:ServerWriter 70 * @param replicationServerDomain 75 ReplicationServerDomain replicationServerDomain, 85 this.replicationServerDomain = replicationServerDomain; 107 || !dsrsShutdownSync.canShutdown(replicationServerDomain.getBaseDN())) 109 final UpdateMsg updateMsg = replicationServerDomain.take(this.handler); 123 dsrsShutdownSync.replicaOfflineMsgForwarded(replicationServerDomain.getBaseDN()); 149 replicationServerDomain.stopServer(handler, false); 180 replicationServerDomain 74 ServerWriter(Session session, ServerHandler handler, ReplicationServerDomain replicationServerDomain, DSRSShutdownSync dsrsShutdownSync) argument [all...] |
H A D | MonitoringPublisher.java | 64 * @param replicationServerDomain The ReplicationServerDomain the monitoring 68 public MonitoringPublisher(ReplicationServerDomain replicationServerDomain, argument 72 + replicationServerDomain.getLocalRSServerId() 74 + replicationServerDomain.getBaseDN() + "\""); 76 this.domain = replicationServerDomain;
|
H A D | StatusAnalyzer.java | 62 private final ReplicationServerDomain replicationServerDomain; field in class:StatusAnalyzer 72 * @param replicationServerDomain 75 StatusAnalyzer(ReplicationServerDomain replicationServerDomain) argument 78 + replicationServerDomain.getLocalRSServerId() 80 + replicationServerDomain.getBaseDN() 82 this.replicationServerDomain = replicationServerDomain; 122 replicationServerDomain.sendPendingStatusMessages(); 132 replicationServerDomain.checkDSDegradedStatus(); 150 return "In RS " + replicationServerDomain [all...] |
H A D | MessageHandler.java | 89 protected ReplicationServerDomain replicationServerDomain; field in class:MessageHandler 212 if (replicationServerDomain == null) 214 replicationServerDomain = 409 cursor = replicationServerDomain.getCursorFrom(serverState); 477 cursor = replicationServerDomain.getCursorFrom(serverState); 531 ServerState latestState = replicationServerDomain.getLatestServerState();
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | MonitoringPublisher.java | 56 private final ReplicationServerDomain replicationServerDomain; field in class:MonitoringPublisher 65 * @param replicationServerDomain The ReplicationServerDomain the monitoring 69 public MonitoringPublisher(ReplicationServerDomain replicationServerDomain, argument 73 + replicationServerDomain.getReplicationServer() 75 + replicationServerDomain.getBaseDn() + "\""); 77 this.replicationServerDomain = replicationServerDomain; 90 + replicationServerDomain.getBaseDn()); 98 MonitorData monitorData = replicationServerDomain 102 replicationServerDomain [all...] |
H A D | ServerWriter.java | 60 private final ReplicationServerDomain replicationServerDomain; field in class:ServerWriter 72 * @param replicationServerDomain 76 ReplicationServerDomain replicationServerDomain) 89 this.replicationServerDomain = replicationServerDomain; 108 UpdateMsg update = replicationServerDomain.take(this.handler); 136 replicationServerDomain.getGenerationId(); 160 replicationServerDomain.getGenerationId(); 181 "In " + replicationServerDomain.getReplicationServer(). 250 replicationServerDomain 75 ServerWriter(Session session, ServerHandler handler, ReplicationServerDomain replicationServerDomain) argument [all...] |
H A D | ECLServerWriter.java | 66 private ReplicationServerDomain replicationServerDomain; field in class:ECLServerWriter 76 * @param replicationServerDomain the ReplicationServerDomain of this 80 ReplicationServerDomain replicationServerDomain) 82 super(session, handler, replicationServerDomain); 89 this.replicationServerDomain = replicationServerDomain; 207 if (replicationServerDomain!=null) 208 replicationServerDomain.stopServer(handler, false); 79 ECLServerWriter(Session session, ECLServerHandler handler, ReplicationServerDomain replicationServerDomain) argument
|
H A D | StatusAnalyzer.java | 60 private final ReplicationServerDomain replicationServerDomain; field in class:StatusAnalyzer 70 * @param replicationServerDomain 73 StatusAnalyzer(ReplicationServerDomain replicationServerDomain) argument 76 + replicationServerDomain.getReplicationServer().getServerId() 78 + replicationServerDomain.getBaseDn() + "\""); 79 this.replicationServerDomain = replicationServerDomain; 95 replicationServerDomain.getBaseDn()); 121 replicationServerDomain.sendPendingStatusMessages(); 131 replicationServerDomain [all...] |
H A D | MessageHandler.java | 95 protected ReplicationServerDomain replicationServerDomain = null; field in class:MessageHandler 209 if (replicationServerDomain==null) 211 replicationServerDomain = 215 return replicationServerDomain; 314 for (int serverId : replicationServerDomain.getServers()) 318 ReplicationIterator iterator = replicationServerDomain 497 for (int serverId : replicationServerDomain.getServers()) 503 replicationServerDomain.getChangelogIterator(serverId, lastCsn); 576 ServerState dbState = replicationServerDomain.getDbServerState(); 679 this.replicationServerDomain [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | MonitoringPublisher.java | 58 private final ReplicationServerDomain replicationServerDomain; field in class:MonitoringPublisher 70 * @param replicationServerDomain The ReplicationServerDomain the monitoring 74 public MonitoringPublisher(ReplicationServerDomain replicationServerDomain, argument 78 + replicationServerDomain.getReplicationServer() 80 + replicationServerDomain.getBaseDn() + "\""); 82 this.replicationServerDomain = replicationServerDomain; 95 + replicationServerDomain.getBaseDn()); 111 MonitorData monitorData = replicationServerDomain 114 MonitorMsg monitorMsg = replicationServerDomain [all...] |
H A D | ServerWriter.java | 60 private final ReplicationServerDomain replicationServerDomain; field in class:ServerWriter 72 * @param replicationServerDomain 76 ReplicationServerDomain replicationServerDomain) 89 this.replicationServerDomain = replicationServerDomain; 108 UpdateMsg update = replicationServerDomain.take(this.handler); 136 replicationServerDomain.getGenerationId(); 160 replicationServerDomain.getGenerationId(); 181 "In " + replicationServerDomain.getReplicationServer(). 250 replicationServerDomain 75 ServerWriter(Session session, ServerHandler handler, ReplicationServerDomain replicationServerDomain) argument [all...] |
H A D | StatusAnalyzer.java | 59 private final ReplicationServerDomain replicationServerDomain; field in class:StatusAnalyzer 71 * @param replicationServerDomain The ReplicationServerDomain the status 76 public StatusAnalyzer(ReplicationServerDomain replicationServerDomain, argument 80 + replicationServerDomain.getReplicationServer() 82 + replicationServerDomain.getBaseDn() + "\""); 84 this.replicationServerDomain = replicationServerDomain; 98 replicationServerDomain.getBaseDn()); 129 replicationServerDomain.getConnectedDSs(). values()) 136 replicationServerDomain [all...] |
H A D | ECLServerWriter.java | 66 private ReplicationServerDomain replicationServerDomain; field in class:ECLServerWriter 76 * @param replicationServerDomain the ReplicationServerDomain of this 80 ReplicationServerDomain replicationServerDomain) 82 super(session, handler, replicationServerDomain); 89 this.replicationServerDomain = replicationServerDomain; 207 if (replicationServerDomain!=null) 208 replicationServerDomain.stopServer(handler, false); 79 ECLServerWriter(Session session, ECLServerHandler handler, ReplicationServerDomain replicationServerDomain) argument
|
H A D | MessageHandler.java | 95 protected ReplicationServerDomain replicationServerDomain = null; field in class:MessageHandler 209 if (replicationServerDomain==null) 211 replicationServerDomain = 215 return replicationServerDomain; 314 for (int serverId : replicationServerDomain.getServers()) 318 ReplicationIterator iterator = replicationServerDomain 497 for (int serverId : replicationServerDomain.getServers()) 503 replicationServerDomain.getChangelogIterator(serverId, lastCsn); 576 ServerState dbState = replicationServerDomain.getDbServerState(); 679 this.replicationServerDomain [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ServerWriter.java | 59 private final ReplicationServerDomain replicationServerDomain; field in class:ServerWriter 70 * @param replicationServerDomain 75 ReplicationServerDomain replicationServerDomain, 85 this.replicationServerDomain = replicationServerDomain; 107 || !dsrsShutdownSync.canShutdown(replicationServerDomain.getBaseDN())) 109 final UpdateMsg updateMsg = replicationServerDomain.take(this.handler); 123 dsrsShutdownSync.replicaOfflineMsgForwarded(replicationServerDomain.getBaseDN()); 149 replicationServerDomain.stopServer(handler, false); 180 replicationServerDomain 74 ServerWriter(Session session, ServerHandler handler, ReplicationServerDomain replicationServerDomain, DSRSShutdownSync dsrsShutdownSync) argument [all...] |
H A D | MonitoringPublisher.java | 64 * @param replicationServerDomain The ReplicationServerDomain the monitoring 68 public MonitoringPublisher(ReplicationServerDomain replicationServerDomain, argument 72 + replicationServerDomain.getLocalRSServerId() 74 + replicationServerDomain.getBaseDN() + "\""); 76 this.domain = replicationServerDomain;
|
H A D | StatusAnalyzer.java | 62 private final ReplicationServerDomain replicationServerDomain; field in class:StatusAnalyzer 72 * @param replicationServerDomain 75 StatusAnalyzer(ReplicationServerDomain replicationServerDomain) argument 78 + replicationServerDomain.getLocalRSServerId() 80 + replicationServerDomain.getBaseDN() 82 this.replicationServerDomain = replicationServerDomain; 122 replicationServerDomain.sendPendingStatusMessages(); 132 replicationServerDomain.checkDSDegradedStatus(); 150 return "In RS " + replicationServerDomain [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ServerWriter.java | 54 private final ReplicationServerDomain replicationServerDomain; field in class:ServerWriter 65 * @param replicationServerDomain 70 ReplicationServerDomain replicationServerDomain, 80 this.replicationServerDomain = replicationServerDomain; 102 || !dsrsShutdownSync.canShutdown(replicationServerDomain.getBaseDN())) 118 dsrsShutdownSync.replicaOfflineMsgForwarded(replicationServerDomain.getBaseDN()); 144 replicationServerDomain.stopServer(handler, false); 173 replicationServerDomain.getGenerationId()); 190 final long referenceGenerationId = replicationServerDomain 69 ServerWriter(Session session, ServerHandler handler, ReplicationServerDomain replicationServerDomain, DSRSShutdownSync dsrsShutdownSync) argument [all...] |
H A D | MonitoringPublisher.java | 58 * @param replicationServerDomain The ReplicationServerDomain the monitoring 62 public MonitoringPublisher(ReplicationServerDomain replicationServerDomain, argument 66 + replicationServerDomain.getLocalRSServerId() 68 + replicationServerDomain.getBaseDN() + "\""); 70 this.domain = replicationServerDomain;
|
H A D | StatusAnalyzer.java | 57 private final ReplicationServerDomain replicationServerDomain; field in class:StatusAnalyzer 67 * @param replicationServerDomain 70 StatusAnalyzer(ReplicationServerDomain replicationServerDomain) argument 73 + replicationServerDomain.getLocalRSServerId() 75 + replicationServerDomain.getBaseDN() 77 this.replicationServerDomain = replicationServerDomain; 116 replicationServerDomain.sendPendingStatusMessages(); 126 replicationServerDomain.checkDSDegradedStatus(); 144 return "In RS " + replicationServerDomain [all...] |