Package com.orientechnologies.orient.distributed.context

Class OSyncState

java.lang.Object

com.orientechnologies.orient.distributed.context.OSyncState

public class OSyncState
extends Object

Constructor Summary

Constructors

Constructor	Description
OSyncState(ODatabaseId dbId, OSyncId syncId, ONodeId sender, ONodeId receiver, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)

Method Summary

Modifier and Type	Method	Description
ODatabaseId	getDbId()
int	getMessageCount()
OSyncMode	getMode()
ONodeId	getReceiver()
ONodeId	getSender()
Optional<OTransactionSequenceStatus>	getSequenceStatus()
OSyncId	getSyncId()
long	getTotalsize()
boolean	isClose()
boolean	isIncremental()
void	receiveData(byte[] data, boolean finished)
void	requestNext(boolean close)
void	setReceiver(OReceiverInputStream receiver)
void	transaferd(long size)
void	waitForNext()

Methods inherited from class java.lang.Object

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

Constructor Details

OSyncState

public OSyncState(ODatabaseId dbId,
 OSyncId syncId,
 ONodeId sender,
 ONodeId receiver,
 OSyncMode mode,
 Optional<OTransactionSequenceStatus> sequenceStatus)

Method Details

transaferd

public void transaferd(long size)

getMessageCount

public int getMessageCount()

getTotalsize

public long getTotalsize()

getDbId

public ODatabaseId getDbId()

getSender

public ONodeId getSender()

getReceiver

public ONodeId getReceiver()

getMode

public OSyncMode getMode()

getSyncId

public OSyncId getSyncId()

isIncremental

public boolean isIncremental()

receiveData

public void receiveData(byte[] data,
 boolean finished)

setReceiver

public void setReceiver(OReceiverInputStream receiver)

isClose

public boolean isClose()

waitForNext

public void waitForNext()
                 throws InterruptedException

Throws:

InterruptedException

requestNext

public void requestNext(boolean close)

getSequenceStatus

public Optional<OTransactionSequenceStatus> getSequenceStatus()