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

hopefully fix streaming test

Browse Source
This commit is contained in:
zzz
2017-12-06 13:09:53 +00:00
parent a28ddedce7
commit 956c9607ff
1 changed files with 3 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
apps/streaming/java/test/junit/net/i2p/client/streaming/impl/MessageInputStreamTest.java
View File

@ -87,21 +87,11 @@ public class MessageInputStreamTest {
@Test
public void testCanAccept_locallyClosed() {
// Fill the buffer
int numMsgs = _options.getInboundBufferSize() / _options.getMaxMessageSize();
byte orig[] = new byte[_options.getInboundBufferSize()];
_context.random().nextBytes(orig);
for (int i = 0; i < numMsgs; i++) {
byte msg[] = new byte[_options.getMaxMessageSize()];
System.arraycopy(orig, i*_options.getMaxMessageSize(), msg, 0, _options.getMaxMessageSize());
in.messageReceived(i, new ByteArray(msg));
}
// Check that new messages won't be accepted
assertFalse(in.canAccept(numMsgs, 1));
// Close
in.close();
// Check that new messages will now be accepted
assertTrue(in.canAccept(numMsgs, 1));
assertTrue(in.isLocallyClosed());
// Check that new messages will not be accepted
assertFalse(in.canAccept(2, 1));
}
@Test