Changeset 6e36d37


Ignore:
Timestamp:
Jun 29, 2013 9:12:11 PM (7 years ago)
Author:
zab2 <zab2@…>
Branches:
master
Children:
67f73d7
Parents:
740b37b7
Message:

wip

File:
1 edited

Legend:

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

    r740b37b7 r6e36d37  
    2020    @Before
    2121    public void setUp() throws Exception {
    22         System.setProperty(I2PClient.PROP_TCP_HOST, "localhost");
    23         System.setProperty(I2PClient.PROP_TCP_PORT, "11001"); 
     22//        System.setProperty(I2PClient.PROP_TCP_HOST, "localhost");
     23//        System.setProperty(I2PClient.PROP_TCP_PORT, "11001"); 
    2424    }
    2525   
     
    3131        _server = createSession();
    3232        _log.debug("running server");
    33         runServer(context, _server);
     33        Thread server = runServer(context, _server);
     34        Thread [] clients = new Thread[5];
    3435        for (int i = 0; i < 5; i++) {
    3536            _log.debug("running client");
    36             runClient(context, createSession());
     37            clients[i] = runClient(context, createSession());
    3738        }
     39        for (Thread c : clients)
     40            c.join();
    3841    }
    3942   
     
    6770                    I2PSocket socket = ssocket.accept();
    6871                    _log.debug("socket accepted: " + socket);
    69                     try { Thread.sleep(5*1000); } catch (InterruptedException ie) {}
     72                    Thread.sleep(5*1000);
    7073                    socket.close();
    7174                }
     
    8992                I2PSocket socket = mgr.connect(_server.getMyDestination());
    9093                _log.debug("socket created");
    91                 try { Thread.sleep(5*1000); } catch (InterruptedException ie) {}
     94                Thread.sleep(5*1000);
    9295                socket.close();
    9396                _log.debug("socket closed");
Note: See TracChangeset for help on using the changeset viewer.