From d267dd1dda606f0c56d8afaa7187485e60ebfd86 Mon Sep 17 00:00:00 2001 From: Sam Anthony Date: Thu, 28 Nov 2024 17:32:28 -0500 Subject: move replica2 to top level --- .../derms/replica/replica2/ResourceTransfer.java | 50 ---------------------- 1 file changed, 50 deletions(-) delete mode 100644 src/main/java/derms/replica/replica2/ResourceTransfer.java (limited to 'src/main/java/derms/replica/replica2/ResourceTransfer.java') diff --git a/src/main/java/derms/replica/replica2/ResourceTransfer.java b/src/main/java/derms/replica/replica2/ResourceTransfer.java deleted file mode 100644 index bb3a907..0000000 --- a/src/main/java/derms/replica/replica2/ResourceTransfer.java +++ /dev/null @@ -1,50 +0,0 @@ -package derms.replica.replica2; - -import java.io.IOException; -import java.io.Serializable; -import java.net.DatagramPacket; -import java.net.DatagramSocket; -import java.net.SocketAddress; -import java.util.ArrayList; -import java.util.List; - -class ResourceTransfer { - static final int bufsize = 1024; - - static void send(Resource[] resources, SocketAddress remoteAddr) throws IOException { - DatagramSocket sock = new DatagramSocket(); - - for (Resource resource : resources) { - DatagramPacket pkt = ObjectPacket.create(resource, remoteAddr); - sock.send(pkt); - } - - DatagramPacket pkt = ObjectPacket.create(new EndOfTransmission(), remoteAddr); - sock.send(pkt); - sock.close(); - } - - static Resource[] receive(DatagramSocket sock) throws IOException { - List resources = new ArrayList(); - byte[] buf = new byte[bufsize]; - DatagramPacket response = new DatagramPacket(buf, buf.length); - - for (;;) { - sock.receive(response); - - Object obj = ObjectPacket.deserialize(response, Object.class); - if (obj.getClass() == EndOfTransmission.class) { - break; - } - try { - resources.add((Resource) obj); - } catch (Exception e) { - throw new IOException("expected Resource; got "+obj.getClass().toString()); - } - } - Resource[] arr = new Resource[0]; - return resources.toArray(arr); - } - - private static class EndOfTransmission implements Serializable {} -} \ No newline at end of file -- cgit v1.2.3