com.orientechnologies.orient.server.distributed

Class ODistributedSyncConfiguration

java.lang.Object

com.orientechnologies.orient.server.distributed.ODistributedSyncConfiguration

public class ODistributedSyncConfiguration
extends Object

Immutable class to store and handle information about synchronization between nodes.

Author:

Luca Garulli (l.garulli--at--orientdb.com)

Constructor Summary

Constructors

Constructor and Description
ODistributedSyncConfiguration(ODistributedServerManager manager, String databaseName, File file)

Method Summary

Modifier and Type	Method and Description
OLogSequenceNumber	getLastLSN(String server)
long	getLastOperationTimestamp()
ODistributedMomentum	getMomentum()
void	load()
void	removeServer(String nodeName)
void	save()
void	setLastLSN(String server, OLogSequenceNumber lsn, boolean updateLastOperationTimestamp)
protected void	updateInternalDocument()

Methods inherited from class java.lang.Object

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

Constructor Detail

ODistributedSyncConfiguration

public ODistributedSyncConfiguration(ODistributedServerManager manager,
                                     String databaseName,
                                     File file)
                              throws IOException

Throws:

IOException

Method Detail

getMomentum

public ODistributedMomentum getMomentum()

getLastLSN

public OLogSequenceNumber getLastLSN(String server)

setLastLSN

public void setLastLSN(String server,
                       OLogSequenceNumber lsn,
                       boolean updateLastOperationTimestamp)
                throws IOException

Throws:

IOException

load

public void load()
          throws IOException

Throws:

IOException

save

public void save()
          throws IOException

Throws:

IOException

getLastOperationTimestamp

public long getLastOperationTimestamp()

updateInternalDocument

protected void updateInternalDocument()

removeServer

public void removeServer(String nodeName)
                  throws IOException

Throws:

IOException