logstash-core/src/main/java/org/logstash/ackedqueue/Queue.java (7 lines): - line 309: // TODO: here do directory traversal and cleanup lingering pages? could be a background operations to not delay queue start? - line 434: // TODO: verify queue state integrity WRT Queue.open()/recover() at each step of this process - line 441: // TODO: we could possibly reuse the same page file but just rename it? - line 470: // TODO: we will want to avoid initiating a new write operation if Thread.interrupted() was called. - line 544: * TODO: note that this should be the same as isFullyAcked once fixed per https://github.com/elastic/logstash/issues/7570 - line 767: // TODO: review close strategy and exception handling and resiliency of first closing tail pages if crash in the middle - line 772: // TODO: not sure if we need to do this here since the headpage close will also call ensurePersisted logstash-core/src/main/java/org/logstash/ackedqueue/Page.java (5 lines): - line 37: protected long minSeqNum; // TODO: see if we can make it final? - line 45: // TODO: go steal LocalCheckpointService in feature/seq_no from ES - line 46: // TODO: https://github.com/elastic/elasticsearch/blob/feature/seq_no/core/src/main/java/org/elasticsearch/index/seqno/LocalCheckpointService.java - line 111: * TODO: note that this should be the same as isFullyAcked once fixed per https://github.com/elastic/logstash/issues/7570 - line 299: // TODO: eventually refactor to use new bithandling class logstash-core/src/main/java/org/logstash/ackedqueue/io/MmapPageIOV2.java (3 lines): - line 65: private long minSeqNum; // TODO: to make minSeqNum final we have to pass in the minSeqNum in the constructor and not set it on first write - line 213: // TODO: do we need to check is the channel is still open? not sure how it could be closed - line 317: // TODO: I know this isn't a great exception message but at the time of writing I couldn't come up with anything better :P logstash-core/lib/logstash/json.rb (3 lines): - line 26: # TODO [guyboertje] remove these comments in 5.0 - line 37: # TODO [guyboertje] remove these comments in 5.0 - line 39: # also look for Java::JavaUtil::ArrayList, see TODO submit issue lib/pluginmanager/templates/filter-plugin/logstash-filter-example.gemspec.erb (2 lines): - line 6: s.description = 'TODO: Write a longer description or delete this line.' - line 7: s.homepage = 'TODO: Put your plugin''s website or public repo URL here.' logstash-core/src/main/java/org/logstash/execution/QueueReadClientBase.java (2 lines): - line 134: // JTODO getId has been deprecated in JDK 19, when JDK 21 is the target version use threadId() instead - line 193: // JTODO getId has been deprecated in JDK 19, when JDK 21 is the target version use threadId() instead logstash-core/src/main/java/org/logstash/Accessors.java (2 lines): - line 83: // TODO: (colin) this is potentially dangerous, and could produce OOM using arbitrary big numbers - line 84: // TODO: (colin) should be guard against this? lib/pluginmanager/templates/codec-plugin/logstash-codec-example.gemspec.erb (2 lines): - line 6: s.description = 'TODO: Write a longer description or delete this line.' - line 7: s.homepage = 'TODO: Put your plugin''s website or public repo URL here.' lib/pluginmanager/templates/input-plugin/logstash-input-example.gemspec.erb (2 lines): - line 6: s.description = 'TODO: Write a longer description or delete this line.' - line 7: s.homepage = 'TODO: Put your plugin''s website or public repo URL here.' lib/pluginmanager/templates/output-plugin/logstash-output-example.gemspec.erb (2 lines): - line 6: s.description = 'TODO: Write a longer description or delete this line.' - line 7: s.homepage = 'TODO: Put your plugin''s website or public repo URL here.' logstash-core/spec/logstash/api/commands/stats_spec.rb (2 lines): - line 49: # TODO pass in a real sample vertex - line 60: # TODO re-add vertices -- see above x-pack/spec/license_checker/license_reader_spec.rb (2 lines): - line 34: # TODO: fix indirection - line 114: # TODO: really, dawg? which is it? exceptions or not? logstash-core/lib/logstash/outputs/base.rb (2 lines): - line 36: # TODO remove this in Logstash 6.0 - line 143: # TODO: noop for now, remove this once we delete this call from all plugins logstash-core/src/main/java/org/logstash/ackedqueue/io/PageIO.java (1 line): - line 36: // TODO: we should probably refactor this with a factory to force the creation of a fully logstash-core/src/main/java/org/logstash/ObjectMappers.java (1 line): - line 104: /* TODO use this validator instead of LaissezFaireSubTypeValidator logstash-core/src/main/java/org/logstash/KeyNode.java (1 line): - line 31: // TODO: (colin) this should be moved somewhere else to make it reusable lib/pluginmanager/install.rb (1 line): - line 120: # TODO: find right syntax to allow specifying list of plugins with optional version specification for each logstash-core/src/main/java/org/logstash/RubyJavaIntegration.java (1 line): - line 255: * TODO find proper fix, and submit upstream logstash-core/src/main/java/org/logstash/Event.java (1 line): - line 514: // TODO: we should eventually look into using alternate data structures to do more efficient dedup but that will require properly defining the tagging API too x-pack/lib/monitoring/inputs/metrics/stats_event_factory.rb (1 line): - line 96: # TODO: replace exception logic with has_keys? when it is implemented in MetricStore logstash-core/src/main/java/org/logstash/util/UtilExt.java (1 line): - line 45: // JTODO getId has been deprecated in JDK 19, when JDK 21 is the target version use threadId() instead logstash-core/src/main/java/org/logstash/ackedqueue/Batch.java (1 line): - line 63: // TODO: how should we handle double-closing? logstash-core/lib/logstash/plugins/builtin/pipeline/input.rb (1 line): - line 60: # TODO This should probably push a batch at some point in the future when doing so rakelib/artifacts.rake (1 line): - line 26: ## TODO: Install new service files x-pack/spec/monitoring/inputs/metrics/stats_event_factory_spec.rb (1 line): - line 109: # TODO: fix issue https://github.com/elastic/logstash/issues/12711 logstash-core/src/main/java/org/logstash/ext/JrubyEventExtLibrary.java (1 line): - line 265: // TODO: add UTF-8 validation lib/pluginmanager/util.rb (1 line): - line 192: # TODO: properly merge versions requirements logstash-core/spec/logstash/pipeline_reporter_spec.rb (1 line): - line 22: #TODO: Figure out how to add more tests that actually cover inflight events logstash-core/lib/logstash/filters/base.rb (1 line): - line 230: # TODO: noop for now, remove this once we delete this call from all plugins tools/logstash-docgen/lib/logstash/docgen/static_parser.rb (1 line): - line 25: Regexp.new(/TODO:?/) logstash-core/src/main/java/org/logstash/FileLockFactory.java (1 line): - line 61: * TODO: because of the releaseLock() method, strictly speaking this class is not only a factory anymore, logstash-core/src/main/java/org/logstash/config/ir/compiler/OutputStrategyExt.java (1 line): - line 259: // TODO: fixup mocks logstash-core/lib/logstash/java_pipeline.rb (1 line): - line 461: # TODO: should we also check against calling shutdown multiple times concurrently? x-pack/lib/geoip_database_management/util.rb (1 line): - line 8: include Constants # TODO: push up x-pack/lib/license_checker/license_reader.rb (1 line): - line 33: # TODO: do we need both this AND the exception-based control flow?? logstash-core/src/main/java/org/logstash/instrument/monitors/HotThreadsMonitor.java (1 line): - line 168: // JTODO getId has been deprecated in JDK 19, when JDK 21 is the target version use threadId() instead logstash-core/src/main/java/org/logstash/ConvertedMap.java (1 line): - line 60: // TODO: replace with LRU cache and/or isolated intern pool logstash-core/src/main/java/org/logstash/ackedqueue/io/FileCheckpointIO.java (1 line): - line 151: // TODO - build reader for this version logstash-core/lib/logstash/runner.rb (1 line): - line 516: # TODO: set binding to this instance of Runner logstash-core/src/main/java/org/logstash/plugins/factory/PluginFactoryExt.java (1 line): - line 290: // TODO: caller seems to think that the args is `Map`, but logstash-core/src/main/java/org/logstash/execution/PipelineReporterExt.java (1 line): - line 177: // JTODO getId has been deprecated in JDK 19, when JDK 21 is the target version use threadId() instead qa/rspec/commands.rb (1 line): - line 209: # TODO add specific commands (e.g. to use dnf instead of yum where applicable) logstash-core/src/main/java/org/logstash/common/io/DeadLetterQueueWriter.java (1 line): - line 651: * TODO: Add metadata around 'depth' to enable >1 iteration through the DLQ if required.