public class FileRecoverer
extends java.lang.Object
Constructor and Description |
---|
FileRecoverer(int replicaId,
java.lang.String defaultDir) |
Modifier and Type | Method and Description |
---|---|
int |
getCkpLastConsensusId() |
byte[] |
getCkpState(java.lang.String ckpPath) |
byte[] |
getCkpStateHash() |
java.lang.String |
getLatestFile(java.lang.String extention) |
int |
getLogLastConsensusId() |
CommandsInfo[] |
getLogState(int index,
java.lang.String logPath)
Reads all log messages from the last log file created
|
CommandsInfo[] |
getLogState(long pointer,
int startOffset,
int number,
java.lang.String logPath)
Recover portions of the log for collaborative state transfer.
|
void |
recoverCkpHash(java.lang.String ckpPath) |
void |
transferCkpState(java.nio.channels.SocketChannel sChannel,
java.lang.String ckpPath) |
void |
transferLog(java.nio.channels.SocketChannel sChannel,
int index,
java.lang.String logPath) |
public CommandsInfo[] getLogState(int index, java.lang.String logPath)
public CommandsInfo[] getLogState(long pointer, int startOffset, int number, java.lang.String logPath)
start
- the index for which the commands start to be collectednumber
- the number of commands retrievedpublic byte[] getCkpState(java.lang.String ckpPath)
public void recoverCkpHash(java.lang.String ckpPath)
public void transferLog(java.nio.channels.SocketChannel sChannel, int index, java.lang.String logPath)
public void transferCkpState(java.nio.channels.SocketChannel sChannel, java.lang.String ckpPath)
public byte[] getCkpStateHash()
public int getCkpLastConsensusId()
public int getLogLastConsensusId()
public java.lang.String getLatestFile(java.lang.String extention)