From 6a710c3943f2350f4575f8cb1898129ef3c7dfdd Mon Sep 17 00:00:00 2001 From: Sam Anthony Date: Thu, 28 Nov 2024 10:42:31 -0500 Subject: rename assignment code replica package --- .../java/derms/replica/replica1/ObjectPacket.java | 33 ---------------------- 1 file changed, 33 deletions(-) delete mode 100644 src/main/java/derms/replica/replica1/ObjectPacket.java (limited to 'src/main/java/derms/replica/replica1/ObjectPacket.java') diff --git a/src/main/java/derms/replica/replica1/ObjectPacket.java b/src/main/java/derms/replica/replica1/ObjectPacket.java deleted file mode 100644 index 9d7de45..0000000 --- a/src/main/java/derms/replica/replica1/ObjectPacket.java +++ /dev/null @@ -1,33 +0,0 @@ -package derms.replica.replica1; - -import java.io.*; -import java.net.DatagramPacket; -import java.net.SocketAddress; - -public class ObjectPacket { - public static DatagramPacket create(Serializable obj, SocketAddress remoteAddr) throws IOException { - ByteArrayOutputStream byteStream = new ByteArrayOutputStream(); - ObjectOutputStream objStream = new ObjectOutputStream(byteStream); - objStream.writeObject(obj); - objStream.flush(); - byte[] buf = byteStream.toByteArray(); - objStream.close(); - return new DatagramPacket(buf, buf.length, remoteAddr); - } - - public static E deserialize(DatagramPacket pkt, Class clazz) throws IOException { - ObjectInputStream objectStream; - try { - objectStream = new ObjectInputStream( - new ByteArrayInputStream(pkt.getData())); - } catch (Exception e) { - throw new IOException("failed to create input stream: "+e.getMessage()); - } - - try { - return clazz.cast(objectStream.readObject()); - } catch (Exception e) { - throw new IOException(e.getMessage()); - } - } -} \ No newline at end of file -- cgit v1.2.3