/forgerock/opendj2/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerListener.java | 51 private final DSRSShutdownSync dsrsShutdownSync; field in class:ReplicationServerListener 60 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 67 DSRSShutdownSync dsrsShutdownSync) throws ConfigException 72 this.dsrsShutdownSync = dsrsShutdownSync; 76 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync); 86 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync); 65 ReplicationServerListener( ReplicationSynchronizationProviderCfg configuration, DSRSShutdownSync dsrsShutdownSync) argument
|
H A D | MultimasterReplication.java | 105 private static final DSRSShutdownSync dsrsShutdownSync = new DSRSShutdownSync(); field in class:MultimasterReplication 219 configuration, updateToReplayQueue, dsrsShutdownSync); 256 new LDAPReplicationDomain(configuration, queue, dsrsShutdownSync); 285 replicationServerListener = new ReplicationServerListener(cfg, dsrsShutdownSync);
|
H A D | LDAPReplicationDomain.java | 186 private final DSRSShutdownSync dsrsShutdownSync; field in class:LDAPReplicationDomain 457 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 462 DSRSShutdownSync dsrsShutdownSync) throws ConfigException 467 this.dsrsShutdownSync = dsrsShutdownSync; 2008 dsrsShutdownSync.replicaOfflineMsgSent(getBaseDN()); 460 LDAPReplicationDomain(ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> updateToReplayQueue, DSRSShutdownSync dsrsShutdownSync) argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerListener.java | 51 private final DSRSShutdownSync dsrsShutdownSync; field in class:ReplicationServerListener 60 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 67 DSRSShutdownSync dsrsShutdownSync) throws ConfigException 72 this.dsrsShutdownSync = dsrsShutdownSync; 76 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync); 86 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync); 65 ReplicationServerListener( ReplicationSynchronizationProviderCfg configuration, DSRSShutdownSync dsrsShutdownSync) argument
|
H A D | MultimasterReplication.java | 105 private static final DSRSShutdownSync dsrsShutdownSync = new DSRSShutdownSync(); field in class:MultimasterReplication 219 configuration, updateToReplayQueue, dsrsShutdownSync); 256 new LDAPReplicationDomain(configuration, queue, dsrsShutdownSync); 285 replicationServerListener = new ReplicationServerListener(cfg, dsrsShutdownSync);
|
H A D | LDAPReplicationDomain.java | 186 private final DSRSShutdownSync dsrsShutdownSync; field in class:LDAPReplicationDomain 457 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 462 DSRSShutdownSync dsrsShutdownSync) throws ConfigException 467 this.dsrsShutdownSync = dsrsShutdownSync; 2008 dsrsShutdownSync.replicaOfflineMsgSent(getBaseDN()); 460 LDAPReplicationDomain(ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> updateToReplayQueue, DSRSShutdownSync dsrsShutdownSync) argument
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/ |
H A D | ReplicationServerListener.java | 51 private final DSRSShutdownSync dsrsShutdownSync; field in class:ReplicationServerListener 60 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 67 DSRSShutdownSync dsrsShutdownSync) throws ConfigException 72 this.dsrsShutdownSync = dsrsShutdownSync; 76 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync); 87 replicationServer = new ReplicationServer(cfg, dsrsShutdownSync); 65 ReplicationServerListener( ReplicationSynchronizationProviderCfg configuration, DSRSShutdownSync dsrsShutdownSync) argument
|
H A D | MultimasterReplication.java | 108 private static final DSRSShutdownSync dsrsShutdownSync = new DSRSShutdownSync(); field in class:MultimasterReplication 205 configuration, updateToReplayQueue, dsrsShutdownSync); 241 new LDAPReplicationDomain(configuration, queue, dsrsShutdownSync); 270 replicationServerListener = new ReplicationServerListener(cfg, dsrsShutdownSync);
|
H A D | LDAPReplicationDomain.java | 233 private final DSRSShutdownSync dsrsShutdownSync; field in class:LDAPReplicationDomain 476 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 481 DSRSShutdownSync dsrsShutdownSync) throws ConfigException 486 this.dsrsShutdownSync = dsrsShutdownSync; 1981 dsrsShutdownSync.replicaOfflineMsgSent(getBaseDN()); 479 LDAPReplicationDomain(ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> updateToReplayQueue, DSRSShutdownSync dsrsShutdownSync) argument
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ServerWriter.java | 60 private final DSRSShutdownSync dsrsShutdownSync; field in class:ServerWriter 72 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 76 DSRSShutdownSync dsrsShutdownSync) 86 this.dsrsShutdownSync = dsrsShutdownSync; 107 || !dsrsShutdownSync.canShutdown(replicationServerDomain.getBaseDN())) 123 dsrsShutdownSync.replicaOfflineMsgForwarded(replicationServerDomain.getBaseDN()); 74 ServerWriter(Session session, ServerHandler handler, ReplicationServerDomain replicationServerDomain, DSRSShutdownSync dsrsShutdownSync) argument
|
H A D | ReplicationServer.java | 85 private final DSRSShutdownSync dsrsShutdownSync; field in class:ReplicationServer 145 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 148 public ReplicationServer(ReplicationServerCfg cfg, DSRSShutdownSync dsrsShutdownSync) throws ConfigException argument 150 this(cfg, dsrsShutdownSync, new ECLEnabledDomainPredicate()); 158 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 162 public ReplicationServer(final ReplicationServerCfg cfg, final DSRSShutdownSync dsrsShutdownSync, argument 166 this.dsrsShutdownSync = dsrsShutdownSync; 1368 return dsrsShutdownSync;
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ServerWriter.java | 60 private final DSRSShutdownSync dsrsShutdownSync; field in class:ServerWriter 72 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 76 DSRSShutdownSync dsrsShutdownSync) 86 this.dsrsShutdownSync = dsrsShutdownSync; 107 || !dsrsShutdownSync.canShutdown(replicationServerDomain.getBaseDN())) 123 dsrsShutdownSync.replicaOfflineMsgForwarded(replicationServerDomain.getBaseDN()); 74 ServerWriter(Session session, ServerHandler handler, ReplicationServerDomain replicationServerDomain, DSRSShutdownSync dsrsShutdownSync) argument
|
H A D | ReplicationServer.java | 85 private final DSRSShutdownSync dsrsShutdownSync; field in class:ReplicationServer 145 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 148 public ReplicationServer(ReplicationServerCfg cfg, DSRSShutdownSync dsrsShutdownSync) throws ConfigException argument 150 this(cfg, dsrsShutdownSync, new ECLEnabledDomainPredicate()); 158 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 162 public ReplicationServer(final ReplicationServerCfg cfg, final DSRSShutdownSync dsrsShutdownSync, argument 166 this.dsrsShutdownSync = dsrsShutdownSync; 1368 return dsrsShutdownSync;
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ServerWriter.java | 55 private final DSRSShutdownSync dsrsShutdownSync; field in class:ServerWriter 67 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 71 DSRSShutdownSync dsrsShutdownSync) 81 this.dsrsShutdownSync = dsrsShutdownSync; 102 || !dsrsShutdownSync.canShutdown(replicationServerDomain.getBaseDN())) 118 dsrsShutdownSync.replicaOfflineMsgForwarded(replicationServerDomain.getBaseDN()); 69 ServerWriter(Session session, ServerHandler handler, ReplicationServerDomain replicationServerDomain, DSRSShutdownSync dsrsShutdownSync) argument
|
H A D | ReplicationServer.java | 93 private final DSRSShutdownSync dsrsShutdownSync; field in class:ReplicationServer 149 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 152 public ReplicationServer(ReplicationServerCfg cfg, DSRSShutdownSync dsrsShutdownSync) throws ConfigException argument 154 this(cfg, dsrsShutdownSync, new ECLEnabledDomainPredicate()); 162 * @param dsrsShutdownSync Synchronization object for shutdown of combined DS/RS instances. 166 public ReplicationServer(final ReplicationServerCfg cfg, final DSRSShutdownSync dsrsShutdownSync, argument 170 this.dsrsShutdownSync = dsrsShutdownSync; 1329 return dsrsShutdownSync;
|