This is an automated email from the ASF dual-hosted git repository.
fgerlits pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
from 5d6efa8a3 MINIFICPP-1937 Rework rocksdb handling, use
OptimizeForPointLookup
new ffd02405a MINIFICPP-1958 - CoreComponent should pass strings by value
and move them in constructor
new 8bda98d4a MINIFICPP-1959 - Ensure that VolatileFlowFileRepository does
not delete referenced resource
new 7888ca431 MINIFICPP-1978 - Flush MergeContent bundles when its size
would grow beyond max group size
new 9c439e272 MINIFICPP-1981 Decrease default C2 heartbeat frequency
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
C2.md | 4 +-
conf/minifi.properties | 4 +-
.../minifi.properties | 2 +-
encrypt-config/tests/resources/minifi.properties | 2 +-
...th-additional-sensitive-props.minifi.properties | 2 +-
.../aws/controllerservices/AWSCredentialsService.h | 23 ++----
extensions/aws/processors/DeleteS3Object.h | 4 +-
extensions/aws/processors/FetchS3Object.h | 4 +-
extensions/aws/processors/ListS3.h | 4 +-
extensions/aws/processors/PutS3Object.h | 4 +-
extensions/aws/processors/S3Processor.cpp | 4 +-
extensions/aws/processors/S3Processor.h | 16 +---
.../AzureStorageCredentialsService.h | 9 ++-
.../processors/AzureBlobStorageProcessorBase.h | 8 +-
.../AzureBlobStorageSingleBlobProcessorBase.h | 8 +-
.../AzureDataLakeStorageFileProcessorBase.h | 8 +-
.../processors/AzureDataLakeStorageProcessorBase.h | 8 +-
.../azure/processors/AzureStorageProcessorBase.h | 5 +-
.../azure/processors/DeleteAzureBlobStorage.h | 8 +-
.../azure/processors/DeleteAzureDataLakeStorage.h | 8 +-
.../azure/processors/FetchAzureBlobStorage.h | 8 +-
.../azure/processors/FetchAzureDataLakeStorage.h | 8 +-
extensions/azure/processors/ListAzureBlobStorage.h | 8 +-
.../azure/processors/ListAzureDataLakeStorage.h | 8 +-
extensions/azure/processors/PutAzureBlobStorage.h | 8 +-
.../azure/processors/PutAzureDataLakeStorage.h | 8 +-
extensions/bustache/ApplyTemplate.h | 5 +-
extensions/civetweb/processors/ListenHTTP.h | 4 +-
extensions/civetweb/protocols/RESTReceiver.cpp | 4 +-
extensions/civetweb/protocols/RESTReceiver.h | 2 +-
extensions/coap/controllerservice/CoapConnector.h | 4 +-
extensions/coap/protocols/CoapC2Protocol.cpp | 4 +-
extensions/coap/protocols/CoapC2Protocol.h | 2 +-
extensions/coap/server/CoapServer.h | 16 +---
.../ExpressionContextBuilder.cpp | 8 +-
.../expression-language/ExpressionContextBuilder.h | 5 +-
extensions/gcp/processors/DeleteGCSObject.h | 7 +-
extensions/gcp/processors/FetchGCSObject.h | 7 +-
extensions/gcp/processors/GCSProcessor.h | 4 +-
extensions/gcp/processors/ListGCSBucket.h | 7 +-
extensions/gcp/processors/PutGCSObject.h | 7 +-
extensions/gps/GetGPS.h | 19 ++---
extensions/http-curl/client/HTTPClient.cpp | 4 +-
extensions/http-curl/client/HTTPClient.h | 2 +-
extensions/http-curl/processors/InvokeHTTP.h | 5 +-
extensions/http-curl/protocols/AgentPrinter.cpp | 6 +-
extensions/http-curl/protocols/AgentPrinter.h | 2 +-
extensions/http-curl/protocols/RESTSender.cpp | 4 +-
extensions/http-curl/protocols/RESTSender.h | 2 +-
extensions/http-curl/sitetosite/HTTPProtocol.h | 2 +-
extensions/jni/ExecuteJavaControllerService.h | 19 ++---
extensions/jni/ExecuteJavaProcessor.h | 21 ++---
extensions/jni/JVMCreator.h | 9 ++-
extensions/jni/jvm/JavaControllerService.h | 4 +-
extensions/jni/jvm/JniConfigurationContext.h | 19 ++---
extensions/libarchive/BinFiles.h | 7 +-
extensions/libarchive/CompressContent.h | 4 +-
extensions/libarchive/FocusArchiveEntry.h | 5 +-
extensions/libarchive/ManipulateArchive.h | 19 ++---
extensions/libarchive/UnfocusArchiveEntry.h | 5 +-
extensions/librdkafka/ConsumeKafka.h | 4 +-
extensions/librdkafka/KafkaProcessorBase.h | 7 +-
extensions/librdkafka/PublishKafka.h | 4 +-
extensions/mqtt/processors/AbstractMQTTProcessor.h | 5 +-
extensions/mqtt/processors/ConsumeMQTT.h | 4 +-
extensions/mqtt/processors/PublishMQTT.h | 4 +-
extensions/opc/include/fetchopc.h | 5 +-
extensions/opc/include/opcbase.h | 5 +-
extensions/opc/include/putopc.h | 5 +-
extensions/opencv/CaptureRTSPFrame.h | 4 +-
extensions/opencv/MotionDetector.h | 17 ++--
.../SourceInitiatedSubscriptionListener.cpp | 4 +-
.../SourceInitiatedSubscriptionListener.h | 2 +-
extensions/pcap/CapturePacket.h | 24 ++----
extensions/procfs/processors/ProcFsMonitor.h | 4 +-
.../rocksdb-repos/DatabaseContentRepository.h | 7 +-
extensions/rocksdb-repos/FlowFileRepository.h | 8 +-
extensions/rocksdb-repos/ProvenanceRepository.h | 8 +-
.../RocksDbPersistableKeyValueStoreService.cpp | 5 +-
.../RocksDbPersistableKeyValueStoreService.h | 2 +-
extensions/script/ExecuteScript.h | 4 +-
extensions/script/python/ExecutePythonProcessor.h | 19 ++---
extensions/script/python/PythonCreator.h | 16 +---
extensions/sensors/GetEnvironmentalSensors.h | 17 ++--
extensions/sensors/GetMovementSensors.h | 17 ++--
extensions/sensors/SensorBase.h | 16 +---
extensions/sftp/processors/FetchSFTP.cpp | 4 +-
extensions/sftp/processors/FetchSFTP.h | 2 +-
extensions/sftp/processors/ListSFTP.cpp | 4 +-
extensions/sftp/processors/ListSFTP.h | 2 +-
extensions/sftp/processors/PutSFTP.cpp | 4 +-
extensions/sftp/processors/PutSFTP.h | 2 +-
extensions/sftp/processors/SFTPProcessorBase.cpp | 4 +-
extensions/sftp/processors/SFTPProcessorBase.h | 2 +-
extensions/sftp/tests/ListSFTPTests.cpp | 2 +-
extensions/splunk/PutSplunkHTTP.h | 7 +-
extensions/splunk/QuerySplunkIndexingStatus.h | 7 +-
extensions/splunk/SplunkHECProcessor.h | 8 +-
extensions/sql/processors/ExecuteSQL.cpp | 4 +-
extensions/sql/processors/ExecuteSQL.h | 15 +---
extensions/sql/processors/PutSQL.cpp | 4 +-
extensions/sql/processors/PutSQL.h | 2 +-
extensions/sql/processors/QueryDatabaseTable.cpp | 4 +-
extensions/sql/processors/QueryDatabaseTable.h | 14 +---
extensions/sql/processors/SQLProcessor.h | 16 +---
extensions/sql/services/DatabaseService.h | 8 +-
extensions/sql/services/ODBCConnector.h | 8 +-
.../UnorderedMapKeyValueStoreService.cpp | 8 +-
.../controllers/UnorderedMapKeyValueStoreService.h | 4 +-
...UnorderedMapPersistableKeyValueStoreService.cpp | 8 +-
.../UnorderedMapPersistableKeyValueStoreService.h | 4 +-
.../processors/AppendHostInfo.h | 19 ++---
.../processors/AttributesToJSON.h | 25 +++---
.../processors/DefragmentText.h | 7 +-
.../processors/ExecuteProcess.h | 5 +-
.../standard-processors/processors/ExtractText.h | 5 +-
.../standard-processors/processors/FetchFile.h | 7 +-
.../processors/GenerateFlowFile.h | 4 +-
.../standard-processors/processors/GetFile.h | 4 +-
extensions/standard-processors/processors/GetTCP.h | 4 +-
.../standard-processors/processors/HashContent.h | 4 +-
.../standard-processors/processors/ListFile.h | 11 +--
.../standard-processors/processors/ListenSyslog.h | 4 +-
.../standard-processors/processors/ListenTCP.h | 5 +-
.../standard-processors/processors/LogAttribute.h | 4 +-
.../processors/NetworkListenerProcessor.h | 4 +-
.../standard-processors/processors/PutFile.h | 4 +-
.../standard-processors/processors/PutUDP.cpp | 4 +-
extensions/standard-processors/processors/PutUDP.h | 3 +-
.../standard-processors/processors/ReplaceText.cpp | 4 +-
.../standard-processors/processors/ReplaceText.h | 2 +-
.../standard-processors/processors/RetryFlowFile.h | 16 +---
.../processors/RouteOnAttribute.h | 17 ++--
.../standard-processors/processors/RouteText.cpp | 4 +-
.../standard-processors/processors/RouteText.h | 2 +-
.../standard-processors/processors/TailFile.h | 4 +-
.../processors/UpdateAttribute.h | 17 ++--
.../tests/unit/DefragmentTextTests.cpp | 4 +-
.../tests/unit/ProcessorTests.cpp | 4 +-
.../tests/unit/TailFileTests.cpp | 4 +-
extensions/systemd/ConsumeJournald.cpp | 4 +-
extensions/systemd/ConsumeJournald.h | 11 +--
extensions/test-processors/KamikazeProcessor.h | 7 +-
.../test-processors/LogOnDestructionProcessor.h | 5 +-
extensions/usb-camera/GetUSBCamera.h | 17 ++--
libminifi/include/Connection.h | 10 +--
libminifi/include/RemoteProcessorGroupPort.h | 6 +-
libminifi/include/c2/C2Protocol.h | 17 ++--
libminifi/include/c2/C2Trigger.h | 21 ++---
libminifi/include/c2/ControllerSocketProtocol.h | 5 +-
libminifi/include/c2/HeartbeatLogger.h | 2 +-
libminifi/include/c2/HeartbeatReporter.h | 40 ++++-----
libminifi/include/c2/triggers/FileUpdateTrigger.h | 8 +-
.../controllers/LinuxPowerManagementService.h | 8 +-
.../controllers/NetworkPrioritizerService.h | 8 +-
libminifi/include/controllers/SSLContextService.h | 11 ++-
.../include/controllers/ThreadManagementService.h | 24 +++---
.../controllers/UpdatePolicyControllerService.h | 14 ++--
.../AbstractAutoPersistingKeyValueStoreService.h | 2 +-
.../controllers/keyvalue/KeyValueStoreService.h | 14 +---
.../keyvalue/PersistableKeyValueStoreService.h | 14 +---
libminifi/include/core/Connectable.h | 4 +-
libminifi/include/core/Core.h | 8 +-
libminifi/include/core/Funnel.h | 7 +-
libminifi/include/core/ProcessContextBuilder.h | 4 +-
libminifi/include/core/ProcessGroup.h | 14 +---
libminifi/include/core/Processor.h | 4 +-
libminifi/include/core/ProcessorNode.h | 19 ++---
libminifi/include/core/Repository.h | 4 +-
libminifi/include/core/SerializableComponent.h | 9 ++-
.../include/core/controller/ControllerService.h | 39 +++------
.../core/controller/ControllerServiceNode.h | 36 +++------
.../core/controller/ControllerServiceProvider.h | 29 ++-----
.../controller/StandardControllerServiceNode.h | 11 +--
.../reporting/SiteToSiteProvenanceReportingTask.h | 35 +++-----
.../include/core/repository/FileSystemRepository.h | 5 +-
.../core/repository/VolatileFlowFileRepository.h | 4 +
.../include/core/repository/VolatileRepository.h | 11 +--
.../include/core/state/nodes/AgentInformation.h | 56 ++++++-------
.../include/core/state/nodes/BuildInformation.h | 9 ++-
.../core/state/nodes/ConfigurationChecksums.h | 3 +-
.../include/core/state/nodes/DeviceInformation.h | 15 ++--
.../include/core/state/nodes/FlowInformation.h | 16 ++--
libminifi/include/core/state/nodes/MetricsBase.h | 34 ++++----
.../include/core/state/nodes/RepositoryMetrics.h | 8 +-
.../include/core/state/nodes/SchedulingNodes.h | 10 +--
libminifi/include/core/state/nodes/StateMonitor.h | 23 ++----
.../include/core/state/nodes/SupportedOperations.h | 4 +-
libminifi/include/provenance/Provenance.h | 5 --
libminifi/include/sitetosite/RawSocketProtocol.h | 6 +-
libminifi/src/Connection.cpp | 20 ++---
libminifi/src/c2/HeartbeatLogger.cpp | 4 +-
.../AbstractAutoPersistingKeyValueStoreService.cpp | 4 +-
.../controllers/keyvalue/KeyValueStoreService.cpp | 19 ++---
.../keyvalue/PersistableKeyValueStoreService.cpp | 16 +---
libminifi/src/core/Connectable.cpp | 8 +-
libminifi/src/core/Core.cpp | 8 +-
libminifi/src/core/ProcessContextBuilder.cpp | 8 +-
libminifi/src/core/ProcessGroup.cpp | 31 +++----
libminifi/src/core/ProcessSession.cpp | 94 +++++++++++++---------
libminifi/src/core/Processor.cpp | 8 +-
libminifi/src/core/RepositoryFactory.cpp | 4 +-
.../src/core/state/nodes/SupportedOperations.cpp | 8 +-
libminifi/test/DummyProcessor.h | 5 +-
libminifi/test/ReadFromFlowFileTestProcessor.h | 9 ++-
libminifi/test/TestBase.cpp | 32 ++++++--
libminifi/test/TestBase.h | 13 ++-
libminifi/test/WriteToFlowFileTestProcessor.h | 4 +-
libminifi/test/archive-tests/MergeFileTests.cpp | 66 +++++++++++++++
libminifi/test/flow-tests/CustomProcessors.h | 22 ++---
.../test/persistence-tests/PersistenceTests.cpp | 2 +-
.../test/resources/encrypted.minifi.properties | 2 +-
libminifi/test/sql-tests/mocks/MockODBCService.h | 9 ++-
libminifi/test/unit/ChecksumCalculatorTests.cpp | 4 +-
.../test/unit/ContentRepositoryDependentTests.h | 2 +-
libminifi/test/unit/MockClasses.h | 17 ++--
libminifi/test/unit/ProcessSessionTests.cpp | 51 +++++++++++-
msi/WixWin.wsi | 2 +-
msi/WixWinMergeModules.wsi | 2 +-
nanofi/include/cxx/CallbackProcessor.h | 16 +---
220 files changed, 1011 insertions(+), 1151 deletions(-)
