|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.klomp.snark.Snark
public class Snark
Main Snark program startup class.
Nested Class Summary | |
---|---|
static interface |
Snark.CompleteListener
|
Field Summary | |
---|---|
I2PSnarkUtil |
_util
|
ConnectionAcceptor |
acceptor
|
(package private) String |
activity
|
static int |
ALL
|
(package private) boolean |
allChecked
|
(package private) boolean |
allocating
|
(package private) boolean |
checking
|
Snark.CompleteListener |
completeListener
|
PeerCoordinator |
coordinator
|
static int |
DEBUG
|
static int |
ERROR
|
(package private) byte[] |
id
|
static int |
INFO
|
(package private) static int |
MAX_TOTAL_UPLOADERS
|
MetaInfo |
meta
|
(package private) static int |
MIN_TOTAL_UPLOADERS
Maintain a configurable total uploader cap coordinatorListener |
static int |
NOTICE
|
(package private) boolean |
prechecking
|
static String |
PROP_MAX_CONNECTIONS
|
String |
rootDataDir
|
boolean |
stopped
|
Storage |
storage
|
String |
torrent
|
TrackerClient |
trackerclient
|
static int |
WARNING
|
Constructor Summary | |
---|---|
Snark(I2PAppContext ctx,
Properties opts,
String torrent,
StorageListener slistener,
boolean start,
String rootDir)
single torrent - via router |
|
Snark(I2PSnarkUtil util,
String torrent,
String ip,
int user_port,
StorageListener slistener,
CoordinatorListener clistener)
from main() via parseArguments() single torrent |
|
Snark(I2PSnarkUtil util,
String torrent,
String ip,
int user_port,
StorageListener slistener,
CoordinatorListener clistener,
Snark.CompleteListener complistener,
PeerCoordinatorSet peerCoordinatorSet,
ConnectionAcceptor connectionAcceptor,
boolean start,
String rootDir)
multitorrent |
Method Summary | |
---|---|
void |
fatal(String s)
Aborts program abnormally. |
void |
fatal(String s,
Throwable t)
Aborts program abnormally. |
static void |
main(String[] args)
|
boolean |
overUpBWLimit()
|
boolean |
overUpBWLimit(long total)
|
boolean |
overUploadLimit(int uploaders)
|
(package private) static Snark |
parseArguments(String[] args)
|
(package private) static Snark |
parseArguments(String[] args,
StorageListener slistener,
CoordinatorListener clistener)
Sets debug, ip and torrent variables then creates a Snark instance. |
void |
peerChange(PeerCoordinator coordinator,
Peer peer)
coordinatorListener |
void |
setWantedPieces(Storage storage)
Reset the peer's wanted pieces table Call after the storage double-check fails |
void |
shutdown()
Called when the SnarkShutdown hook has finished shutting down all subcomponents. |
void |
startTorrent()
Start up contacting peers and querying the tracker |
void |
stopTorrent()
Stop contacting the tracker and talking with peers |
void |
storageAllChecked(Storage storage)
Called when all pieces in the storage have been checked. |
void |
storageAllocated(Storage storage,
long length)
Called to indicate that length bytes have been allocated. |
void |
storageChecked(Storage storage,
int num,
boolean checked)
Called when storage is being checked and the num piece of that total pieces has been checked. |
void |
storageCompleted(Storage storage)
Called the one time when the data is completely received and checked. |
void |
storageCreateFile(Storage storage,
String name,
long length)
Called when the storage creates a new file of a given length. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final int ERROR
public static final int WARNING
public static final int NOTICE
public static final int INFO
public static final int DEBUG
public static final int ALL
String activity
public static final String PROP_MAX_CONNECTIONS
public String torrent
public MetaInfo meta
public Storage storage
public PeerCoordinator coordinator
public ConnectionAcceptor acceptor
public TrackerClient trackerclient
public String rootDataDir
public Snark.CompleteListener completeListener
public boolean stopped
byte[] id
public I2PSnarkUtil _util
boolean allocating
boolean allChecked
boolean checking
boolean prechecking
static final int MIN_TOTAL_UPLOADERS
static final int MAX_TOTAL_UPLOADERS
Constructor Detail |
---|
Snark(I2PSnarkUtil util, String torrent, String ip, int user_port, StorageListener slistener, CoordinatorListener clistener)
public Snark(I2PAppContext ctx, Properties opts, String torrent, StorageListener slistener, boolean start, String rootDir)
public Snark(I2PSnarkUtil util, String torrent, String ip, int user_port, StorageListener slistener, CoordinatorListener clistener, Snark.CompleteListener complistener, PeerCoordinatorSet peerCoordinatorSet, ConnectionAcceptor connectionAcceptor, boolean start, String rootDir)
Method Detail |
---|
public static void main(String[] args)
public void startTorrent()
public void stopTorrent()
static Snark parseArguments(String[] args)
static Snark parseArguments(String[] args, StorageListener slistener, CoordinatorListener clistener)
public void fatal(String s)
public void fatal(String s, Throwable t)
public void peerChange(PeerCoordinator coordinator, Peer peer)
peerChange
in interface CoordinatorListener
public void storageCreateFile(Storage storage, String name, long length)
StorageListener
storageCreateFile
in interface StorageListener
public void storageAllocated(Storage storage, long length)
StorageListener
storageAllocated
in interface StorageListener
public void storageChecked(Storage storage, int num, boolean checked)
StorageListener
storageChecked
in interface StorageListener
public void storageAllChecked(Storage storage)
StorageListener
storageAllChecked
in interface StorageListener
public void storageCompleted(Storage storage)
StorageListener
storageCompleted
in interface StorageListener
public void setWantedPieces(Storage storage)
StorageListener
setWantedPieces
in interface StorageListener
public void shutdown()
ShutdownListener
shutdown
in interface ShutdownListener
public boolean overUploadLimit(int uploaders)
overUploadLimit
in interface CoordinatorListener
public boolean overUpBWLimit()
overUpBWLimit
in interface CoordinatorListener
public boolean overUpBWLimit(long total)
overUpBWLimit
in interface CoordinatorListener
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |