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

wait until client thread finishes before declaring victory

Browse Source
This commit is contained in:
zab2
2013-06-29 21:03:19 +00:00
parent 782e38bdcf
commit 740b37b70c
1 changed files with 4 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -27,11 +27,12 @@ public class EchoLargeTest extends StreamingTestBase {
_log.debug("creating server session"); _log.debug("creating server session");
_server = createSession(); _server = createSession();
_log.debug("running server"); _log.debug("running server");
runServer(context, _server); Thread server = runServer(context, _server);
_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); Thread client = runClient(context, _client);
client.join();
} }
@@ -144,14 +145,7 @@ public class EchoLargeTest extends StreamingTestBase {
break; break;
} }
} }
if (firstOff < 0) { assertTrue(firstOff < 0);
System.out.println("** Read match");
} else {
System.out.println("** Read does not match: first off = " + firstOff);
_log.error("read does not match (first off = " + firstOff + "): \n"
+ Base64.encode(orig) + "\n"
+ Base64.encode(rbuf));
}
} }
} }
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
@@ -160,7 +154,6 @@ public class EchoLargeTest extends StreamingTestBase {
_log.debug("socket closed"); _log.debug("socket closed");
Thread.sleep(5*1000); Thread.sleep(5*1000);
System.exit(0);
} catch (Exception e) { } catch (Exception e) {
_log.error("error running", e); _log.error("error running", e);
} }