com.hazelcast.cp.internal.datastructures.spi.blocking

Class ResourceRegistry<W extends WaitKey,R extends BlockingResource<W>>

java.lang.Object

com.hazelcast.cp.internal.datastructures.spi.blocking.ResourceRegistry<W,R>

Type Parameters:

W - concrete type of the WaitKey

R - concrete type of the resource

All Implemented Interfaces:

DataSerializable

Direct Known Subclasses:

RaftCountDownLatchRegistry, RaftSemaphoreRegistry

public abstract class ResourceRegistry<W extends WaitKey,R extends BlockingResource<W>>
extends Object
implements DataSerializable

Base class for registries for blocking resources. Maintains blocking resources and their associated wait timeouts. When a new wait key is registered into a blocking resource, a timeout can be set here. If a return value is not produced for that wait key until the timeout occurs, the wait key will be expired.

Field Summary

Fields

Modifier and Type	Field and Description
protected Set<String>	destroyedNames
protected CPGroupId	groupId
protected Map<String,R>	resources
protected ConcurrentMap<Tuple2<String,UUID>,Tuple2<Long,Long>>	waitTimeouts

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ResourceRegistry()
protected	ResourceRegistry(CPGroupId groupId)

Method Summary

Modifier and Type	Method and Description
protected void	addWaitKey(String name, W key, long timeoutMs)
protected abstract ResourceRegistry<W,R>	cloneForSnapshot()
protected abstract R	createNewResource(CPGroupId groupId, String name)
Collection<Long>	destroy()
CPGroupId	getGroupId()
Collection<Tuple2<Address,Long>>	getLiveOperations()
protected R	getOrInitResource(String name)
R	getResourceOrNull(String name)
Map<Tuple2<String,UUID>,Tuple2<Long,Long>>	getWaitTimeouts()
void	populate(LiveOperations liveOperations, long now)
void	readData(ObjectDataInput in) Reads fields from the input stream
protected void	removeWaitKey(String name, W key)
String	toString()
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class java.lang.Object

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

Field Detail

groupId

protected CPGroupId groupId

resources

protected final Map<String,R extends BlockingResource<W>> resources

destroyedNames

protected final Set<String> destroyedNames

waitTimeouts

protected final ConcurrentMap<Tuple2<String,UUID>,Tuple2<Long,Long>> waitTimeouts

Constructor Detail

ResourceRegistry

protected ResourceRegistry()

ResourceRegistry

protected ResourceRegistry(CPGroupId groupId)

Method Detail

createNewResource

protected abstract R createNewResource(CPGroupId groupId,
                                       String name)

cloneForSnapshot

protected abstract ResourceRegistry<W,R> cloneForSnapshot()

getResourceOrNull

public final R getResourceOrNull(String name)

getOrInitResource

protected final R getOrInitResource(String name)

addWaitKey

protected final void addWaitKey(String name,
                                W key,
                                long timeoutMs)

removeWaitKey

protected final void removeWaitKey(String name,
                                   W key)

getGroupId

public final CPGroupId getGroupId()

getWaitTimeouts

public final Map<Tuple2<String,UUID>,Tuple2<Long,Long>> getWaitTimeouts()

destroy

public final Collection<Long> destroy()

populate

public void populate(LiveOperations liveOperations,
                     long now)

getLiveOperations

public final Collection<Tuple2<Address,Long>> getLiveOperations()

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the input stream has been closed.

toString

public String toString()

Overrides:

toString in class Object