diff options
Diffstat (limited to 'libraries/spongycastle/core/src/test/java/org/spongycastle/crypto/tls/test/DTLSProtocolTest.java')
-rw-r--r-- | libraries/spongycastle/core/src/test/java/org/spongycastle/crypto/tls/test/DTLSProtocolTest.java | 104 |
1 files changed, 0 insertions, 104 deletions
diff --git a/libraries/spongycastle/core/src/test/java/org/spongycastle/crypto/tls/test/DTLSProtocolTest.java b/libraries/spongycastle/core/src/test/java/org/spongycastle/crypto/tls/test/DTLSProtocolTest.java deleted file mode 100644 index 1d30ede85..000000000 --- a/libraries/spongycastle/core/src/test/java/org/spongycastle/crypto/tls/test/DTLSProtocolTest.java +++ /dev/null @@ -1,104 +0,0 @@ -package org.spongycastle.crypto.tls.test; - -import java.security.SecureRandom; - -import junit.framework.TestCase; - -import org.spongycastle.crypto.tls.DTLSClientProtocol; -import org.spongycastle.crypto.tls.DTLSServerProtocol; -import org.spongycastle.crypto.tls.DTLSTransport; -import org.spongycastle.crypto.tls.DatagramTransport; -import org.spongycastle.crypto.tls.ProtocolVersion; -import org.spongycastle.util.Arrays; - -public class DTLSProtocolTest - extends TestCase -{ - public void testClientServer() - throws Exception - { - SecureRandom secureRandom = new SecureRandom(); - - DTLSClientProtocol clientProtocol = new DTLSClientProtocol(secureRandom); - DTLSServerProtocol serverProtocol = new DTLSServerProtocol(secureRandom); - - MockDatagramAssociation network = new MockDatagramAssociation(1500); - - ServerThread serverThread = new ServerThread(serverProtocol, network.getServer()); - serverThread.start(); - - DatagramTransport clientTransport = network.getClient(); - - clientTransport = new UnreliableDatagramTransport(clientTransport, secureRandom, 0, 0); - - clientTransport = new LoggingDatagramTransport(clientTransport, System.out); - - MockDTLSClient client = new MockDTLSClient(null); - - DTLSTransport dtlsClient = clientProtocol.connect(client, clientTransport); - - for (int i = 1; i <= 10; ++i) - { - byte[] data = new byte[i]; - Arrays.fill(data, (byte)i); - dtlsClient.send(data, 0, data.length); - } - - byte[] buf = new byte[dtlsClient.getReceiveLimit()]; - while (dtlsClient.receive(buf, 0, buf.length, 1000) >= 0) - { - ; - } - - dtlsClient.close(); - - serverThread.shutdown(); - } - - static class ServerThread - extends Thread - { - private final DTLSServerProtocol serverProtocol; - private final DatagramTransport serverTransport; - private volatile boolean isShutdown = false; - - ServerThread(DTLSServerProtocol serverProtocol, DatagramTransport serverTransport) - { - this.serverProtocol = serverProtocol; - this.serverTransport = serverTransport; - } - - public void run() - { - try - { - MockDTLSServer server = new MockDTLSServer(); - DTLSTransport dtlsServer = serverProtocol.accept(server, serverTransport); - byte[] buf = new byte[dtlsServer.getReceiveLimit()]; - while (!isShutdown) - { - int length = dtlsServer.receive(buf, 0, buf.length, 1000); - if (length >= 0) - { - dtlsServer.send(buf, 0, length); - } - } - dtlsServer.close(); - } - catch (Exception e) - { - e.printStackTrace(); - } - } - - void shutdown() - throws InterruptedException - { - if (!isShutdown) - { - isShutdown = true; - this.join(); - } - } - } -} |