com.hazelcast.spi.hotrestart.backup

Class HotRestartBackupOperation

java.lang.Object

com.hazelcast.spi.Operation

com.hazelcast.spi.hotrestart.backup.HotRestartBackupOperation

All Implemented Interfaces:

com.hazelcast.nio.serialization.DataSerializable, com.hazelcast.nio.serialization.IdentifiedDataSerializable, com.hazelcast.spi.impl.AllowedDuringPassiveState

public class HotRestartBackupOperation
extends com.hazelcast.spi.Operation
implements com.hazelcast.spi.impl.AllowedDuringPassiveState, com.hazelcast.nio.serialization.IdentifiedDataSerializable

Operation for performing cluster hot restart data backup. The backup operation is performed inside a transaction and this class is used for all phases of the transaction. The prepareOperation(Address, String, long) method is used for the prepare phase, the commitOperation(long, Address, String) is used for the commit phase and the rollbackOperation(Address, String) is used for for creating a new operation for the rollback phase.

Field Summary

Fields inherited from class com.hazelcast.spi.Operation

GENERIC_PARTITION_ID

Constructor Summary

Constructors

Constructor and Description
HotRestartBackupOperation()

Method Summary

Modifier and Type	Method and Description
void	beforeRun()
static HotRestartBackupOperation	commitOperation(long backupSeq, com.hazelcast.nio.Address initiator, String txnId) Create a operation for commiting a transaction of a cluster-wide hot restart backup.
int	getFactoryId()
int	getId()
String	getServiceName()
void	logError(Throwable e)
com.hazelcast.spi.ExceptionAction	onInvocationException(Throwable throwable)
static HotRestartBackupOperation	prepareOperation(com.hazelcast.nio.Address initiator, String txnId, long leaseTime) Create a operation for preparing a transaction of a cluster-wide hot restart backup.
protected void	readInternal(com.hazelcast.nio.ObjectDataInput in)
static HotRestartBackupOperation	rollbackOperation(com.hazelcast.nio.Address initiator, String txnId) Create a operation for transaction rollback of a cluster-wide hot restart backup.
void	run()
protected void	writeInternal(com.hazelcast.nio.ObjectDataOutput out)

Methods inherited from class com.hazelcast.spi.Operation

afterRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponse, getService, getWaitTimeout, isUrgent, onExecutionFailure, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, toString, validatesTarget, writeData

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.nio.serialization.DataSerializable

readData, writeData

Constructor Detail

HotRestartBackupOperation

public HotRestartBackupOperation()

Method Detail

prepareOperation

public static HotRestartBackupOperation prepareOperation(com.hazelcast.nio.Address initiator,
                                                         String txnId,
                                                         long leaseTime)

Create a operation for preparing a transaction of a cluster-wide hot restart backup.

Parameters:

initiator - the member which initiated the backup

txnId - the transaction ID

leaseTime - duration in ms after which this transaction will expire

Returns:

the prepare operation for hot restart backup

commitOperation

public static HotRestartBackupOperation commitOperation(long backupSeq,
                                                        com.hazelcast.nio.Address initiator,
                                                        String txnId)

Create a operation for commiting a transaction of a cluster-wide hot restart backup.

Parameters:

backupSeq - the suffix for the hot restart backup directory

initiator - the member which initiated the backup

txnId - the transaction ID

Returns:

the commit operation for hot restart backup

rollbackOperation

public static HotRestartBackupOperation rollbackOperation(com.hazelcast.nio.Address initiator,
                                                          String txnId)

Create a operation for transaction rollback of a cluster-wide hot restart backup.

Parameters:

initiator - the member which initiated the backup

txnId - the transaction ID

Returns:

the rollback operation for hot restart backup

beforeRun

public void beforeRun()
               throws Exception

Overrides:

beforeRun in class com.hazelcast.spi.Operation

Throws:

Exception

run

public void run()
         throws Exception

Overrides:

run in class com.hazelcast.spi.Operation

Throws:

Exception

logError

public void logError(Throwable e)

Overrides:

logError in class com.hazelcast.spi.Operation

onInvocationException

public com.hazelcast.spi.ExceptionAction onInvocationException(Throwable throwable)

Overrides:

onInvocationException in class com.hazelcast.spi.Operation

getServiceName

public String getServiceName()

Overrides:

getServiceName in class com.hazelcast.spi.Operation

writeInternal

protected void writeInternal(com.hazelcast.nio.ObjectDataOutput out)
                      throws IOException

Overrides:

writeInternal in class com.hazelcast.spi.Operation

Throws:

IOException

readInternal

protected void readInternal(com.hazelcast.nio.ObjectDataInput in)
                     throws IOException

Overrides:

readInternal in class com.hazelcast.spi.Operation

Throws:

IOException

getFactoryId

public int getFactoryId()

Specified by:

getFactoryId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

getId

public int getId()

Specified by:

getId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializable