summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/replica/replica2/ObjectPacket.java
diff options
context:
space:
mode:
authorSam Anthony <sam@samanthony.xyz>2024-11-28 17:32:28 -0500
committerSam Anthony <sam@samanthony.xyz>2024-11-28 17:32:28 -0500
commitd267dd1dda606f0c56d8afaa7187485e60ebfd86 (patch)
treee1bca5933aa7e5e9793773057fd5616ff65a9eb8 /src/main/java/derms/replica/replica2/ObjectPacket.java
parent6654546671eea9f9becd32b3160a134802659cbc (diff)
downloadsoen423-d267dd1dda606f0c56d8afaa7187485e60ebfd86.zip
move replica2 to top level
Diffstat (limited to 'src/main/java/derms/replica/replica2/ObjectPacket.java')
-rw-r--r--src/main/java/derms/replica/replica2/ObjectPacket.java33
1 files changed, 0 insertions, 33 deletions
diff --git a/src/main/java/derms/replica/replica2/ObjectPacket.java b/src/main/java/derms/replica/replica2/ObjectPacket.java
deleted file mode 100644
index bd711db..0000000
--- a/src/main/java/derms/replica/replica2/ObjectPacket.java
+++ /dev/null
@@ -1,33 +0,0 @@
-package derms.replica.replica2;
-
-import java.io.*;
-import java.net.DatagramPacket;
-import java.net.SocketAddress;
-
-class ObjectPacket {
- 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);
- }
-
- static <E> E deserialize(DatagramPacket pkt, Class<E> 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