Package net.i2p.router.update

Class UpdateRunner

java.lang.Object

java.lang.Thread

net.i2p.util.I2PThread

net.i2p.util.I2PAppThread

net.i2p.router.update.UpdateRunner

All Implemented Interfaces:

Runnable, UpdateTask, EepGet.StatusListener

Direct Known Subclasses:

DevSU3UpdateChecker, DevSU3UpdateRunner, NewsFetcher, PluginUpdateChecker, PluginUpdateRunner, UnsignedUpdateChecker, UnsignedUpdateRunner

class UpdateRunner
extends I2PAppThread
implements UpdateTask, EepGet.StatusListener

The downloader for router signed updates, and the base class for all the other Checkers and Runners.

Since:

0.9.4 moved from UpdateHandler

Nested Class Summary

Nested classes/interfaces inherited from class net.i2p.util.I2PThread

I2PThread.OOMEventListener

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

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected final ByteArrayOutputStream	_baos	56 byte header, only used for suds
protected final RouterContext	_context
protected URI	_currentURI
protected EepGet	_get
protected boolean	_isPartial	tells the listeners what mode we are in - set to true in extending classes for checks
protected boolean	_isRunning
protected final Log	_log
protected final UpdateMethod	_method
protected final ConsoleUpdateManager	_mgr
protected String	_newVersion	set by the listeners on completion
protected final UpdateType	_type
protected final String	_updateFile
protected final List<URI>	_urls
protected static final long	CONNECT_TIMEOUT
protected boolean	done
protected static final long	INACTIVITY_TIMEOUT
protected static final long	NOPROXY_INACTIVITY_TIMEOUT

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
UpdateRunner(RouterContext ctx, ConsoleUpdateManager mgr, UpdateType type, List<URI> uris)	Uses router version for partial checks
UpdateRunner(RouterContext ctx, ConsoleUpdateManager mgr, UpdateType type, List<URI> uris, String currentVersion)
UpdateRunner(RouterContext ctx, ConsoleUpdateManager mgr, UpdateType type, UpdateMethod method, List<URI> uris)	Uses router version for partial checks
UpdateRunner(RouterContext ctx, ConsoleUpdateManager mgr, UpdateType type, UpdateMethod method, List<URI> uris, String currentVersion)

Method Summary

Modifier and Type	Method	Description
protected String	_t(String s)	translate a string
protected String	_t(String s, Object o)	translate a string with a parameter
void	attemptFailed(String url, long bytesTransferred, long bytesRemaining, int currentAttempt, int numRetries, Exception cause)
void	attempting(String url)
void	bytesTransferred(long alreadyTransferred, int currentWrite, long bytesTransferred, long bytesRemaining, String url)	subclasses should override
String	getID()	Valid for plugins
UpdateMethod	getMethod()
UpdateType	getType()
URI	getURI()	The current URI being checked or downloaded from.
void	headerReceived(String url, int attemptNum, String key, String val)	Note: Headers are not processed, and this is not called, for most error response codes, unless setWriteErrorToOutput() is called before fetch().
boolean	isRunning()
protected static String	linkify(String url)
void	run()
void	shutdown()
String	toString()
void	transferComplete(long alreadyTransferred, long bytesTransferred, long bytesRemaining, String url, String outputFile, boolean notModified)	subclasses should override
void	transferFailed(String url, long bytesTransferred, long bytesRemaining, int currentAttempt)	subclasses should override
protected void	update()	Loop through the entire list of update URLs.
protected void	updateStatus(String s)

Methods inherited from class net.i2p.util.I2PAppThread

addOOMEventThreadListener, fireOOM, removeOOMEventThreadListener

Methods inherited from class net.i2p.util.I2PThread

addOOMEventListener, removeOOMEventListener, start

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.i2p.update.UpdateTask

start

Field Details

_context

protected final RouterContext _context

_log

protected final Log _log

_mgr

protected final ConsoleUpdateManager _mgr

_type

protected final UpdateType _type

_method

protected final UpdateMethod _method

_urls

protected final List<URI> _urls

_updateFile

protected final String _updateFile

_isRunning

protected volatile boolean _isRunning

done

protected boolean done

_get

protected EepGet _get

_isPartial

protected boolean _isPartial

tells the listeners what mode we are in - set to true in extending classes for checks

_newVersion

protected String _newVersion

set by the listeners on completion

_baos

protected final ByteArrayOutputStream _baos

56 byte header, only used for suds

_currentURI

protected URI _currentURI

CONNECT_TIMEOUT

protected static final long CONNECT_TIMEOUT

See Also:

• Constant Field Values

INACTIVITY_TIMEOUT

protected static final long INACTIVITY_TIMEOUT

