diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-11-23 13:22:07 -0500 |
|---|---|---|
| committer | Sam Anthony <sam@samanthony.xyz> | 2024-11-23 13:22:07 -0500 |
| commit | e3b72053e8b04f2df013da0d7d49fe33927461a9 (patch) | |
| tree | cdefb9adc63971655ad0bae7d799e28db46dc441 /src/test/java/derms/net/runicast | |
| parent | 1272127b76fa70739adac269698018bc12a3d696 (diff) | |
| download | soen423-e3b72053e8b04f2df013da0d7d49fe33927461a9.zip | |
very basic tests
Diffstat (limited to 'src/test/java/derms/net/runicast')
| -rw-r--r-- | src/test/java/derms/net/runicast/ReliableUnicastTest.java | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/src/test/java/derms/net/runicast/ReliableUnicastTest.java b/src/test/java/derms/net/runicast/ReliableUnicastTest.java new file mode 100644 index 0000000..0a66315 --- /dev/null +++ b/src/test/java/derms/net/runicast/ReliableUnicastTest.java @@ -0,0 +1,45 @@ +package derms.net.runicast; + +import derms.net.StringMessage; +import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Test; + +import java.io.IOException; +import java.net.InetAddress; +import java.net.InetSocketAddress; +import java.net.UnknownHostException; + +import static org.junit.jupiter.api.Assertions.assertEquals; + +public class ReliableUnicastTest { + static final int port = 12345; + + static InetAddress laddr; + + @BeforeAll + static void setup() throws UnknownHostException { + laddr = InetAddress.getLocalHost(); + } + + @Test + void openClose() throws IOException, InterruptedException { + ReliableUnicastSender<StringMessage> sender = new ReliableUnicastSender<StringMessage>(new InetSocketAddress(laddr, port)); + ReliableUnicastReceiver<StringMessage> receiver = new ReliableUnicastReceiver<StringMessage>(new InetSocketAddress(laddr, port)); + sender.close(); + receiver.close(); + } + + @Test + void sendRecv() throws IOException, InterruptedException { + ReliableUnicastSender<StringMessage> sender = new ReliableUnicastSender<StringMessage>(new InetSocketAddress(laddr, port)); + ReliableUnicastReceiver<StringMessage> receiver = new ReliableUnicastReceiver<StringMessage>(new InetSocketAddress(laddr, port)); + + StringMessage want = new StringMessage("foo"); + sender.send(want); + StringMessage got = receiver.receive(); + assertEquals(want, got); + + sender.close(); + receiver.close(); + } +} |