Changeset 843230a for apps/streaming


Ignore:
Timestamp:
Apr 26, 2015 1:43:34 AM (5 years ago)
Author:
str4d <str4d@…>
Branches:
master
Children:
ef195aa
Parents:
84e63f3b
Message:

Fixed MessageInputStreamTest? after constructor changes

File:
1 edited

Legend:

Unmodified
Added
Removed
  • apps/streaming/java/test/junit/net/i2p/client/streaming/impl/MessageInputStreamTest.java

    r84e63f3b r843230a  
    2121    private I2PAppContext _context;
    2222    private Log _log;
     23    private ConnectionOptions _options;
    2324   
    2425    @Before
     
    2627        _context = I2PAppContext.getGlobalContext();
    2728        _log = _context.logManager().getLog(MessageInputStreamTest.class);
     29        _options = new ConnectionOptions();
    2830    }
    2931   
     
    3335        _context.random().nextBytes(orig);
    3436       
    35         MessageInputStream in = new MessageInputStream(_context);
     37        MessageInputStream in = new MessageInputStream(_context, _options.getMaxMessageSize(),
     38                                                       _options.getMaxWindowSize(), _options.getInboundBufferSize());
    3639        for (int i = 0; i < orig.length / 1024; i++) {
    3740            byte msg[] = new byte[1024];
     
    5962        _context.random().nextBytes(orig);
    6063       
    61         MessageInputStream in = new MessageInputStream(_context);
     64        MessageInputStream in = new MessageInputStream(_context, _options.getMaxMessageSize(),
     65                                                       _options.getMaxWindowSize(), _options.getInboundBufferSize());
    6266        ArrayList<Integer> order = new ArrayList<Integer>(32);
    6367        for (int i = 0; i < orig.length / 1024; i++)
     
    9195        _context.random().nextBytes(orig);
    9296       
    93         MessageInputStream in = new MessageInputStream(_context);
     97        MessageInputStream in = new MessageInputStream(_context, _options.getMaxMessageSize(),
     98                                                       _options.getMaxWindowSize(), _options.getInboundBufferSize());
    9499        for (int n = 0; n < 3; n++) {
    95100            ArrayList<Integer> order = new ArrayList<Integer>(32);
     
    126131        _context.random().nextBytes(orig);
    127132       
    128         MessageInputStream in = new MessageInputStream(_context);
     133        MessageInputStream in = new MessageInputStream(_context, _options.getMaxMessageSize(),
     134                                                       _options.getMaxWindowSize(), _options.getInboundBufferSize());
    129135        ArrayList<Integer> order = new ArrayList<Integer>(32);
    130136        for (int i = 0; i < orig.length / 1024; i++)
Note: See TracChangeset for help on using the changeset viewer.