Searched refs:purgeDelayMs (Results 1 - 11 of 11) sorted by relevance

/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/session/blacklist/
H A DCachingSessionBlacklist.java36 private final long purgeDelayMs; field in class:CachingSessionBlacklist
39 CachingSessionBlacklist(final SessionBlacklist delegate, final int maxSize, final long purgeDelayMs, argument
44 this.purgeDelayMs = purgeDelayMs;
58 * @param purgeDelayMs the additional delay before purging elements from the cache.
60 public CachingSessionBlacklist(final SessionBlacklist delegate, final int maxSize, final long purgeDelayMs) { argument
61 this(delegate, maxSize, purgeDelayMs, TimeService.SYSTEM);
66 if (cache.put(session.getStableStorageID(), session.getBlacklistExpiryTime(purgeDelayMs)) == null) {
85 cache.put(key, session.getBlacklistExpiryTime(purgeDelayMs));
H A DCTSSessionBlacklist.java94 private final long purgeDelayMs; field in class:CTSSessionBlacklist
107 this.purgeDelayMs = serviceConfig.getSessionBlacklistPurgeDelay(MILLISECONDS);
116 token.setExpiryTimestamp(timeOf(session.getBlacklistExpiryTime(purgeDelayMs)));
168 notifyListeners(session.getStableStorageID(), session.getBlacklistExpiryTime(purgeDelayMs));
H A DBloomFilterSessionBlacklist.java162 static SessionBlacklistEntry from(Session session, long purgeDelayMs) throws SessionException { argument
163 return new SessionBlacklistEntry(session.getStableStorageID(), session.getBlacklistExpiryTime(purgeDelayMs));
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/blacklist/
H A DCachingBlacklist.java36 private final long purgeDelayMs; field in class:CachingBlacklist
39 CachingBlacklist(Blacklist<T> delegate, int maxSize, long purgeDelayMs, final TimeService clock) { argument
43 this.purgeDelayMs = purgeDelayMs;
57 * @param purgeDelayMs the additional delay before purging elements from the cache.
59 public CachingBlacklist(Blacklist<T> delegate, int maxSize, long purgeDelayMs) { argument
60 this(delegate, maxSize, purgeDelayMs, TimeService.SYSTEM);
65 if (cache.put(entry.getStableStorageID(), entry.getBlacklistExpiryTime() + purgeDelayMs) == null) {
84 cache.put(key, entry.getBlacklistExpiryTime() + purgeDelayMs);
H A DBloomFilterBlacklist.java50 private final long purgeDelayMs; field in class:BloomFilterBlacklist
54 BloomFilterBlacklist(Blacklist<T> delegate, long purgeDelayMs, final BloomFilter<BlacklistEntry> bloomFilter) { argument
58 this.purgeDelayMs = purgeDelayMs;
81 * @param purgeDelayMs The purge delay in milli seconds.
83 public BloomFilterBlacklist(Blacklist<T> delegate, long purgeDelayMs) { argument
84 this(delegate, purgeDelayMs, BloomFilters.create(EntryFunnel.INSTANCE)
104 if (bloomFilter.mightContain(BlacklistEntry.from(entry, purgeDelayMs))) {
155 static BlacklistEntry from(Blacklistable entry, long purgeDelayMs) throws BlacklistException { argument
156 return new BlacklistEntry(entry.getStableStorageID(), entry.getBlacklistExpiryTime() + purgeDelayMs);
[all...]
H A DConfigurableSessionBlacklist.java83 final long purgeDelayMs = sessionServiceConfig.getSessionBlacklistPurgeDelay(TimeUnit.MILLISECONDS);
89 blacklist = new CachingBlacklist<>(blacklist, cacheSize, purgeDelayMs);
93 blacklist = new BloomFilterBlacklist<>(blacklist, purgeDelayMs);
H A DCTSBlacklist.java92 private final long purgeDelayMs; field in class:CTSBlacklist
95 ThreadMonitor threadMonitor, WebtopNamingQuery serverConfig, long purgeDelayMs, long pollIntervalMs) {
101 this.purgeDelayMs = purgeDelayMs;
118 token.setExpiryTimestamp(timeOf(entry.getBlacklistExpiryTime() + purgeDelayMs));
170 notifyListeners(entry.getStableStorageID(), entry.getBlacklistExpiryTime() + purgeDelayMs);
94 CTSBlacklist(CTSPersistentStore cts, TokenType tokenType, ScheduledExecutorService scheduler, ThreadMonitor threadMonitor, WebtopNamingQuery serverConfig, long purgeDelayMs, long pollIntervalMs) argument
/forgerock/openam/openam-oauth2/src/main/java/org/forgerock/openam/oauth2/guice/
H A DOAuth2GuiceModule.java441 long purgeDelayMs = globalSettings.getBlacklistPurgeDelay(TimeUnit.MILLISECONDS);
444 webtopNamingQuery, purgeDelayMs, pollIntervalMs);
455 long purgeDelayMs = globalSettings.getBlacklistPurgeDelay(TimeUnit.MILLISECONDS);
461 blacklist = new CachingBlacklist<>(blacklist, cacheSize, purgeDelayMs);
465 blacklist = new BloomFilterBlacklist<>(blacklist, purgeDelayMs);
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/core/guice/
H A DCoreGuiceModule.java328 long purgeDelayMs = serviceConfig.getSessionBlacklistPurgeDelay(TimeUnit.MILLISECONDS);
331 serverConfig, purgeDelayMs, pollIntervalMs);
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/
H A DSession.java606 * @param purgeDelayMs the additional delay (in milliseconds) before purging the session.
610 public long getBlacklistExpiryTime(long purgeDelayMs) throws SessionException { argument
612 return sessionExpiryTime + purgeDelayMs;
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/core/guice/
H A DCoreGuiceModule.java555 final long purgeDelayMs = serviceConfig.getSessionBlacklistPurgeDelay(TimeUnit.MILLISECONDS);
561 blacklist = new CachingSessionBlacklist(blacklist, cacheSize, purgeDelayMs);

Completed in 32 milliseconds