Changeset bddfe3ed


Ignore:
Timestamp:
Jun 28, 2013 4:00:47 PM (7 years ago)
Author:
zab2 <zab2@…>
Branches:
master
Children:
79f8e88, a9d9e6b
Parents:
a308179
Message:

Convert most streaming tests to JUnit4

Location:
apps/streaming/java/test/junit/net/i2p/client/streaming
Files:
7 edited

Legend:

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

    ra308179 rbddfe3ed  
    55import java.io.InputStream;
    66import java.util.Properties;
     7
     8import org.junit.Test;
     9
     10import junit.framework.TestCase;
    711
    812import net.i2p.I2PAppContext;
     
    1923 *
    2024 */
    21 public class ConnectCloseTest {
     25public class ConnectCloseTest extends TestCase {
    2226    private Log _log;
    2327    private I2PSession _server;
    24     public void test() {
    25         try {
    26             I2PAppContext context = I2PAppContext.getGlobalContext();
    27             _log = context.logManager().getLog(ConnectCloseTest.class);
    28             _log.debug("creating server session");
    29             _server = createSession();
    30             _log.debug("running server");
    31             runServer(context, _server);
    32             _log.debug("running client");
    33             runClient(context, createSession());
    34         } catch (Exception e) {
    35             _log.error("error running", e);
    36         }
    37         try { Thread.sleep(10*60*1000); } catch (Exception e) {}
     28   
     29    @Test
     30    public void test() throws Exception {
     31        I2PAppContext context = I2PAppContext.getGlobalContext();
     32        _log = context.logManager().getLog(ConnectCloseTest.class);
     33        _log.debug("creating server session");
     34        _server = createSession();
     35        _log.debug("running server");
     36        runServer(context, _server);
     37        _log.debug("running client");
     38        runClient(context, createSession());
    3839    }
    3940   
     
    131132        }
    132133    }
    133    
    134     public static void main(String args[]) {
    135         ConnectCloseTest ct = new ConnectCloseTest();
    136         ct.test();
    137     }
    138134}
  • apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectInactivityTest.java

    ra308179 rbddfe3ed  
    44import java.io.ByteArrayOutputStream;
    55import java.util.Properties;
     6
     7import org.junit.Test;
     8
     9import junit.framework.TestCase;
    610
    711import net.i2p.I2PAppContext;
     
    1519 *
    1620 */
    17 public class ConnectInactivityTest {
     21public class ConnectInactivityTest extends TestCase{
    1822    private Log _log;
    1923    private I2PSession _client;
    2024    private I2PSession _server;
    21     public void test() {
    22         try {
    23             I2PAppContext context = I2PAppContext.getGlobalContext();
    24             _log = context.logManager().getLog(ConnectTest.class);
    25             _log.debug("creating server session");
    26             _server = createSession();
    27             _log.debug("running server");
    28             runServer(context, _server);
    29             _log.debug("creating client session");
    30             _client = createSession();
    31             _log.debug("running client");
    32             runClient(context, _client);
    33         } catch (Exception e) {
    34             _log.error("error running", e);
    35         }
     25   
     26    @Test
     27    public void test() throws Exception {
     28        I2PAppContext context = I2PAppContext.getGlobalContext();
     29        _log = context.logManager().getLog(ConnectTest.class);
     30        _log.debug("creating server session");
     31        _server = createSession();
     32        _log.debug("running server");
     33        runServer(context, _server);
     34        _log.debug("creating client session");
     35        _client = createSession();
     36        _log.debug("running client");
     37        runClient(context, _client);
    3638    }
    3739   
     
    124126        }
    125127    }
    126    
    127     public static void main(String args[]) {
    128         ConnectInactivityTest ct = new ConnectInactivityTest();
    129         ct.test();
    130     }
    131128}
  • apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectTest.java

    ra308179 rbddfe3ed  
    44import java.io.ByteArrayOutputStream;
    55import java.util.Properties;
     6
     7import org.junit.Before;
     8import org.junit.Test;
     9
     10import junit.framework.TestCase;
    611
    712import net.i2p.I2PAppContext;
     
    1520 *
    1621 */
    17 public class ConnectTest {
     22public class ConnectTest  extends TestCase {
    1823    private Log _log;
    1924    private I2PSession _server;
    20     public void test() {
    21         try {
    22             I2PAppContext context = I2PAppContext.getGlobalContext();
    23             _log = context.logManager().getLog(ConnectTest.class);
    24             _log.debug("creating server session");
    25             _server = createSession();
    26             _log.debug("running server");
    27             runServer(context, _server);
    28             for (int i = 0; i < 5; i++) {
    29                 _log.debug("running client");
    30                 runClient(context, createSession());
    31             }
    32         } catch (Exception e) {
    33             _log.error("error running", e);
     25   
     26    @Before
     27    public void setUp() throws Exception {
     28        System.setProperty(I2PClient.PROP_TCP_HOST, "localhost");
     29        System.setProperty(I2PClient.PROP_TCP_PORT, "11001"); 
     30    }
     31   
     32    @Test
     33    public void test() throws Exception {
     34        I2PAppContext context = I2PAppContext.getGlobalContext();
     35        _log = context.logManager().getLog(ConnectTest.class);
     36        _log.debug("creating server session");
     37        _server = createSession();
     38        _log.debug("running server");
     39        runServer(context, _server);
     40        for (int i = 0; i < 5; i++) {
     41            _log.debug("running client");
     42            runClient(context, createSession());
    3443        }
    35         try { Thread.sleep(10*60*1000); } catch (Exception e) {}
    3644    }
    3745   
     
    123131        }
    124132    }
    125    
    126     public static void main(String args[]) {
    127         System.setProperty(I2PClient.PROP_TCP_HOST, "localhost");
    128         System.setProperty(I2PClient.PROP_TCP_PORT, "11001");       
    129         ConnectTest ct = new ConnectTest();
    130         ct.test();
    131     }
    132133}
  • apps/streaming/java/test/junit/net/i2p/client/streaming/ConnectTimeoutTest.java

    ra308179 rbddfe3ed  
    44import java.io.ByteArrayOutputStream;
    55import java.util.Properties;
     6
     7import org.junit.Test;
     8
     9import junit.framework.TestCase;
    610
    711import net.i2p.I2PAppContext;
     
    1620 * timeout.
    1721 */
    18 public class ConnectTimeoutTest {
     22public class ConnectTimeoutTest  extends TestCase {
    1923    private Log _log;
    2024    private I2PSession _client;
     
    2226    private Destination _serverDest;
    2327   
    24     public void testNonexistant() {
     28    @Test
     29    public void testNonexistant() throws Exception {
     30        I2PAppContext context = I2PAppContext.getGlobalContext();
     31        _log = context.logManager().getLog(ConnectTest.class);
     32        _log.debug("creating server dest");
    2533        try {
    26             I2PAppContext context = I2PAppContext.getGlobalContext();
    27             _log = context.logManager().getLog(ConnectTest.class);
    28             _log.debug("creating server dest");
    29             try {
    30                 _serverDest = I2PClientFactory.createClient().createDestination(new ByteArrayOutputStream());
    31             } catch (Exception e) {}
    32             _log.debug("creating client session");
    33             _client = createSession();
    34             _log.debug("running client");
    35             runClient(context, _client);
    36         } catch (Exception e) {
    37             _log.error("error running", e);
    38         }
    39         while (true) { synchronized (this) { try { wait(); } catch (Exception e) {} } }
     34            _serverDest = I2PClientFactory.createClient().createDestination(new ByteArrayOutputStream());
     35        } catch (Exception e) {}
     36        _log.debug("creating client session");
     37        _client = createSession();
     38        _log.debug("running client");
     39        runClient(context, _client);
    4040    }
    4141   
     
    9292    }
    9393   
    94     public static void main(String args[]) {
    95         ConnectTimeoutTest ct = new ConnectTimeoutTest();
    96         ct.testNonexistant();
    97     }
    98    
    9994    private static Properties getProps() {
    10095        Properties p = new Properties();
  • apps/streaming/java/test/junit/net/i2p/client/streaming/EchoLargeTest.java

    ra308179 rbddfe3ed  
    66import java.io.OutputStream;
    77import java.util.Properties;
     8
     9import org.junit.Test;
     10
     11import junit.framework.TestCase;
    812
    913import net.i2p.I2PAppContext;
     
    1822 *
    1923 */
    20 public class EchoLargeTest {
     24public class EchoLargeTest extends TestCase {
    2125    private Log _log;
    2226    private I2PSession _client;
    2327    private I2PSession _server;
    2428   
    25     public void test() {
    26         try {
    27             I2PAppContext context = I2PAppContext.getGlobalContext();
    28             _log = context.logManager().getLog(ConnectTest.class);
    29             _log.debug("creating server session");
    30             _server = createSession();
    31             _log.debug("running server");
    32             runServer(context, _server);
    33             _log.debug("creating client session");
    34             _client = createSession();
    35             _log.debug("running client");
    36             runClient(context, _client);
    37         } catch (Exception e) {
    38             _log.error("error running", e);
    39         }
    40         try { Thread.sleep(300*1000); } catch (Exception e) {}
     29    @Test
     30    public void test() throws Exception {
     31        I2PAppContext context = I2PAppContext.getGlobalContext();
     32        _log = context.logManager().getLog(ConnectTest.class);
     33        _log.debug("creating server session");
     34        _server = createSession();
     35        _log.debug("running server");
     36        runServer(context, _server);
     37        _log.debug("creating client session");
     38        _client = createSession();
     39        _log.debug("running client");
     40        runClient(context, _client);
    4141    }
    4242   
     
    193193        }
    194194    }
    195    
    196     public static void main(String args[]) {
    197         EchoLargeTest et = new EchoLargeTest();
    198         et.test();
    199     }
    200195}
  • apps/streaming/java/test/junit/net/i2p/client/streaming/EchoTest.java

    ra308179 rbddfe3ed  
    66import java.io.OutputStream;
    77import java.util.Properties;
     8
     9import org.junit.Test;
     10
     11import junit.framework.TestCase;
    812
    913import net.i2p.I2PAppContext;
     
    1721 *
    1822 */
    19 public class EchoTest {
     23public class EchoTest extends TestCase {
    2024    private Log _log;
    2125    private I2PSession _client;
    2226    private I2PSession _server;
    23     public void test() {
    24         try {
    25             I2PAppContext context = I2PAppContext.getGlobalContext();
    26             _log = context.logManager().getLog(ConnectTest.class);
    27             _log.debug("creating server session");
    28             _server = createSession();
    29             _log.debug("running server");
    30             runServer(context, _server);
    31             _log.debug("creating client session");
    32             _client = createSession();
    33             _log.debug("running client");
    34             runClient(context, _client);
    35         } catch (Exception e) {
    36             _log.error("error running", e);
    37         }
    38         try { Thread.sleep(300*1000); } catch (Exception e) {}
     27   
     28    @Test
     29    public void test() throws Exception {
     30        I2PAppContext context = I2PAppContext.getGlobalContext();
     31        _log = context.logManager().getLog(ConnectTest.class);
     32        _log.debug("creating server session");
     33        _server = createSession();
     34        _log.debug("running server");
     35        runServer(context, _server);
     36        _log.debug("creating client session");
     37        _client = createSession();
     38        _log.debug("running client");
     39        runClient(context, _client);
    3940    }
    4041   
     
    171172        }
    172173    }
    173    
    174     public static void main(String args[]) {
    175         EchoTest et = new EchoTest();
    176         et.test();
    177     }
    178174}
  • apps/streaming/java/test/junit/net/i2p/client/streaming/MessageInputStreamTest.java

    ra308179 rbddfe3ed  
    44import java.util.ArrayList;
    55import java.util.Collections;
     6
     7import org.junit.Before;
     8import org.junit.Test;
     9
     10import junit.framework.TestCase;
    611
    712import net.i2p.I2PAppContext;
     
    1318 * Stress test the MessageInputStream
    1419 */
    15 public class MessageInputStreamTest {
     20public class MessageInputStreamTest extends TestCase {
    1621    private I2PAppContext _context;
    1722    private Log _log;
    1823   
    19     public MessageInputStreamTest() {
     24    @Before
     25    public void setUp() {
    2026        _context = I2PAppContext.getGlobalContext();
    2127        _log = _context.logManager().getLog(MessageInputStreamTest.class);
    2228    }
    2329   
     30    @Test
    2431    public void testInOrder() {
    2532        byte orig[] = new byte[256*1024];
     
    4754    }
    4855   
     56    @Test
    4957    public void testRandomOrder() {
    5058        byte orig[] = new byte[256*1024];
     
    7886    }
    7987   
     88    @Test
    8089    public void testRandomDups() {
    8190        byte orig[] = new byte[256*1024];
     
    111120    }
    112121   
     122    @Test
    113123    public void testStaggered() {
    114124        byte orig[] = new byte[256*1024];
     
    149159        _log.info("Passed test: staggered");
    150160    }
    151    
    152     public static void main(String args[]) {
    153         MessageInputStreamTest t = new MessageInputStreamTest();
    154         try {
    155             t.testInOrder();
    156             t.testRandomOrder();
    157             t.testRandomDups();
    158             t.testStaggered();
    159         } catch (Exception e) {
    160             e.printStackTrace();
    161         }
    162         try { Thread.sleep(10*1000); } catch (InterruptedException ie) {}
    163     }
    164161}
Note: See TracChangeset for help on using the changeset viewer.