I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Commit 937404b3 authored by zab2's avatar zab2
Browse files

test seems to be hopelessly out of date

parent a0bf2230
No related branches found
No related tags found
No related merge requests found
...@@ -30,7 +30,7 @@ public class ConnectTimeoutTest extends StreamingTestBase { ...@@ -30,7 +30,7 @@ public class ConnectTimeoutTest extends StreamingTestBase {
_log.debug("creating client session"); _log.debug("creating client session");
_client = createSession(); _client = createSession();
_log.debug("running client"); _log.debug("running client");
runClient(context, _client); runClient(context, _client).join();
} }
protected Runnable getClient(I2PAppContext ctx, I2PSession session) { protected Runnable getClient(I2PAppContext ctx, I2PSession session) {
...@@ -43,22 +43,10 @@ public class ConnectTimeoutTest extends StreamingTestBase { ...@@ -43,22 +43,10 @@ public class ConnectTimeoutTest extends StreamingTestBase {
} }
public void run() { public void run() {
try { I2PSocketManager mgr = I2PSocketManagerFactory.createManager("localhost", 10001, getProperties());
I2PSocketManager mgr = I2PSocketManagerFactory.createManager("localhost", 10001, getProperties()); assertNull(mgr);
_log.debug("manager created");
_log.debug("options: " + mgr.getDefaultOptions());
I2PSocket socket = mgr.connect(_serverDest);
_log.debug("socket created");
socket.getOutputStream().write("you smell".getBytes());
socket.getOutputStream().flush();
_log.error("wtf, shouldn't have flushed");
socket.close();
_log.debug("socket closed");
} catch (Exception e) {
_log.error("error running (yay!)", e);
}
} }
} }
@Override @Override
...@@ -71,8 +59,6 @@ public class ConnectTimeoutTest extends StreamingTestBase { ...@@ -71,8 +59,6 @@ public class ConnectTimeoutTest extends StreamingTestBase {
Properties p = new Properties(); Properties p = new Properties();
p.setProperty(I2PSocketManagerFactory.PROP_MANAGER, I2PSocketManagerFull.class.getName()); p.setProperty(I2PSocketManagerFactory.PROP_MANAGER, I2PSocketManagerFull.class.getName());
p.setProperty("tunnels.depthInbound", "0"); p.setProperty("tunnels.depthInbound", "0");
p.setProperty(I2PClient.PROP_TCP_HOST, "localhost");
p.setProperty(I2PClient.PROP_TCP_PORT, "10001");
p.setProperty(ConnectionOptions.PROP_CONNECT_TIMEOUT, "30000"); p.setProperty(ConnectionOptions.PROP_CONNECT_TIMEOUT, "30000");
//p.setProperty(ConnectionOptions.PROP_CONNECT_DELAY, "10000"); //p.setProperty(ConnectionOptions.PROP_CONNECT_DELAY, "10000");
p.setProperty(ConnectionOptions.PROP_CONNECT_DELAY, "0"); p.setProperty(ConnectionOptions.PROP_CONNECT_DELAY, "0");
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment