eu.unicore.uftp.rsync

Class LocalChannel

java.lang.Object

eu.unicore.uftp.rsync.LocalChannel

All Implemented Interfaces:

MasterChannel, SlaveChannel

public class LocalChannel
extends Object
implements SlaveChannel, MasterChannel

for testing: direct channel between Slave and Master

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LocalChannel.ByteArrayChannel

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	closed

Constructor Summary

Constructors

Constructor and Description
LocalChannel(boolean dryRun)

Method Summary

Modifier and Type	Method and Description
RsyncData	receive()
ChecksumHolder	receiveChecksums()
void	sendData(long bytes, ByteChannel source, int blockIndex)
void	sendToMaster(List<Long> weakChecksums, List<byte[]> strongChecksums, int blocksize)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

closed

protected boolean closed

Constructor Detail

LocalChannel

public LocalChannel(boolean dryRun)

Method Detail

sendToMaster

public void sendToMaster(List<Long> weakChecksums,
                         List<byte[]> strongChecksums,
                         int blocksize)
                  throws IOException

Specified by:

sendToMaster in interface SlaveChannel

Throws:

IOException

receive

public RsyncData receive()
                  throws IOException

Specified by:

receive in interface SlaveChannel

Throws:

IOException

receiveChecksums

public ChecksumHolder receiveChecksums()

Specified by:

receiveChecksums in interface MasterChannel

sendData

public void sendData(long bytes,
                     ByteChannel source,
                     int blockIndex)
              throws IOException

Specified by:

sendData in interface MasterChannel

Throws:

IOException

shutdown

public void shutdown()
              throws IOException

Specified by:

shutdown in interface MasterChannel

Throws:

IOException