clientP2P

Class ClientDownload

java.lang.Object

tools.ServeErrors

clientP2P.ClientDownload

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

ClientDownloadTCP, ClientDownloadUDP

public abstract class ClientDownload
extends ServeErrors
implements java.lang.Runnable

Class to download file

Version:

1.0

Author:

Louis Royer, Flavien Haas, JS Auge

Field Summary

Fields

Modifier and Type	Field and Description
protected HostItem	client
(package private) static int	DIFF_PERCENT_PROGRESS
(package private) static int	DIFF_TIME_PROGRESS_MILLIS
protected java.lang.String	dirStorage
protected java.lang.String	filename
protected byte[]	hash512
protected java.util.List<HostItem>	hostList
protected int	lastPercentProgress
protected java.time.Instant	lastTimeProgress
protected Logger	logger
protected static long	MAX_PARTIAL_SIZE
protected java.util.List<java.lang.Long>	offsetsPending
protected java.util.List<java.lang.Long>	offsetsToAsk
protected java.lang.String	partsSubdir
protected java.util.Map<HostItem,java.lang.Long>	ratioUpdater
protected long	size
protected java.util.List<ClientDownloadPart>	sockList
protected boolean	stop
protected boolean	success
protected HostItem	tracker

Constructor Summary

Constructors

Constructor and Description
ClientDownload(java.lang.String filename, java.util.List<HostItem> hostList, java.lang.String partsSubdir, java.lang.String dirStorage, Logger logger, HostItem client, HostItem tracker) Constructor with parameters: filename, list of hosts, parts subdirectory and dirStorage

Method Summary

Modifier and Type	Method and Description
protected void	assignTasks() Assign tasks randomly to threads.
protected void	checkTasksStatus() Remove tasks from failed threads.
protected abstract void	closeHostItemSocket(HostItem hostItem) Close HostItem socket
protected abstract ClientDownloadPart	createDownloadPart(HostItem hostItem) Create a clientDownloadPart
byte[]	getHashSum512() Getter for hash512sum
protected byte[]	getHashSum512(HostItem hostItem) Get hashsum from server.
protected abstract java.lang.Object	getHostItemSocket(HostItem hostItem) Getter for HostItem socket
boolean	getSuccess() Success getter.
protected void	init() Initialize infos about file to download (size, hash512sum, partslist to dl).
protected void	initThreads() Starts threads for each server in hostList.
protected void	printProgression() Print progression of the download.
protected void	purgeList() Removes servers not owning the correct file to download from list.
protected void	reassembleFile() Reassemble file from file parts.
void	run() Runnable implementation
void	sendRatioUpdate() Send Ratio update to the tracker
protected void	setSize() Set size of file to download.
void	setStop() Asks thread to stop
protected void	stopTasks() Stop threads

Methods inherited from class tools.ServeErrors

createProtocolP2PPacket, sendEmptyDirectory, sendEmptyFile, sendInternalError, sendNotATracker, sendNotFound, sendUnknownHost, writeLog, writeLog

Methods inherited from class java.lang.Object

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

Field Detail

hostList

protected java.util.List<HostItem> hostList

filename

protected java.lang.String filename

hash512

protected byte[] hash512

sockList

protected java.util.List<ClientDownloadPart> sockList

ratioUpdater

protected java.util.Map<HostItem,java.lang.Long> ratioUpdater

offsetsToAsk

protected java.util.List<java.lang.Long> offsetsToAsk

offsetsPending

protected java.util.List<java.lang.Long> offsetsPending

stop

protected boolean stop

size

protected long size

MAX_PARTIAL_SIZE

protected static final long MAX_PARTIAL_SIZE

See Also:

Constant Field Values

partsSubdir

protected java.lang.String partsSubdir

dirStorage

protected java.lang.String dirStorage

success

protected boolean success

logger

protected Logger logger

client

protected HostItem client

tracker

protected HostItem tracker

lastPercentProgress

protected int lastPercentProgress

lastTimeProgress

protected java.time.Instant lastTimeProgress

DIFF_TIME_PROGRESS_MILLIS

static final int DIFF_TIME_PROGRESS_MILLIS

See Also:

Constant Field Values

DIFF_PERCENT_PROGRESS

static final int DIFF_PERCENT_PROGRESS

See Also:

Constant Field Values

Constructor Detail

ClientDownload

public ClientDownload(java.lang.String filename,
                      java.util.List<HostItem> hostList,
                      java.lang.String partsSubdir,
                      java.lang.String dirStorage,
                      Logger logger,
                      HostItem client,
                      HostItem tracker)

Constructor with parameters: filename, list of hosts, parts subdirectory and dirStorage

Parameters:

filename - name of file to download

hostList - list of servers

partsSubdir - directory to store .part files

dirStorage - directory to write assembled file

logger - Logger

client - HostItem of the application

tracker - HostItem of the tracker

Method Detail

getSuccess

public boolean getSuccess()

Success getter.

Returns:

true when file have successfully been reassembled.

getHashSum512

public byte[] getHashSum512()

Getter for hash512sum

Returns:

hash512sum

stopTasks

protected void stopTasks()

Stop threads

setStop

public void setStop()

Asks thread to stop

assignTasks

protected void assignTasks()
                    throws InternalError

Assign tasks randomly to threads.

Throws:

InternalError

createDownloadPart

protected abstract ClientDownloadPart createDownloadPart(HostItem hostItem)

Create a clientDownloadPart

Parameters:

hostItem - Hostitem of the server

initThreads

protected void initThreads()

Starts threads for each server in hostList.

checkTasksStatus

protected void checkTasksStatus()
                         throws InternalError

Remove tasks from failed threads. Update done status.

Throws:

InternalError

sendRatioUpdate

public void sendRatioUpdate()

Send Ratio update to the tracker

getHashSum512

protected byte[] getHashSum512(HostItem hostItem)
                        throws InternalError

Get hashsum from server.

Parameters:

hostItem - server to ask hash

Returns:

hash512sum

Throws:

InternalError

purgeList

protected void purgeList()
                  throws InternalError

Removes servers not owning the correct file to download from list. This is done by comparing hash512sum.

Throws:

InternalError

reassembleFile

protected void reassembleFile()

Reassemble file from file parts. Set success to true if file is reassembled successfully.

setSize

protected void setSize()
                throws InternalError

Set size of file to download.

Throws:

InternalError

closeHostItemSocket

protected abstract void closeHostItemSocket(HostItem hostItem)

Close HostItem socket

Parameters:

hostItem - HostItem

run

public void run()

Runnable implementation

Specified by:

run in interface java.lang.Runnable

printProgression

protected void printProgression()

Print progression of the download.

init

protected void init()
             throws InternalError

Initialize infos about file to download (size, hash512sum, partslist to dl). Also download first partfile (to get size).

Throws:

InternalError

getHostItemSocket

protected abstract java.lang.Object getHostItemSocket(HostItem hostItem)
                                               throws java.net.SocketException,
                                                      java.net.UnknownHostException,
                                                      java.io.IOException

Getter for HostItem socket

Parameters:

hostItem - HostItem

Throws:

java.net.SocketException

java.net.UnknownHostException

java.io.IOException