Changeset db9555d for apps/streaming

Timestamp:

Jul 27, 2015 6:49:07 AM (5 years ago)

Author:

str4d <str4d@…>

Branches:

master

Children:

e704bad

Parents:

4b34b49

Message:

Fix test

File:

• apps/streaming/java/test/junit/net/i2p/client/streaming/impl/MessageInputStreamTest.java (modified) (1 diff)

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

@@ -182 +182 @@
         byte orig[] = new byte[_options.getInboundBufferSize()];
         _context.random().nextBytes(orig);
-        for (int i = 0; i < numMsgs - 1; i++) {
-            byte msg[] = new byte[_options.getMaxMessageSize()];
-            System.arraycopy(orig, i*_options.getMaxMessageSize(), msg, 0, _options.getMaxMessageSize());
-            in.messageReceived(i, new ByteArray(msg));
-        }
-        // Add one half-size msg
+        for (int i = 0; i < numMsgs - 2; i++) {
+            byte msg[] = new byte[_options.getMaxMessageSize()];
+            System.arraycopy(orig, i*_options.getMaxMessageSize(), msg, 0, _options.getMaxMessageSize());
+            in.messageReceived(i, new ByteArray(msg));
+        }
+        // Add two half-size messages (to get past shortcut)
         byte msg[] = new byte[_options.getMaxMessageSize()/2];
         System.arraycopy(orig, (numMsgs-1)*_options.getMaxMessageSize(), msg, 0, _options.getMaxMessageSize()/2);
+        in.messageReceived(numMsgs - 2, new ByteArray(msg));
         in.messageReceived(numMsgs - 1, new ByteArray(msg));
         // Check that it predicts only one more msgId will be accepted