Searched defs:dsrsShutdownSync (Results 1 - 15 of 15) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DServerWriter.java60 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 DReplicationServer.java85 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 DServerWriter.java60 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 DReplicationServer.java85 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 DServerWriter.java55 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 DReplicationServer.java93 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;
/forgerock/opendj2/src/server/org/opends/server/replication/plugin/
H A DReplicationServerListener.java51 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 DMultimasterReplication.java105 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 DLDAPReplicationDomain.java186 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 DReplicationServerListener.java51 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 DMultimasterReplication.java105 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 DLDAPReplicationDomain.java186 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 DReplicationServerListener.java51 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 DMultimasterReplication.java108 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 DLDAPReplicationDomain.java233 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

Completed in 148 milliseconds