eu.unicore.uftp.rsync

Class Slave

java.lang.Object

eu.unicore.uftp.rsync.Slave

All Implemented Interfaces:

Callable<RsyncStats>

public class Slave
extends Object
implements Callable<RsyncStats>

the slave has an out-of-date copy of a file which should be synchronized with the master copy.

Author:

schuller

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BLOCKSIZE

Constructor Summary

Constructors

Constructor and Description
Slave(File file, SlaveChannel channel, String name)
Slave(RandomAccessFile file, SlaveChannel channel, String name) using the default blocksize
Slave(RandomAccessFile file, SlaveChannel channel, String name, int blocksize)

Method Summary

Modifier and Type	Method and Description
RsyncStats	call()
protected void	computeChecksums()
int	getBlocksize()
SlaveChannel	getChannel()
List<byte[]>	getStrongChecksums()
File	getTmpFile(File file)
List<Long>	getWeakChecksums()
static int	reasonableBlockSize(File file)
void	reconstructFile()
void	setFileAccess(UserFileAccess f)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_BLOCKSIZE

public static final int DEFAULT_BLOCKSIZE

See Also:

Constant Field Values

Constructor Detail

Slave

public Slave(File file,
             SlaveChannel channel,
             String name)
      throws FileNotFoundException

Throws:

FileNotFoundException

Slave

public Slave(RandomAccessFile file,
             SlaveChannel channel,
             String name)

using the default blocksize

Parameters:

local - file that should be synchronized with the master

channel - - communication to the master

name - - file name

Slave

public Slave(RandomAccessFile file,
             SlaveChannel channel,
             String name,
             int blocksize)

Parameters:

file - - local file that should be synchronized with the master

channel - - communication to the master

blocksize -

Method Detail

call

public RsyncStats call()
                throws Exception

Specified by:

call in interface Callable<RsyncStats>

Throws:

Exception

reconstructFile

public void reconstructFile()
                     throws Exception

Throws:

Exception

computeChecksums

protected void computeChecksums()
                         throws IOException

Throws:

IOException

getChannel

public SlaveChannel getChannel()

getBlocksize

public int getBlocksize()

getWeakChecksums

public List<Long> getWeakChecksums()

getStrongChecksums

public List<byte[]> getStrongChecksums()

setFileAccess

public void setFileAccess(UserFileAccess f)

getTmpFile

public File getTmpFile(File file)

reasonableBlockSize

public static int reasonableBlockSize(File file)