opensource/graylog2-server
1
0
Fork 0
mirror of https://github.com/Graylog2/graylog2-server.git synced 2026-03-13 09:32:21 +08:00
Code Issues Packages Projects Releases Wiki Activity

hoist gePayload() out of loop

Browse Source
This commit is contained in:
patrickmann
2026-03-12 18:52:47 +01:00
parent a71bf81bfa
commit 48acbf430a
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
graylog2-server/src/main/java/org/graylog2/shared/buffers/processors/DecodingProcessor.java
View File

@@ -175,11 +175,12 @@ public class DecodingProcessor implements EventHandler<MessageEvent> {
event.setMessage(postProcessMessage(raw, codec, inputIdOnCurrentNode, baseMetricName, message.get(), decodeTime, raw.getPayload().length));
} else if (messages != null && !messages.isEmpty()) {
final List<Message> 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);