From 1b29ea35d60fd9e79bdbcacc8add73903289b952 Mon Sep 17 00:00:00 2001
From: Tomasz Kowalczewski <tomasz.kowalczewski@gmail.com>
Date: Fri, 1 Sep 2023 15:02:14 +0200
Subject: [PATCH] Re #86: Changing buffer to off heap - it might help with
 alignment issues on 32bit. (#117)

---
 .../stats/StandardMonitoringModule.java       | 23 ++++++++++---------
 1 file changed, 12 insertions(+), 11 deletions(-)

diff --git a/core/src/main/java/pl/tkowalcz/tjahzi/stats/StandardMonitoringModule.java b/core/src/main/java/pl/tkowalcz/tjahzi/stats/StandardMonitoringModule.java
index aee9a7e..40beed1 100644
--- a/core/src/main/java/pl/tkowalcz/tjahzi/stats/StandardMonitoringModule.java
+++ b/core/src/main/java/pl/tkowalcz/tjahzi/stats/StandardMonitoringModule.java
@@ -4,6 +4,7 @@ import org.agrona.concurrent.SystemEpochClock;
 import org.agrona.concurrent.UnsafeBuffer;
 import org.agrona.concurrent.errors.DistinctErrorLog;
 
+import java.nio.ByteBuffer;
 import java.util.concurrent.atomic.AtomicLong;
 
 public class StandardMonitoringModule implements MonitoringModule {
@@ -31,7 +32,7 @@ public class StandardMonitoringModule implements MonitoringModule {
         }
 
         distinctErrorLog = new DistinctErrorLog(
-                new UnsafeBuffer(new byte[ERROR_LOG_CAPACITY]),
+                new UnsafeBuffer(ByteBuffer.allocateDirect(ERROR_LOG_CAPACITY)),
                 new SystemEpochClock()
         );
 
@@ -130,15 +131,15 @@ public class StandardMonitoringModule implements MonitoringModule {
     @Override
     public String toString() {
         return "StandardMonitoringModule{" +
-                "droppedPuts=" + droppedPuts +
-                ", httpConnectAttempts=" + httpConnectAttempts +
-                ", sentHttpRequests=" + sentHttpRequests +
-                ", sentKilobytes=" + (sentBytes.longValue() / 1024) +
-                ", failedHttpRequests=" + failedHttpRequests +
-                ", retriedHttpRequests=" + retriedHttpRequests +
-                ", httpResponses=" + httpResponses +
-                ", channelInactive=" + channelInactive +
-                ", agentErrors=" + agentErrors +
-                '}';
+               "droppedPuts=" + droppedPuts +
+               ", httpConnectAttempts=" + httpConnectAttempts +
+               ", sentHttpRequests=" + sentHttpRequests +
+               ", sentKilobytes=" + (sentBytes.longValue() / 1024) +
+               ", failedHttpRequests=" + failedHttpRequests +
+               ", retriedHttpRequests=" + retriedHttpRequests +
+               ", httpResponses=" + httpResponses +
+               ", channelInactive=" + channelInactive +
+               ", agentErrors=" + agentErrors +
+               '}';
     }
 }