java.lang.Runnable
, EepGet.StatusListener
public class FetchAndAdd extends Snark implements EepGet.StatusListener, java.lang.Runnable
_util, PROP_MAX_CONNECTIONS
コンストラクタ | 説明 |
---|---|
FetchAndAdd(I2PAppContext ctx,
SnarkManager mgr,
java.lang.String url,
java.io.File dataDir) |
Caller should call _mgr.addDownloader(this), which
will start things off.
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
void |
attemptFailed(java.lang.String url,
long bytesTransferred,
long bytesRemaining,
int currentAttempt,
int numRetries,
java.lang.Exception cause) |
|
void |
attempting(java.lang.String url) |
|
void |
bytesTransferred(long alreadyTransferred,
int currentWrite,
long bytesTransferred,
long bytesRemaining,
java.lang.String url) |
alreadyTransferred - total of all attempts, not including currentWrite
If nonzero on the first call, a partial file of that length was found,
_and_ the server supports resume.
|
java.lang.String |
getBaseName() |
|
long |
getDownloaded() |
|
long |
getDownloadRate() |
|
byte[] |
getInfoHash() |
|
java.lang.String |
getName() |
|
long |
getNeededLength() |
Bytes still wanted.
|
int |
getPeerCount() |
|
long |
getRemainingLength() |
Bytes not yet in storage.
|
long |
getTotalLength() |
|
int |
getTrackerSeenPeers() |
|
void |
headerReceived(java.lang.String url,
int attemptNum,
java.lang.String key,
java.lang.String val) |
Note: Headers are not processed, and this is not called, for most error response codes,
unless setWriteErrorToOutput() is called before fetch().
|
boolean |
isStopped() |
|
void |
run() |
Set off by startTorrent()
|
void |
startTorrent() |
Start up contacting peers and querying the tracker.
|
void |
stopTorrent() |
Stop contacting the tracker and talking with peers
|
void |
transferComplete(long alreadyTransferred,
long bytesTransferred,
long bytesRemaining,
java.lang.String url,
java.lang.String outputFile,
boolean notModified) |
|
void |
transferFailed(java.lang.String url,
long bytesTransferred,
long bytesRemaining,
int currentAttempt) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addComments, addMessage, getCheckingProgress, getComments, getID, getMetaInfo, getNeeded, getPeerList, getPieceLength, getPieces, getRPCID, getSkippedLength, getStartedTime, getStorage, getTrackerProblems, getTrackerURL, getUploaded, getUploadRate, gotMetaInfo, isAllocating, isAutoStoppable, isChecking, isStarting, overUpBWLimit, overUpBWLimit, overUploadLimit, peerChange, restartAcceptor, setAutoStoppable, setStarting, setTrackerProblems, setTrackerSeenPeers, setWantedPieces, shutdown, stopTorrent, storageAllChecked, storageAllocated, storageChecked, storageCompleted, storageCreateFile, updatePiecePriorities
public FetchAndAdd(I2PAppContext ctx, SnarkManager mgr, java.lang.String url, java.io.File dataDir)
dataDir
- null to default to snark data directorypublic void run()
run
インタフェース内 java.lang.Runnable
public void startTorrent()
Snark
startTorrent
クラス内 Snark
public void stopTorrent()
Snark
stopTorrent
クラス内 Snark
public java.lang.String getName()
public java.lang.String getBaseName()
getBaseName
クラス内 Snark
public byte[] getInfoHash()
getInfoHash
クラス内 Snark
public long getTotalLength()
getTotalLength
クラス内 Snark
public long getRemainingLength()
Snark
getRemainingLength
クラス内 Snark
public long getNeededLength()
Snark
getNeededLength
クラス内 Snark
public long getDownloadRate()
getDownloadRate
クラス内 Snark
public long getDownloaded()
getDownloaded
クラス内 Snark
public int getPeerCount()
getPeerCount
クラス内 Snark
public int getTrackerSeenPeers()
getTrackerSeenPeers
クラス内 Snark
public void attemptFailed(java.lang.String url, long bytesTransferred, long bytesRemaining, int currentAttempt, int numRetries, java.lang.Exception cause)
attemptFailed
インタフェース内 EepGet.StatusListener
public void bytesTransferred(long alreadyTransferred, int currentWrite, long bytesTransferred, long bytesRemaining, java.lang.String url)
EepGet.StatusListener
bytesTransferred
インタフェース内 EepGet.StatusListener
public void transferComplete(long alreadyTransferred, long bytesTransferred, long bytesRemaining, java.lang.String url, java.lang.String outputFile, boolean notModified)
transferComplete
インタフェース内 EepGet.StatusListener
public void transferFailed(java.lang.String url, long bytesTransferred, long bytesRemaining, int currentAttempt)
transferFailed
インタフェース内 EepGet.StatusListener
public void headerReceived(java.lang.String url, int attemptNum, java.lang.String key, java.lang.String val)
EepGet.StatusListener
headerReceived
インタフェース内 EepGet.StatusListener
public void attempting(java.lang.String url)
attempting
インタフェース内 EepGet.StatusListener