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

wip

Browse Source
This commit is contained in:
zab2
2013-06-29 21:12:11 +00:00
parent 740b37b70c
commit 6e36d374ea
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectTest.java
View File

@@ -19,8 +19,8 @@ public class ConnectTest extends StreamingTestBase {
@Before
public void setUp() throws Exception {
System.setProperty(I2PClient.PROP_TCP_HOST, "localhost");
System.setProperty(I2PClient.PROP_TCP_PORT, "11001");
// System.setProperty(I2PClient.PROP_TCP_HOST, "localhost");
// System.setProperty(I2PClient.PROP_TCP_PORT, "11001");
}
@Test
@@ -30,11 +30,14 @@ public class ConnectTest extends StreamingTestBase {
_log.debug("creating server session");
_server = createSession();
_log.debug("running server");
runServer(context, _server);
Thread server = runServer(context, _server);
Thread [] clients = new Thread[5];
for (int i = 0; i < 5; i++) {
_log.debug("running client");
runClient(context, createSession());
clients[i] = runClient(context, createSession());
}
for (Thread c : clients)
c.join();
}
@@ -66,7 +69,7 @@ public class ConnectTest extends StreamingTestBase {
while (true) {
I2PSocket socket = ssocket.accept();
_log.debug("socket accepted: " + socket);
try { Thread.sleep(5*1000); } catch (InterruptedException ie) {}
Thread.sleep(5*1000);
socket.close();
}
} catch (Exception e) {
@@ -88,7 +91,7 @@ public class ConnectTest extends StreamingTestBase {
_log.debug("manager created");
I2PSocket socket = mgr.connect(_server.getMyDestination());
_log.debug("socket created");
try { Thread.sleep(5*1000); } catch (InterruptedException ie) {}
Thread.sleep(5*1000);
socket.close();
_log.debug("socket closed");
mgr.destroySocketManager();