lbt/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

allow overriding the I2CP port/host

Browse Source
This commit is contained in:
jrandom
2004-05-02 07:49:22 +00:00
committed by zzz
parent 2231abd407
commit 7912050647
1 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
apps/sam/java/src/net/i2p/sam/SAMStreamSession.java
View File

@@ -26,6 +26,7 @@ import net.i2p.client.streaming.I2PSocket;
import net.i2p.client.streaming.I2PSocketManager; import net.i2p.client.streaming.I2PSocketManager;
import net.i2p.client.streaming.I2PSocketManagerFactory; import net.i2p.client.streaming.I2PSocketManagerFactory;
import net.i2p.client.streaming.I2PSocketOptions; import net.i2p.client.streaming.I2PSocketOptions;
import net.i2p.client.I2PClient;
import net.i2p.data.Base64; import net.i2p.data.Base64;
import net.i2p.data.DataFormatException; import net.i2p.data.DataFormatException;
import net.i2p.data.Destination; import net.i2p.data.Destination;
@@ -101,10 +102,22 @@ public class SAMStreamSession {
allprops.putAll(props); allprops.putAll(props);
// FIXME: we should setup I2CP host and port, too // FIXME: we should setup I2CP host and port, too
String i2cpHost = allprops.getProperty(I2PClient.PROP_TCP_HOST, "127.0.0.1");
int i2cpPort = 7654;
String port = allprops.getProperty(I2PClient.PROP_TCP_PORT, "7654");
try {
i2cpPort = Integer.parseInt(port);
} catch (NumberFormatException nfe) {
throw new SAMException("Invalid I2CP port specified [" + port + "]");
}
// streams MUST be mode=guaranteed (though i think the socket manager
// enforces this anyway...
allprops.setProperty(I2PClient.PROP_RELIABILITY, I2PClient.PROP_RELIABILITY_GUARANTEED);
_log.debug("Creating I2PSocketManager..."); _log.debug("Creating I2PSocketManager...");
socketMgr = I2PSocketManagerFactory.createManager(destStream, socketMgr = I2PSocketManagerFactory.createManager(destStream,
"127.0.0.1", i2cpHost,
7654, allprops); i2cpPort,
allprops);
if (socketMgr == null) { if (socketMgr == null) {
throw new SAMException("Error creating I2PSocketManager"); throw new SAMException("Error creating I2PSocketManager");
} }