Package org.keycloak.models.map.storage.hotRod.locking

Class HotRodLocksUtils

java.lang.Object

org.keycloak.models.map.storage.hotRod.locking.HotRodLocksUtils

public class HotRodLocksUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	SEPARATOR

Constructor Summary

Constructors

Constructor	Description
HotRodLocksUtils()

Method Summary

Modifier and Type	Method	Description
static boolean	removeWithInstanceIdentifier(ConcurrentMap<String,String> map, String lockName)	Removes the entry with key lockName from map if the value of the entry is equal to this node's identifier
static void	repeatPutIfAbsent(org.infinispan.client.hotrod.RemoteCache<String,String> locksCache, String lockName, Duration timeout, int repeatInterval)	Repeatedly attempts to put an entry with the key lockName to the locksCache.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SEPARATOR

public static final String SEPARATOR

See Also:

Constant Field Values

Constructor Detail

HotRodLocksUtils

public HotRodLocksUtils()

Method Detail

repeatPutIfAbsent

public static void repeatPutIfAbsent(org.infinispan.client.hotrod.RemoteCache<String,String> locksCache,
                                     String lockName,
                                     Duration timeout,
                                     int repeatInterval)
                              throws LockAcquiringTimeoutException

Repeatedly attempts to put an entry with the key lockName to the locksCache. Succeeds only if there is no entry with the same key already.

Execution of this method is time bounded, if this method does not succeed within timeoutMilliseconds it gives up and returns false.

There is a pause after each unsuccessful attempt equal to repeatInterval milliseconds

Parameters:

locksCache - Cache that will be used for putting the value

lockName - Name of the entry

timeout - duration to wait until the lock is acquired

repeatInterval - Number of milliseconds to wait after each unsuccessful attempt

Throws:

LockAcquiringTimeoutException - the key lockName was NOT put into the map within time boundaries

IllegalStateException - when a lock value found in the storage has wrong format. It is expected the lock value has the following format 'timeAcquired;keycloakInstanceIdentifier'

removeWithInstanceIdentifier

public static boolean removeWithInstanceIdentifier(ConcurrentMap<String,String> map,
                                                   String lockName)

Removes the entry with key lockName from map if the value of the entry is equal to this node's identifier

Parameters:

map - Map that will be used for removing

lockName - Name of the entry

Returns:

true if the entry was removed, false otherwise