com.orientechnologies.orient.server.distributed.impl

Class OSyncReceiver

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.OSyncReceiver

All Implemented Interfaces:

Runnable

public class OSyncReceiver
extends Object
implements Runnable

Constructor Summary

Constructors

Constructor and Description
OSyncReceiver(ODistributedAbstractPlugin distributed, String databaseName, ODistributedDatabaseChunk firstChunk, AtomicReference<ODistributedMomentum> momentum, String iNode, String dbPath)

Method Summary

Modifier and Type	Method and Description
CountDownLatch	getDone()
PipedInputStream	getInputStream()
CountDownLatch	getStarted()
void	run()
protected long	writeDatabaseChunk(int iChunkId, ODistributedDatabaseChunk chunk, OutputStream out)

Methods inherited from class java.lang.Object

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

Constructor Detail

OSyncReceiver

public OSyncReceiver(ODistributedAbstractPlugin distributed,
                     String databaseName,
                     ODistributedDatabaseChunk firstChunk,
                     AtomicReference<ODistributedMomentum> momentum,
                     String iNode,
                     String dbPath)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

writeDatabaseChunk

protected long writeDatabaseChunk(int iChunkId,
                                  ODistributedDatabaseChunk chunk,
                                  OutputStream out)
                           throws IOException

Throws:

IOException

getStarted

public CountDownLatch getStarted()

getInputStream

public PipedInputStream getInputStream()

getDone

public CountDownLatch getDone()