Searched refs:cnPurger (Results 1 - 5 of 5) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DFileChangelogDB.java128 private final AtomicReference<ChangelogDBPurger> cnPurger = new AtomicReference<ChangelogDBPurger>(); field in class:FileChangelogDB
366 final ChangelogDBPurger purger = cnPurger.getAndSet(null);
585 if (cnPurger.compareAndSet(null, newPurger))
592 final ChangelogDBPurger currentPurger = cnPurger.get();
601 final ChangelogDBPurger purgerToStop = cnPurger.getAndSet(null);
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DJEChangelogDB.java123 private final AtomicReference<ChangelogDBPurger> cnPurger = new AtomicReference<ChangelogDBPurger>(); field in class:JEChangelogDB
387 final ChangelogDBPurger purger = cnPurger.getAndSet(null);
628 if (cnPurger.compareAndSet(null, newPurger))
635 final ChangelogDBPurger currentPurger = cnPurger.get();
644 final ChangelogDBPurger purgerToStop = cnPurger.getAndSet(null);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DFileChangelogDB.java128 private final AtomicReference<ChangelogDBPurger> cnPurger = new AtomicReference<ChangelogDBPurger>(); field in class:FileChangelogDB
366 final ChangelogDBPurger purger = cnPurger.getAndSet(null);
585 if (cnPurger.compareAndSet(null, newPurger))
592 final ChangelogDBPurger currentPurger = cnPurger.get();
601 final ChangelogDBPurger purgerToStop = cnPurger.getAndSet(null);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/
H A DJEChangelogDB.java123 private final AtomicReference<ChangelogDBPurger> cnPurger = new AtomicReference<ChangelogDBPurger>(); field in class:JEChangelogDB
387 final ChangelogDBPurger purger = cnPurger.getAndSet(null);
628 if (cnPurger.compareAndSet(null, newPurger))
635 final ChangelogDBPurger currentPurger = cnPurger.get();
644 final ChangelogDBPurger purgerToStop = cnPurger.getAndSet(null);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DFileChangelogDB.java118 private final AtomicReference<ChangelogDBPurger> cnPurger = new AtomicReference<>(); field in class:FileChangelogDB
388 final ChangelogDBPurger purger = cnPurger.getAndSet(null);
578 final ChangelogDBPurger purgerToStop = cnPurger.getAndSet(null);
589 if (cnPurger.compareAndSet(null, newPurger))
596 final ChangelogDBPurger currentPurger = cnPurger.get();

Completed in 43 milliseconds