See Also:

• Constant Field Values

NOPROXY_INACTIVITY_TIMEOUT

protected static final long NOPROXY_INACTIVITY_TIMEOUT

See Also:

• Constant Field Values

Constructor Details

UpdateRunner

public UpdateRunner(RouterContext ctx,
 ConsoleUpdateManager mgr,
 UpdateType type,
 List<URI> uris)

Uses router version for partial checks

UpdateRunner

public UpdateRunner(RouterContext ctx,
 ConsoleUpdateManager mgr,
 UpdateType type,
 UpdateMethod method,
 List<URI> uris)

Uses router version for partial checks

Since:

0.9.9

UpdateRunner

public UpdateRunner(RouterContext ctx,
 ConsoleUpdateManager mgr,
 UpdateType type,
 List<URI> uris,
 String currentVersion)

Parameters:

currentVersion - used for partial checks

Since:

0.9.7

UpdateRunner

public UpdateRunner(RouterContext ctx,
 ConsoleUpdateManager mgr,
 UpdateType type,
 UpdateMethod method,
 List<URI> uris,
 String currentVersion)

Parameters:

method - HTTP, HTTP_CLEARNET, or HTTPS_CLEARNET

currentVersion - used for partial checks

Since:

0.9.9

Method Details

isRunning

public boolean isRunning()

Specified by:

isRunning in interface UpdateTask

shutdown

public void shutdown()

Specified by:

shutdown in interface UpdateTask

getType

public UpdateType getType()

Specified by:

getType in interface UpdateTask

getMethod

public UpdateMethod getMethod()

Specified by:

getMethod in interface UpdateTask

getURI

public URI getURI()

Description copied from interface: UpdateTask

The current URI being checked or downloaded from. Can change if there are multiple URIs to try.

Specified by:

getURI in interface UpdateTask

getID

public String getID()

Description copied from interface: UpdateTask

Valid for plugins

Specified by:

getID in interface UpdateTask

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class I2PThread

update

protected void update()

Loop through the entire list of update URLs. For each one, first get the version from the first 56 bytes and see if it is newer than what we are running now. If it is, get the whole thing.

attemptFailed

public void attemptFailed(String url,
 long bytesTransferred,
 long bytesRemaining,
 int currentAttempt,
 int numRetries,
 Exception cause)

Specified by:

attemptFailed in interface EepGet.StatusListener

See Also:

• EepGet.StatusListener.bytesTransferred(long, int, long, long, java.lang.String)

bytesTransferred

public void bytesTransferred(long alreadyTransferred,
 int currentWrite,
 long bytesTransferred,
 long bytesRemaining,
 String url)

subclasses should override

Specified by:

bytesTransferred in interface EepGet.StatusListener

Parameters:

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. If zero on a subsequent call after some bytes are transferred (and presumably after an attemptFailed), the server does _not_ support resume and we had to start over. To track _actual_ transfer if the output file could already exist, the listener should keep its own counter, or subtract the initial alreadyTransferred value. And watch out for alreadyTransferred resetting if a resume failed...

currentWrite - since last call to the listener

bytesTransferred - includes headers, retries, redirects, discarded partial downloads, ...

bytesRemaining - on this attempt only, currentWrite already subtracted - or -1 if chunked encoding or server does not return a length

transferComplete

public void transferComplete(long alreadyTransferred,
 long bytesTransferred,
 long bytesRemaining,
 String url,
 String outputFile,
 boolean notModified)

subclasses should override

Specified by:

transferComplete in interface EepGet.StatusListener

Parameters:

outputFile - null if unknown (output stream constructor)

See Also:

• EepGet.StatusListener.bytesTransferred(long, int, long, long, java.lang.String)

transferFailed

public void transferFailed(String url,
 long bytesTransferred,
 long bytesRemaining,
 int currentAttempt)

subclasses should override

Specified by:

transferFailed in interface EepGet.StatusListener

See Also:

• EepGet.StatusListener.bytesTransferred(long, int, long, long, java.lang.String)

headerReceived

public void headerReceived(String url,
 int attemptNum,
 String key,
 String val)

Description copied from interface: EepGet.StatusListener

Note: Headers are not processed, and this is not called, for most error response codes, unless setWriteErrorToOutput() is called before fetch(). To be changed?

Specified by:

headerReceived in interface EepGet.StatusListener

attempting

public void attempting(String url)

Specified by:

attempting in interface EepGet.StatusListener

updateStatus

protected void updateStatus(String s)

linkify

protected static String linkify(String url)

_t

protected String _t(String s)

translate a string

_t

protected String _t(String s,
 Object o)

translate a string with a parameter

toString

public String toString()

Overrides:

toString in class Thread