mirror of
https://github.com/tiennm99/tjahzi.git
synced 2026-10-15 00:17:55 +00:00
This commit is contained in:
1 parent
67fda17f12
commit
1b29ea35d6
1 file changed
+12
-11
@@ -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 +
|
||||
'}';
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user