Modifier and Type | Method and Description |
---|---|
OperationID |
AbstractSpaceCacheContainer.createNewOperationID() |
Modifier and Type | Method and Description |
---|---|
void |
LocalViewReplicationEntryEventHandler.changeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int routingHash,
int version,
int previousVersion,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry) |
void |
LocalViewReplicationEntryLeaseEventHandler.inEntryLeaseExpiredByUID(IReplicationInContext context,
String typeName,
String uid,
boolean isTransient,
OperationID operationID) |
void |
LocalViewReplicationEntryEventHandler.removeEntryByUid(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String uid,
boolean isTransient,
OperationID operationID) |
Modifier and Type | Method and Description |
---|---|
OperationID |
ISpaceProxy.createNewOperationID()
Generate a unique operation ID
|
OperationID |
SpaceProxyImpl.createNewOperationID() |
Modifier and Type | Method and Description |
---|---|
OperationID |
PrepareAndCommitTransactionSpaceOperationRequest.getOperationID() |
OperationID |
CommitPreparedTransactionSpaceOperationRequest.getOperationID() |
OperationID |
AbortPreparedTransactionSpaceOperationRequest.getOperationID() |
Constructor and Description |
---|
AbortPreparedTransactionSpaceOperationRequest(TransactionManager mgr,
long id,
int partitionId,
OperationID operationID) |
AbortPreparedTransactionSpaceOperationRequest(TransactionManager mgr,
Object xid,
int partitionId,
OperationID operationID) |
CommitPreparedTransactionSpaceOperationRequest(TransactionManager mgr,
long id,
int partitionId,
int numParticipants,
OperationID operationID) |
CommitPreparedTransactionSpaceOperationRequest(TransactionManager mgr,
Object xid,
int partitionId,
int numParticipants,
OperationID operationID) |
PrepareAndCommitTransactionSpaceOperationRequest(TransactionManager mgr,
long id,
int partitionId,
OperationID operationID) |
PrepareAndCommitTransactionSpaceOperationRequest(TransactionManager mgr,
Object xid,
int partitionId,
OperationID operationID) |
Modifier and Type | Method and Description |
---|---|
void |
IReplicationNode.outNotificationSentAndExecute(OperationID operationId)
Notify and dispatch the replication event representing that a notification was sent
successfully
|
Modifier and Type | Method and Description |
---|---|
OperationID |
ITransactionInContext.getOperationID() |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractReplicationEntryEventHandler.changeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int routingHash,
int version,
int previousVersion,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntryData) |
void |
IReplicationInEntryHandler.inChangeEntry(IReplicationInContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
int routingHash,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID) |
void |
AbstractReplicationEntryEventHandler.inChangeEntry(IReplicationInContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
int routingHash,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID) |
void |
IReplicationInEntryLeaseExpiredHandler.inEntryLeaseExpiredByUID(IReplicationInContext context,
String className,
String uid,
boolean isTransient,
OperationID operationID) |
void |
IReplicationInEvictEntryHandler.inEvictEntry(IReplicationInContext context,
String uid,
boolean isTransient,
OperationID operationID) |
void |
IReplicationInNotificationSentHandler.inNotificationSent(IReplicationInContext context,
OperationID operationId) |
void |
IReplicationInNotifyTemplateLeaseExpiredHandler.inNotifyTemplateLeaseExpired(IReplicationInContext context,
String className,
String uid,
OperationID operationID) |
void |
IReplicationInEntryHandler.inRemoveEntryByUID(IReplicationInContext context,
String typeName,
String uid,
boolean isTransient,
OperationID operationID) |
void |
AbstractReplicationEntryEventHandler.inRemoveEntryByUID(IReplicationInContext context,
String typeName,
String uid,
boolean isTransient,
OperationID operationID) |
abstract void |
AbstractReplicationEntryEventHandler.removeEntryByUid(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String uid,
boolean isTransient,
OperationID operationID) |
Modifier and Type | Field and Description |
---|---|
OperationID[] |
ReplicationOutContext._operationIDs |
Modifier and Type | Method and Description |
---|---|
OperationID |
ReplicationOutContext.getOperationID() |
OperationID[] |
ReplicationOutContext.getOperationIDs() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationNodeInFacade.inChangeEntry(IReplicationInContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
int routingHash,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID) |
void |
ReplicationNodeInFacade.inEntryLeaseExpiredByUID(IReplicationInContext context,
String className,
String uid,
boolean isTransient,
OperationID operationID) |
void |
ReplicationNodeInFacade.inEvictEntry(IReplicationInContext context,
String uid,
boolean isTransient,
OperationID operationID) |
void |
ReplicationNodeInFacade.inNotificationSent(IReplicationInContext context,
OperationID operationId) |
void |
ReplicationNodeInFacade.inNotifyTemplateLeaseExpired(IReplicationInContext context,
String className,
String uid,
OperationID operationID) |
void |
ReplicationNodeInFacade.inRemoveEntryByUID(IReplicationInContext context,
String typeName,
String uid,
boolean isTransient,
OperationID operationID) |
void |
ReplicationNode.outNotificationSentAndExecute(OperationID operationId) |
void |
ReplicationOutContext.setOperationID(OperationID operationID) |
void |
ReplicationOutContext.setOperationIDs(OperationID[] operationIDs) |
Constructor and Description |
---|
NotificationSentSyncOperation(OperationID operationId) |
Modifier and Type | Method and Description |
---|---|
void |
LocalClusterReplicationInTransactionHandler.changeEntry(IReplicationInBatchContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID) |
void |
LocalClusterReplicationInEntryHandler.inChangeEntry(IReplicationInContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
int routingHash,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID) |
void |
LocalClusterReplicationInEntryHandler.inRemoveEntryByUID(IReplicationInContext context,
String typeName,
String uid,
boolean isTransient,
OperationID operationID) |
void |
LocalClusterReplicationInTransactionHandler.removeEntryByUID(IReplicationInBatchContext context,
String typeName,
String uid,
OperationID operationID) |
Modifier and Type | Method and Description |
---|---|
OperationID |
UnknownEntryLeaseException.getOperationID() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSpaceReplicationEntryEventHandler.changeEntry(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int routingHash,
int version,
int previousVersion,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry) |
void |
SpaceReplicationTransactionEventHandler.changeEntry(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntryData) |
protected void |
BlobstorePrimaryBackupSpaceReplicationEntryEventHandler.changeEntryInSpace(IReplicationInContext context,
Transaction txn,
String uid,
int version,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry,
long timeToLive,
boolean twoPhaseCommit) |
protected void |
PrimaryBackupSpaceReplicationEntryEventHandler.changeEntryInSpace(IReplicationInContext context,
Transaction txn,
String uid,
int version,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry,
long timeToLive,
boolean twoPhaseCommit) |
protected void |
AbstractSpaceReplicationEntryEventHandler.changeEntryInSpace(IReplicationInContext context,
Transaction txn,
String uid,
int version,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntry,
long timeToLive,
boolean twoPhaseCommit) |
void |
SpaceReplicationEntryLeaseEventHandler.inEntryLeaseExpiredByUID(IReplicationInContext context,
String typeName,
String uid,
boolean isTransient,
OperationID operationID) |
void |
AbstractSpaceReplicationEntryEventHandler.inEvictEntry(IReplicationInContext context,
String uid,
boolean isTransient,
OperationID operationID) |
void |
SpaceReplicationTemplateEventHandler.inNotifyTemplateLeaseExpired(IReplicationInContext context,
String className,
String uid,
OperationID operationID) |
void |
AbstractSpaceReplicationEntryEventHandler.removeEntryByUid(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
String uid,
boolean isTransient,
OperationID operationID) |
void |
SpaceReplicationTransactionEventHandler.removeEntryByUID(IReplicationInContext context,
Transaction txn,
boolean twoPhaseCommit,
String uid,
boolean isTransient,
OperationID operationID) |
Constructor and Description |
---|
UnknownEntryLeaseException(String className,
String uid,
OperationID operationID,
UnknownLeaseException ex) |
Modifier and Type | Method and Description |
---|---|
OperationID |
IReplicationPacketEntryData.getOperationId() |
Modifier and Type | Method and Description |
---|---|
void |
ITransactionalBatchExecutionCallback.changeEntry(IReplicationInBatchContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID) |
void |
ITransactionalExecutionCallback.changeEntry(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID,
IEntryData previousEntryData) |
void |
ITransactionalBatchExecutionCallback.removeEntryByUID(IReplicationInBatchContext context,
String typeName,
String uid,
OperationID operationID) |
void |
ITransactionalExecutionCallback.removeEntryByUID(IReplicationInContext context,
Transaction transaction,
boolean twoPhaseCommit,
String uid,
boolean isTransient,
OperationID operationID) |
Constructor and Description |
---|
UnknownEntryLeaseConsumeResult(String className,
String uid,
OperationID operationId,
UnknownEntryLeaseException error) |
Modifier and Type | Method and Description |
---|---|
OperationID |
SingleUidReplicationPacketData.getOperationId() |
OperationID |
AbstractReplicationPacketSingleEntryData.getOperationId() |
OperationID |
SingleReplicationPacketData.getOperationId() |
OperationID |
TransactionOnePhaseReplicationPacketData.getOperationID() |
OperationID |
TransactionReplicationPacketData.getOperationID()
Deprecated.
|
OperationID |
AbstractTransactionReplicationPacketData.getOperationID() |
OperationID |
AbstractPrepareDependentTransactionReplicationPacketData.getOperationID() |
Constructor and Description |
---|
AbstractPrepareDependentTransactionReplicationPacketData(ServerTransaction transaction,
OperationID operationID,
boolean fromGateway) |
CancelLeaseReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
OperationID operationID,
int routingHash,
boolean isFromGateway) |
ChangeReplicationPacketData(String typeName,
String uid,
Object id,
int version,
int previousVersion,
boolean isTransient,
IEntryData entryData,
OperationID operationID,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
IEntryData previousEntryData,
long timeToLive,
long expirationTime,
boolean fromGateway) |
EntryLeaseExpiredReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
OperationID operationID) |
EvictReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
OperationID operationID) |
ExtendEntryLeaseReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
long expirationTime,
long leaseTime,
OperationID operationID,
int routingHash,
boolean isFromGateway) |
ExtendNotifyTemplateLeaseReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
long expirationTime,
long leaseTime,
int objectType,
NotifyInfo notifyInfo,
OperationID operationID) |
NotifyTemplateLeaseExpiredReplicationPacketData(String className,
String uid,
IEntryData entryData,
OperationID operationID) |
RemoveByUIDReplicationPacketData(String typeName,
String uid,
boolean isTransient,
IEntryData entryData,
OperationID operationID,
boolean fromGateway) |
RemoveNotifyTemplateReplicationPacketData(String className,
NotifyInfo notifyInfo,
int objectType,
String templateUid,
boolean isTransient,
IEntryData entryData,
OperationID operationID) |
SingleUidReplicationPacketData(String uid,
OperationID operationID,
boolean isTransient,
boolean fromGateway,
IEntryData entryData) |
TransactionAbortReplicationPacketData(ServerTransaction transaction,
OperationID operationID,
boolean fromGateway) |
TransactionCommitReplicationPacketData(ServerTransaction transaction,
OperationID operationID,
boolean fromGateway) |
TransactionOnePhaseReplicationPacketData(OperationID operationID,
boolean fromGateway) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationNotificationInTransactionEntryHandler.changeEntry(IReplicationInBatchContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID) |
void |
AbstractReplicationNotificationInEntryHandler.handleEntryLeaseExpiredByUID(IReplicationInContext context,
boolean inTransaction,
String className,
String uid,
boolean isTransient,
OperationID operationID) |
void |
AbstractReplicationNotificationInEntryHandler.handleRemoveEntryByUID(IReplicationInContext context,
boolean inTransaction,
String uid,
boolean isTransient,
OperationID operationID) |
void |
AbstractReplicationNotificationInEntryHandler.inChangeEntry(IReplicationInContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
int routingHash,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID) |
void |
AbstractReplicationNotificationInEntryHandler.inEntryLeaseExpiredByUID(IReplicationInContext context,
String className,
String uid,
boolean isTransient,
OperationID operationID) |
void |
AbstractReplicationNotificationInEntryHandler.inRemoveEntryByUID(IReplicationInContext context,
String typeName,
String uid,
boolean isTransient,
OperationID operationID) |
void |
ReplicationNotificationInTransactionEntryHandler.removeEntryByUID(IReplicationInBatchContext context,
String typeName,
String uid,
OperationID operationID) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceEngine.abort(TransactionManager mgr,
ServerTransaction st,
boolean supportsTwoPhaseReplication,
OperationID operationID) |
void |
SpaceImpl.abortImpl(TransactionManager mgr,
Object id,
boolean supportsTwoPhaseReplication,
OperationID operationID) |
void |
SpaceEngine.abortSA(TransactionManager mgr,
ServerTransaction st,
boolean fromLeaseExpiration,
boolean verifyExpiredXtn,
boolean supportsTwoPhaseReplication,
OperationID operationID) |
void |
DuplicateOperationIDFilter.add(OperationID operationID) |
void |
NullDuplicateOperationIDFilter.add(OperationID operationID) |
void |
BackupFailoverOperationIDFilter.add(OperationID operationID) |
void |
SpaceEngine.commit(TransactionManager mgr,
ServerTransaction st,
boolean supportsTwoPhaseReplication,
OperationID operationID,
boolean mayBeFromReplication) |
void |
SpaceImpl.commitImpl(TransactionManager mgr,
Object id,
int numOfParticipants,
boolean supportsTwoPhaseReplication,
OperationID operationID,
boolean mayBeFromReplication) |
boolean |
DuplicateOperationIDFilter.contains(OperationID operationID) |
boolean |
NullDuplicateOperationIDFilter.contains(OperationID operationID) |
boolean |
BackupFailoverOperationIDFilter.contains(OperationID operationID) |
String |
SpaceEngine.createTransactionDetailsString(ServerTransaction st,
OperationID operationID) |
void |
SpaceEngine.enableDuplicateExecutionProtection(OperationID operationID) |
int |
SpaceEngine.prepare(TransactionManager mgr,
ServerTransaction st,
boolean singleParticipant,
boolean supportsTwoPhaseReplication,
OperationID operationID) |
int |
SpaceEngine.prepareAndCommit(TransactionManager mgr,
ServerTransaction st,
OperationID operationID)
Prepare and commit the transaction - called for single participant transaction or transaction
without changes
|
int |
SpaceImpl.prepareAndCommitImpl(TransactionManager mgr,
Object id,
OperationID operationID) |
Constructor and Description |
---|
BackupFailoverOperationIDFilter(IAddOnlySet<OperationID> duplicateFilter,
long duplicateProtectionTimeInterval) |
Modifier and Type | Field and Description |
---|---|
protected OperationID |
NotifyContextsHolder._operationId |
Modifier and Type | Method and Description |
---|---|
OperationID |
NotifyContext.getOperationId() |
Modifier and Type | Method and Description |
---|---|
void |
NotifyBackupLog.clearTriggered(OperationID operationId)
Check if all notifications were received and clear them
|
void |
NotifyBackupLog.inNotificationSent(IReplicationInContext context,
OperationID operationId) |
Constructor and Description |
---|
NotifyContext(IEntryHolder notifyEntry,
IEntryHolder referanceEntry,
OperationID operationId,
NotifyActionType notifyType) |
NotifyContext(IEntryHolder notifyEntry,
OperationID operationId,
NotifyActionType notifyType) |
NotifyContextsHolder(IEntryHolder originalEntry,
IEntryHolder newEntry,
OperationID operationId,
NotifyActionType notifyType) |
UpdateNotifyContextHolder(IEntryHolder originalEntry,
IEntryHolder newEntry,
OperationID operationId,
boolean isMatched,
boolean isRematched) |
Modifier and Type | Method and Description |
---|---|
OperationID |
TemplateHolder.getOperationID() |
OperationID |
ITemplateHolder.getOperationID() |
Modifier and Type | Method and Description |
---|---|
RemoteEvent |
NotifyTemplateHolder.createRemoteEvent(IEntryHolder entryHolder,
IEntryHolder oldEntryHolder,
NotifyActionType notifyType,
OperationID operationID,
IJSpace spaceProxy,
boolean fromReplication) |
RemoteEvent |
NotifyTemplateHolder.createRemoteEvent(IEntryHolder entryHolder,
NotifyActionType notifyType,
OperationID operationID,
IJSpace spaceProxy,
boolean fromReplication) |
Modifier and Type | Method and Description |
---|---|
void |
MirrorReplicationInHandler.changeEntry(IReplicationInBatchContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
long timeToLive,
int routingHash,
Collection<SpaceEntryMutator> spaceEntryMutators,
boolean isTransient,
OperationID operationID) |
void |
MirrorReplicationInEntryHandler.inChangeEntry(IReplicationInContext context,
String typeName,
String uid,
Object id,
int version,
int previousVersion,
int routingHash,
long timeToLive,
Collection<SpaceEntryMutator> mutators,
boolean isTransient,
OperationID operationID) |
void |
MirrorReplicationInEntryHandler.inRemoveEntryByUID(IReplicationInContext context,
String typeName,
String uid,
boolean isTransient,
OperationID operationID) |
void |
MirrorReplicationInHandler.removeEntryByUID(IReplicationInBatchContext context,
String typeName,
String uid,
OperationID operationID) |
Modifier and Type | Method and Description |
---|---|
OperationID |
ITransportPacket.getOperationID() |
OperationID |
AbstractEntryPacket.getOperationID() |
Modifier and Type | Method and Description |
---|---|
static IEntryPacket |
EntryPacketFactory.createFullPacket(IEntryData entryData,
OperationID operationID,
String uid,
boolean isTransient,
QueryResultTypeInternal queryResultType) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacket(IEntryData entryData,
String uid,
OperationID operationId,
boolean isTransient) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacket(IEntryHolder entryHolder,
ITemplateHolder template,
String uid,
long timeToLive,
IEntryData entryData,
OperationID operationID) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(IEntryHolder entryHolder,
ITemplateHolder template,
String uid,
long timeToLive,
IEntryData entryData,
OperationID operationId) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacket(IEntryHolder entryHolder,
ITemplateHolder template,
String uid,
long timeToLive,
OperationID operationId) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacket(IEntryHolder entryHolder,
OperationID operationID) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacket(ITemplateHolder template,
String uid,
long timeToLive,
OperationID operationId) |
static IEntryPacket |
EntryPacketFactory.createFullPacketForReplication(IEntryHolder entryHolder,
OperationID operationID) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacketForReplication(NotifyTemplateHolder template,
OperationID operationID) |
static IEntryPacket |
EntryPacketFactory.createPartialUpdatePacketForReplication(IEntryHolder entryHolder,
OperationID operationID,
boolean[] partialUpdatedValuesIndicators) |
static IEntryPacket |
EntryPacketFactory.createRemovePacketForPersistency(IEntryHolder entryHolder,
OperationID operationID) |
void |
ITransportPacket.setOperationID(OperationID operationID) |
void |
AbstractEntryPacket.setOperationID(OperationID operationID) |
Modifier and Type | Method and Description |
---|---|
OperationID |
LeaseManager.createOperationIDForLeaseExpirationEvent() |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
LeaseManager.cancel(String entryUid,
String classname,
int objectType,
boolean fromReplication,
boolean origin,
boolean lease_expired,
OperationID operationID,
boolean isFromGateway) |
EntryArrivedPacket |
EntryArrivedPacketsFactory.getPacket(OperationID operationID,
IEntryHolder entryHolder,
ServerTransaction xtn,
boolean notifyListeners,
IEntryHolder entryValueToNotify,
boolean fromReplication)
returns a constructed EntryArrivedPacket extracted from the pool of resources.
|
Constructor and Description |
---|
EntryTakenPacket(OperationID operationID,
IEntryHolder entryHolder,
ServerTransaction xtn,
IEntryHolder entryValueToNotify,
boolean fromReplication) |
Modifier and Type | Method and Description |
---|---|
OperationID |
XtnData.getOperationID(String uid) |
Modifier and Type | Method and Description |
---|---|
void |
XtnData.addLockedEntry(IEntryCacheInfo pEntry,
OperationID operationID,
boolean fifo) |
boolean |
XtnData.isOperationID(OperationID oi) |
void |
CacheManager.lockEntry(XtnData xtn,
IEntryCacheInfo pEntry,
OperationID operationID) |
void |
XtnData.updateLock(IEntryCacheInfo pEntry,
OperationID operationID,
boolean isReadOperation,
boolean fifo)
When user operation under transaction is upgraded from read to update/take, the order of
entry should be changed to the most recent, so that the changes in prepare come in the right
order.
|
void |
CacheManager.updateLock(XtnData xtn,
IEntryCacheInfo pEntry,
OperationID operationID,
int templateOperation) |
Modifier and Type | Method and Description |
---|---|
OperationID |
Context.getOperationID() |
OperationID[] |
Context.getOperationIDs() |
Modifier and Type | Method and Description |
---|---|
void |
Context.setOperationID(OperationID operationID) |
void |
Context.setOperationIDs(OperationID[] opIDs) |
Modifier and Type | Method and Description |
---|---|
OperationID |
EntryArrivedRemoteEvent.getOperationID() |
Modifier and Type | Method and Description |
---|---|
OperationID |
FifoBackgroundRequest.getOperationID() |
Constructor and Description |
---|
FifoBackgroundRequest(OperationID operID,
boolean isNotifyRequest,
boolean isNonNotifyRequest,
IEntryHolder eh,
IEntryHolder originalEntry,
boolean fromReplication,
int spaceOperation,
ServerTransaction txn,
IEntryHolder cloneEH) |
FifoBackgroundRequest(OperationID operID,
boolean isNotifyRequest,
boolean isNonNotifyRequest,
IEntryHolder eh,
IEntryHolder originalEntry,
boolean fromReplication,
ITemplateHolder template) |
Modifier and Type | Method and Description |
---|---|
OperationID |
BusPacket.getOperationID() |
Modifier and Type | Method and Description |
---|---|
void |
BusPacket.constructBusPacket(OperationID operationID,
IEntryHolder entryHolder,
ServerTransaction xtn,
long timeout)
Constructs a BusPacket.
|
void |
EntryArrivedPacket.constructEntryArrivedPacket(OperationID operationID,
IEntryHolder entryHolder,
ServerTransaction xtn,
boolean notifyListeners,
IEntryHolder entryValueToNotify,
boolean fromReplication)
Constructs an EntryArrivedPacket
|
void |
Processor.handleNotifyRegistration(NotifyTemplateHolder template,
boolean fromReplication,
AnswerHolder answer,
OperationID operationID) |
protected void |
BusPacket.setOperationID(OperationID operationID) |
Constructor and Description |
---|
BusPacket(OperationID operationID,
IEntryHolder entryHolder,
ServerTransaction xtn,
long timeout)
Creates a new BusPacket object.
|
EntryUnmatchedPacket(OperationID operationID,
IEntryHolder originalEntryHolder,
IEntryHolder newEntryHolder,
ServerTransaction xtn,
boolean fromReplication)
Constructs an EntryArrivedPacket
|
EntryUpdatedPacket(OperationID operationID,
IEntryHolder originalEntryHolder,
IEntryHolder newEntryHolder,
IEntryHolder notifyEH,
ServerTransaction xtn,
boolean fromReplication,
boolean notifyMatch,
boolean notifyRematch)
Constructs an EntryUpdatedPacket
|
RemoveWaitingForInfoSABusPacket(OperationID operationID,
IEntryHolder entryHolder,
ITemplateHolder template) |
UpdateOrWriteBusPacket(OperationID operationID,
IResponseContext respContext,
UpdateOrWriteContext ctx) |
UpdateOrWriteBusPacket(OperationID operationID,
IResponseContext respContext,
UpdateOrWriteContext ctx,
ReplyPacket respPacket) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionHandler.checkTransactionDisconnection(OperationID opid,
ServerTransaction txn) |
Modifier and Type | Field and Description |
---|---|
protected OperationID |
AbstractDMLQuery._operationID |
Modifier and Type | Method and Description |
---|---|
OperationID |
AbstractDMLQuery.getOperationID() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractDMLQuery.setOperationID(OperationID operationID) |
Modifier and Type | Method and Description |
---|---|
OperationID |
QueryEntryPacket.getOperationID() |
Modifier and Type | Method and Description |
---|---|
void |
QueryEntryPacket.setOperationID(OperationID operationID) |
Copyright © GigaSpaces.