public interface ISingleStageReplicaDataProducer<T extends ISpaceReplicaData>
Modifier and Type | Interface and Description |
---|---|
static class |
ISingleStageReplicaDataProducer.CloseStatus |
Modifier and Type | Field and Description |
---|---|
static long |
FORCED_CLOSE_WAIT_TIME |
Modifier and Type | Method and Description |
---|---|
ISingleStageReplicaDataProducer.CloseStatus |
close(boolean forced)
Closes the producer, frees up resources held in order to service the replica request.
|
String |
dumpState() |
String |
getName() |
T |
produceNextData(ISynchronizationCallback synchCallback)
Produce next data needed for replica, this call will always be followed by
#releaseLockedData(ISpaceReplicaData) if lockedData is true, it should keep that item
represented by this data locked until the release is called This is done in order to ensure
synchronization correctness |
IReplicationFilterEntry |
toFilterEntry(T data) |
static final long FORCED_CLOSE_WAIT_TIME
ISingleStageReplicaDataProducer.CloseStatus close(boolean forced)
T produceNextData(ISynchronizationCallback synchCallback)
#releaseLockedData(ISpaceReplicaData)
if lockedData is true, it should keep that item
represented by this data locked until the release is called This is done in order to ensure
synchronization correctnesssynchCallback
- callback to the synchronization processor that needs to be called safely
under lockIReplicationFilterEntry toFilterEntry(T data)
String dumpState()
String getName()
Copyright © GigaSpaces.