Changeset 67f73d7


Ignore:
Timestamp:
Jun 29, 2013 9:22:28 PM (7 years ago)
Author:
zab2 <zab2@…>
Branches:
master
Children:
d173b79
Parents:
6e36d37
Message:

wip

File:
1 edited

Legend:

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

    r6e36d37 r67f73d7  
    1515 */
    1616public class ConnectInactivityTest extends StreamingTestBase {
     17    private static final long LONG_TIME = 60 * 1000;
     18   
     19    private static void sleep() throws Exception {
     20        Thread.sleep(LONG_TIME);
     21    }
     22   
    1723    private Log _log;
    1824    private I2PSession _client;
     
    2935        _log.debug("creating client session");
    3036        _client = createSession();
     37       
    3138        _log.debug("running client");
    32         runClient(context, _client);
     39        Thread client = runClient(context, _client);
     40        client.join(LONG_TIME + 1000);
    3341    }
    3442   
     
    5664                _log.debug("server socket created");
    5765                I2PSocket socket = ssocket.accept();
     66                sleep();
    5867                _log.debug("socket accepted: " + socket);
    59                 try { Thread.sleep(10*60*1000); } catch (InterruptedException ie) {}
    6068                socket.close();
    6169                ssocket.close();
    6270                _session.destroySession();
    6371            } catch (Exception e) {
     72                fail(e.getMessage());
    6473                _log.error("error running", e);
    6574            }
     
    8089                I2PSocket socket = mgr.connect(_server.getMyDestination());
    8190                _log.debug("socket created");
    82                 Thread.sleep(10*60*1000);
     91                sleep();
    8392                socket.close();
    8493                _log.debug("socket closed");
    8594                //_session.destroySession();
    8695            } catch (Exception e) {
     96                fail(e.getMessage());
    8797                _log.error("error running", e);
    8898            }
     
    94104    protected Properties getProperties() {
    95105        Properties p = new Properties();
    96         p.setProperty(I2PClient.PROP_TCP_HOST, "localhost");
    97         p.setProperty(I2PClient.PROP_TCP_PORT, "10001");
     106//        p.setProperty(I2PClient.PROP_TCP_HOST, "localhost");
     107//        p.setProperty(I2PClient.PROP_TCP_PORT, "10001");
    98108        return p;
    99109    }
Note: See TracChangeset for help on using the changeset viewer.