Package 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	Description
OSyncReceiver(ODistributedPlugin distributed, String databaseName, ODistributedDatabaseChunk firstChunk, String iNode, String dbPath)

Method Summary

Modifier and Type	Method	Description
void	close()
CountDownLatch	getDone()
PipedInputStream	getInputStream()
CountDownLatch	getStarted()
void	run()
void	spawnReceiverThread()
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 Details

OSyncReceiver

public OSyncReceiver(ODistributedPlugin distributed,
 String databaseName,
 ODistributedDatabaseChunk firstChunk,
 String iNode,
 String dbPath)

Method Details

spawnReceiverThread

public void spawnReceiverThread()

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()

close

public void close()