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

fix comment

Browse Source
This commit is contained in:
patrickmann
2026-02-16 08:04:20 +01:00
parent debe257c78
commit e38516cd4a
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
graylog2-server/src/main/java/org/graylog/plugins/pipelineprocessor/processors/PipelineInterpreter.java
View File

@@ -141,8 +141,10 @@ public class PipelineInterpreter implements MessageProcessor {
for (Message message : currentSet) {
final String msgId = message.getId();
// this makes a copy of the stream IDs, which is mutated later in updateStreamBlacklist
// it serves as a worklist, to keep track of which <msg, stream> tuples need to be re-run again
// getStreamsView() returns a live, unmodifiable view of the message's streams (not a copy).
// We immediately extract the stream IDs into a mutable set that serves as a worklist
// to keep track of which <msg, stream> tuples need to be re-run again.
// The worklist is mutated later in updateStreamBlacklist.
final Set<Stream> currentStreams = message.getStreamsView();
final Set<String> initialStreamIds = new HashSet<>(currentStreams.size());
for (final Stream stream : currentStreams) {