From 48acbf430ae4bb044f36ed4e4baeae4c326a0024 Mon Sep 17 00:00:00 2001 From: patrickmann Date: Thu, 12 Mar 2026 18:52:47 +0100 Subject: [PATCH] hoist gePayload() out of loop --- .../graylog2/shared/buffers/processors/DecodingProcessor.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/graylog2-server/src/main/java/org/graylog2/shared/buffers/processors/DecodingProcessor.java b/graylog2-server/src/main/java/org/graylog2/shared/buffers/processors/DecodingProcessor.java index a75b09aa2a..b38e95d595 100644 --- a/graylog2-server/src/main/java/org/graylog2/shared/buffers/processors/DecodingProcessor.java +++ b/graylog2-server/src/main/java/org/graylog2/shared/buffers/processors/DecodingProcessor.java @@ -175,11 +175,12 @@ public class DecodingProcessor implements EventHandler { event.setMessage(postProcessMessage(raw, codec, inputIdOnCurrentNode, baseMetricName, message.get(), decodeTime, raw.getPayload().length)); } else if (messages != null && !messages.isEmpty()) { final List processedMessages = Lists.newArrayListWithCapacity(messages.size()); + final long payloadLength = raw.getPayload().length; boolean first = true; for (final Message msg : messages) { // Avoid overcounting input traffic by only setting the input size for the first message. - final long inputSize = first ? raw.getPayload().length : 0L; + final long inputSize = first ? payloadLength : 0L; first = false; final Message processedMessage = postProcessMessage(raw, codec, inputIdOnCurrentNode, baseMetricName, msg, decodeTime, inputSize);