From 937751bb700c215680596e3629b4aacd1c4b2022 Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Sat, 23 Nov 2024 11:49:19 -0500
Subject: runicast: reuse buffer between receive()'s

---
 src/main/java/derms/net/runicast/Receive.java     | 3 ++-
 src/main/java/derms/net/runicast/ReceiveAcks.java | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

(limited to 'src/main/java/derms/net/runicast')

diff --git a/src/main/java/derms/net/runicast/Receive.java b/src/main/java/derms/net/runicast/Receive.java
index 8620ebd..88008bd 100644
--- a/src/main/java/derms/net/runicast/Receive.java
+++ b/src/main/java/derms/net/runicast/Receive.java
@@ -28,8 +28,9 @@ class Receive<T extends MessagePayload> implements Runnable {
 
     @Override
     public void run() {
+        ByteBuffer buf = ByteBuffer.allocate(bufSize);
         for (;;) {
-            ByteBuffer buf = ByteBuffer.allocate(bufSize);
+            buf.clear();
             try {
                 SocketAddress sender = sock.receive(buf);
                 Message<T> msg = (Message<T>) Serial.decode(buf, Message.class);
diff --git a/src/main/java/derms/net/runicast/ReceiveAcks.java b/src/main/java/derms/net/runicast/ReceiveAcks.java
index 9d7b7de..e2c7e3c 100644
--- a/src/main/java/derms/net/runicast/ReceiveAcks.java
+++ b/src/main/java/derms/net/runicast/ReceiveAcks.java
@@ -29,8 +29,9 @@ class ReceiveAcks<T extends MessagePayload> implements Runnable {
 
     @Override
     public void run() {
+        ByteBuffer buf = ByteBuffer.allocate(bufSize);
         for (;;) {
-            ByteBuffer buf = ByteBuffer.allocate(bufSize);
+            buf.clear();
             try {
                 sock.receive(buf);
                 Ack ack = Serial.decode(buf, Ack.class);
-- 
cgit v1.2.3