ants.p2p.filesharing
Class MultipleSourcesDownloadManager

java.lang.Object
  java.lang.Thread
      ants.p2p.filesharing.MultipleSourcesDownloadManager

All Implemented Interfaces:

java.lang.Runnable

public class MultipleSourcesDownloadManager
extends java.lang.Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

static int	blocksPerSource
static int	MaxSources
java.beans.PropertyChangeSupport	propertyChangeSupport

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

MultipleSourcesDownloadManager(WarriorAnt n, java.lang.String fileName, java.lang.String fileHash, java.lang.String ed2kFileHash, long bytesDownloaded, int blockSize, long fileSize, java.lang.String extendedInfos)

Method Summary

void	addAutoresumeEngine(AutoresumeEngine ae)
boolean	addPeer(QueryFileTuple peerId)
boolean	checkCompleted()
void	checkDownloadedBlockGroups()
boolean	checkPartsToDownload(boolean[] downloadedBlockGroups, boolean[] inServiceBlockGroups, boolean[] remoteParts)
void	deactivateAutoresumeEngine()
QueryFileTuple	findInServicePeer(java.lang.String peerId)
QueryFileTuple	findPeer(java.lang.String peerId)
AutoresumeEngine	getAutoresumeEngine()
int	getAvaiablePreviewIndexes()
int	getBlockSize()
long	getByteDownloaded()
java.lang.Object[]	getChunkHashes()
boolean[]	getDownloadedBlockGroups()
java.lang.String	getED2KFileHash()
java.lang.String	getExtendedInfos()
java.lang.String	getFileHash()
java.lang.String	getFileName()
long	getFileSize()
java.util.List	getPeerList()
int	getPeersNumber()
java.lang.String	getPercentage()
double	getSpeedValue()
boolean	isAutoresumeActive()
void	removeAllPeers(boolean deactivateAutoresume)
void	removeAllPropertyChangeListeners()
QueryFileTuple	removePeer(java.lang.String peerID)
void	resetInterrupt()
void	run()
void	setInterrupt(boolean deactivateAutoresume)
java.lang.String	sizeToString(double dSize)
java.lang.String	speedToString()
java.lang.String	toString()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Field Detail

blocksPerSource

public static int blocksPerSource

MaxSources

public static int MaxSources

propertyChangeSupport

public java.beans.PropertyChangeSupport propertyChangeSupport

Constructor Detail

MultipleSourcesDownloadManager

public MultipleSourcesDownloadManager(WarriorAnt n,
                                      java.lang.String fileName,
                                      java.lang.String fileHash,
                                      java.lang.String ed2kFileHash,
                                      long bytesDownloaded,
                                      int blockSize,
                                      long fileSize,
                                      java.lang.String extendedInfos)
                               throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

getPeersNumber

public int getPeersNumber()

getAvaiablePreviewIndexes

public int getAvaiablePreviewIndexes()

addPeer

public boolean addPeer(QueryFileTuple peerId)

getPeerList

public java.util.List getPeerList()

removePeer

public QueryFileTuple removePeer(java.lang.String peerID)

removeAllPeers

public void removeAllPeers(boolean deactivateAutoresume)

setInterrupt

public void setInterrupt(boolean deactivateAutoresume)

resetInterrupt

public void resetInterrupt()

removeAllPropertyChangeListeners

public void removeAllPropertyChangeListeners()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

getBlockSize

public int getBlockSize()

getFileHash

public java.lang.String getFileHash()

getED2KFileHash

public java.lang.String getED2KFileHash()

getChunkHashes

public java.lang.Object[] getChunkHashes()

getFileName

public java.lang.String getFileName()

getExtendedInfos

public java.lang.String getExtendedInfos()

getFileSize

public long getFileSize()

getByteDownloaded

public long getByteDownloaded()

getDownloadedBlockGroups

public boolean[] getDownloadedBlockGroups()

getPercentage

public java.lang.String getPercentage()

speedToString

public java.lang.String speedToString()

getSpeedValue

public double getSpeedValue()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Thread

sizeToString

public java.lang.String sizeToString(double dSize)

checkPartsToDownload

public boolean checkPartsToDownload(boolean[] downloadedBlockGroups,
                                    boolean[] inServiceBlockGroups,
                                    boolean[] remoteParts)
                             throws java.lang.Exception

Throws:

java.lang.Exception

checkDownloadedBlockGroups

public void checkDownloadedBlockGroups()

findPeer

public QueryFileTuple findPeer(java.lang.String peerId)

findInServicePeer

public QueryFileTuple findInServicePeer(java.lang.String peerId)

addAutoresumeEngine

public void addAutoresumeEngine(AutoresumeEngine ae)

getAutoresumeEngine

public AutoresumeEngine getAutoresumeEngine()

deactivateAutoresumeEngine

public void deactivateAutoresumeEngine()

isAutoresumeActive

public boolean isAutoresumeActive()

checkCompleted

public boolean checkCompleted()