com.gigaspaces.internal.server.space.eviction

Class EvictionReplicationsMarkersRepository

java.lang.Object

com.gigaspaces.internal.server.space.eviction.EvictionReplicationsMarkersRepository

All Implemented Interfaces:

IEvictionReplicationsMarkersRepository

public class EvictionReplicationsMarkersRepository
extends Object
implements IEvictionReplicationsMarkersRepository

repository for replication markers - used in order to prevent eviction of entries that did not reach the async replication target yet (currently mirror)

Since:

9.1

Author:

Yechiel Feffer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EvictionReplicationsMarkersRepository.EvictionReplicationsMarkersSegment

Field Summary

Fields

Modifier and Type	Field and Description
static int	NUM_OF_IMARKERS_REPOSITORY_SEGMENTS

Constructor Summary

Constructors

Constructor and Description
EvictionReplicationsMarkersRepository()

Method Summary

Modifier and Type	Method and Description
Object	getLockObject(String uid)
IMarker	getMarker(String uid) Gets the marker associated to this uid, null of none exists.
void	insert(String uid, IMarker marker, boolean alreadyLocked)
boolean	isEntryEvictable(String uid, boolean alreadyLocked)
int	reapUnused() reap unsed (i.e.
void	releaseLockObject(Object lockObject)
int	size() # of uids inside.

Methods inherited from class java.lang.Object

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

Field Detail

NUM_OF_IMARKERS_REPOSITORY_SEGMENTS

public static final int NUM_OF_IMARKERS_REPOSITORY_SEGMENTS

See Also:

Constant Field Values

Constructor Detail

EvictionReplicationsMarkersRepository

public EvictionReplicationsMarkersRepository()

Method Detail

insert

public void insert(String uid,
                   IMarker marker,
                   boolean alreadyLocked)

Specified by:

insert in interface IEvictionReplicationsMarkersRepository

isEntryEvictable

public boolean isEntryEvictable(String uid,
                                boolean alreadyLocked)

Specified by:

isEntryEvictable in interface IEvictionReplicationsMarkersRepository

getLockObject

public Object getLockObject(String uid)

Specified by:

getLockObject in interface IEvictionReplicationsMarkersRepository

releaseLockObject

public void releaseLockObject(Object lockObject)

Specified by:

releaseLockObject in interface IEvictionReplicationsMarkersRepository

reapUnused

public int reapUnused()

reap unsed (i.e. reached) markers

Specified by:

reapUnused in interface IEvictionReplicationsMarkersRepository

Returns:

number of reapred markers

getMarker

public IMarker getMarker(String uid)

Description copied from interface: IEvictionReplicationsMarkersRepository

Gets the marker associated to this uid, null of none exists.

Specified by:

getMarker in interface IEvictionReplicationsMarkersRepository

size

public int size()

Description copied from interface: IEvictionReplicationsMarkersRepository

# of uids inside.

Specified by:

size in interface IEvictionReplicationsMarkersRepository