This commit is contained in:
zzz
2015-06-17 23:46:11 +00:00
parent 7c5dfaee20
commit 0f4e09500c
6 changed files with 11 additions and 2 deletions

View File

@@ -33,6 +33,9 @@ public class I2PTunnelHTTPClientRunner extends I2PTunnelRunner {
super(s, i2ps, slock, initialI2PData, null, sockList, onFail); super(s, i2ps, slock, initialI2PData, null, sockList, onFail);
} }
/**
* Only call once!
*/
@Override @Override
protected OutputStream getSocketOut() throws IOException { protected OutputStream getSocketOut() throws IOException {
OutputStream raw = super.getSocketOut(); OutputStream raw = super.getSocketOut();

View File

@@ -21,6 +21,7 @@ import net.i2p.util.Log;
* Also called when opting out of ff to call off the hounds ASAP. * Also called when opting out of ff to call off the hounds ASAP.
* Currently floods FNDF.MAX_TO_FLOOD * 2 routers nearest to us. * Currently floods FNDF.MAX_TO_FLOOD * 2 routers nearest to us.
* *
* @since 0.9.21
*/ */
class FloodfillRouterInfoFloodJob extends JobImpl { class FloodfillRouterInfoFloodJob extends JobImpl {
private final Log _log; private final Log _log;

View File

@@ -20,6 +20,8 @@ import net.i2p.util.Log;
/** /**
* This extends StoreJob to fire off a FloodfillVerifyStoreJob after success. * This extends StoreJob to fire off a FloodfillVerifyStoreJob after success.
* *
* Stores through this class always request a reply.
*
*/ */
class FloodfillStoreJob extends StoreJob { class FloodfillStoreJob extends StoreJob {
private final FloodfillNetworkDatabaseFacade _facade; private final FloodfillNetworkDatabaseFacade _facade;

View File

@@ -33,6 +33,8 @@ import net.i2p.util.Log;
import net.i2p.util.VersionComparator; import net.i2p.util.VersionComparator;
/** /**
* Stores through this always request a reply.
*
* Unused directly - see FloodfillStoreJob * Unused directly - see FloodfillStoreJob
*/ */
class StoreJob extends JobImpl { class StoreJob extends JobImpl {

View File

@@ -193,7 +193,8 @@ class PeerManager {
} }
/** /**
* Find some peers that meet the criteria and we have the netDb info for locally * Find some peers that meet the criteria and we have the netDb info for locally.
* Returned list will not include ourselves.
* *
* Only used by PeerTestJob (PURPOSE_TEST) * Only used by PeerTestJob (PURPOSE_TEST)
*/ */

View File

@@ -24,7 +24,7 @@ class ExploratoryPeerSelector extends TunnelPeerSelector {
super(context); super(context);
} }
public List<Hash> selectPeers(TunnelPoolSettings settings) { public List<Hash> selectPeers(TunnelPoolSettings settings) {
Log l = ctx.logManager().getLog(getClass()); Log l = ctx.logManager().getLog(getClass());
int length = getLength(settings); int length = getLength(settings);
if (length < 0) { if (length < 0) {