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 f811c79 MINIFICPP-1734 Add integration test for Kubernetes log
collection
new 61b98e6 MINIFICPP-1686 - Processor destructors are not called
new 2e39461 MINIFICPP-1754 - Always include agentManifestIdentifier in
heartbeat
new 7e2dbeb MINIFICPP-1759 Fix linux/libc++ issues, use libc++ on ubuntu
new 0f50a5a MINIFICPP-1766 ProcessSession::read can't read zero length
flowfiles (DatabaseContentRepository)
new 38d1fbd MINIFICPP-1767 Remove snap support from repository
The 5 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:
.github/workflows/ci.yml | 12 +-
CMakeLists.txt | 7 +
README.md | 31 +-
cmake/BuildTests.cmake | 3 +-
cmake/BundledBustache.cmake | 6 +-
cmake/DockerConfig.cmake | 1 +
controller/Controller.h | 12 +-
docker/Dockerfile | 3 +-
.../features/core_functionality.feature | 6 +
docker/test/integration/minifi/core/ImageStore.py | 2 +-
.../minifi/core/SingleNodeDockerCluster.py | 3 +
.../TransientMinifiContainer.py} | 20 +-
.../minifi/processors/LogOnDestructionProcessor.py | 8 +
docker/test/integration/steps/steps.py | 16 +
extensions/aws/processors/DeleteS3Object.cpp | 2 +
extensions/aws/processors/FetchS3Object.cpp | 2 +
extensions/aws/processors/FetchS3Object.h | 1 +
extensions/aws/processors/ListS3.cpp | 5 +-
extensions/aws/processors/PutS3Object.cpp | 2 +
extensions/aws/processors/PutS3Object.h | 1 +
extensions/aws/processors/S3Processor.cpp | 1 +
.../processors/AzureBlobStorageProcessorBase.cpp | 3 +-
.../azure/processors/AzureStorageProcessorBase.cpp | 1 +
.../azure/processors/DeleteAzureBlobStorage.cpp | 1 +
.../processors/DeleteAzureDataLakeStorage.cpp | 1 +
.../azure/processors/FetchAzureBlobStorage.cpp | 2 +
.../azure/processors/FetchAzureDataLakeStorage.cpp | 2 +
.../azure/processors/FetchAzureDataLakeStorage.h | 1 +
.../azure/processors/ListAzureDataLakeStorage.cpp | 1 +
.../azure/processors/PutAzureBlobStorage.cpp | 2 +
extensions/azure/processors/PutAzureBlobStorage.h | 1 +
.../azure/processors/PutAzureDataLakeStorage.cpp | 1 +
.../azure/processors/PutAzureDataLakeStorage.h | 1 +
extensions/bustache/ApplyTemplate.cpp | 99 +++---
extensions/bustache/ApplyTemplate.h | 40 +--
extensions/civetweb/protocols/RESTReceiver.cpp | 4 +-
extensions/civetweb/protocols/RESTReceiver.h | 2 +-
extensions/coap/tests/CoapC2VerifyHeartbeat.cpp | 4 +-
extensions/expression-language/Expression.cpp | 4 +-
extensions/http-curl/protocols/AgentPrinter.cpp | 2 +-
extensions/http-curl/protocols/AgentPrinter.h | 2 +-
.../tests/C2ClearCoreComponentStateTest.cpp | 6 +-
.../tests/C2DescribeCoreComponentStateTest.cpp | 6 +-
extensions/http-curl/tests/C2NullConfiguration.cpp | 4 +-
extensions/http-curl/tests/C2PauseResumeTest.cpp | 5 +-
.../http-curl/tests/C2VerifyServeResults.cpp | 4 +-
.../tests/ControllerServiceIntegrationTests.cpp | 4 +-
extensions/http-curl/tests/HTTPHandlers.h | 7 +
extensions/http-curl/tests/VerifyInvokeHTTP.h | 4 +-
.../http-curl/tests/unit/InvokeHTTPTests.cpp | 34 +-
extensions/jni/ExecuteJavaProcessor.cpp | 2 +-
extensions/jni/jvm/JniProcessContext.h | 2 +-
extensions/libarchive/BinFiles.cpp | 4 +-
extensions/libarchive/BinFiles.h | 2 +-
extensions/librdkafka/ConsumeKafka.cpp | 3 +
extensions/librdkafka/ConsumeKafka.h | 4 +
extensions/librdkafka/KafkaProcessorBase.cpp | 1 +
extensions/opencv/CaptureRTSPFrame.cpp | 2 +
extensions/opencv/CaptureRTSPFrame.h | 2 +
extensions/opencv/FrameIO.h | 1 +
extensions/opencv/MotionDetector.cpp | 2 +
extensions/opencv/MotionDetector.h | 1 +
.../SourceInitiatedSubscriptionListener.cpp | 1 +
.../SourceInitiatedSubscriptionListener.h | 2 +-
extensions/pdh/PerformanceDataMonitor.cpp | 2 +
extensions/pdh/PerformanceDataMonitor.h | 1 +
extensions/rocksdb-repos/FlowFileRepository.cpp | 8 +-
extensions/rocksdb-repos/FlowFileRepository.h | 34 +-
extensions/rocksdb-repos/ProvenanceRepository.h | 4 +
extensions/rocksdb-repos/RocksDbStream.cpp | 3 +-
.../script/python/ExecutePythonProcessor.cpp | 5 +-
extensions/script/python/PythonObjectFactory.h | 27 +-
extensions/script/python/PythonProcessor.cpp | 22 +-
extensions/script/python/PythonProcessor.h | 17 +-
extensions/script/python/PythonScriptEngine.h | 6 +-
extensions/sftp/processors/ListSFTP.h | 2 +-
extensions/sftp/tests/ListSFTPTests.cpp | 16 +-
extensions/splunk/PutSplunkHTTP.cpp | 2 +
extensions/splunk/QuerySplunkIndexingStatus.cpp | 2 +
extensions/splunk/SplunkHECProcessor.cpp | 1 +
extensions/splunk/SplunkHECProcessor.h | 1 +
extensions/sql/processors/QueryDatabaseTable.h | 2 +-
.../processors/AttributesToJSON.cpp | 1 +
.../processors/AttributesToJSON.h | 4 +-
.../processors/DefragmentText.cpp | 6 +-
.../processors/DefragmentText.h | 2 +-
.../standard-processors/processors/GetFile.cpp | 16 +-
.../standard-processors/processors/GetTCP.cpp | 2 +
extensions/standard-processors/processors/GetTCP.h | 20 +-
.../standard-processors/processors/PutUDP.cpp | 4 +-
.../standard-processors/processors/RouteText.cpp | 10 +-
.../standard-processors/processors/TailFile.h | 2 +-
.../tests/integration/SecureSocketGetTCPTest.cpp | 4 +-
.../tests/integration/TailFileTest.cpp | 6 +-
.../tests/integration/TestExecuteProcess.cpp | 20 +-
.../standard-processors/tests/unit/GetTCPTests.cpp | 105 +++---
.../tests/unit/ManifestTests.cpp | 2 +-
.../tests/unit/ProcessGroupTestUtils.h | 6 +-
.../tests/unit/ProcessorTests.cpp | 32 +-
.../standard-processors/tests/unit/PutUDPTests.cpp | 1 +
.../tests/unit/RouteTextTests.cpp | 5 +-
.../tests/unit/TailFileTests.cpp | 10 +-
.../tests/unit/YamlConfigurationTests.cpp | 18 +-
.../tests/unit/YamlConnectionParserTest.cpp | 12 +-
extensions/systemd/ConsumeJournald.cpp | 2 +
extensions/systemd/ConsumeJournald.h | 4 +-
extensions/{pdh => test-processors}/CMakeLists.txt | 12 +-
.../test-processors}/KamikazeProcessor.cpp | 12 +-
.../test-processors}/KamikazeProcessor.h | 26 +-
.../test-processors/LogOnDestructionProcessor.cpp | 14 +-
.../LogOnDestructionProcessor.h} | 27 +-
extensions/usb-camera/GetUSBCamera.cpp | 1 +
extensions/windows-event-log/Bookmark.cpp | 2 +-
extensions/windows-event-log/Bookmark.h | 4 +-
.../CollectorInitiatedSubscription.cpp | 1 +
.../windows-event-log/ConsumeWindowsEventLog.h | 2 +-
.../windows-event-log/tests/BookmarkTests.cpp | 48 ++-
libminifi/CMakeLists.txt | 9 -
libminifi/include/Connection.h | 23 +-
libminifi/include/CronDrivenSchedulingAgent.h | 4 +-
libminifi/include/EventDrivenSchedulingAgent.h | 4 +-
libminifi/include/FlowController.h | 31 +-
libminifi/include/SchedulingAgent.h | 12 +-
libminifi/include/ThreadedSchedulingAgent.h | 6 +-
libminifi/include/TimerDrivenSchedulingAgent.h | 2 +-
libminifi/include/agent/build_description.h | 18 +-
libminifi/include/c2/C2Agent.h | 8 +-
libminifi/include/c2/C2Client.h | 2 +-
libminifi/include/c2/ControllerSocketProtocol.h | 6 +-
libminifi/include/c2/HeartbeatLogger.h | 2 +-
libminifi/include/c2/HeartbeatReporter.h | 4 +-
.../AbstractCoreComponentStateManagerProvider.h | 17 +-
libminifi/include/core/ClassLoader.h | 12 +-
libminifi/include/core/Connectable.h | 18 +-
libminifi/include/core/Core.h | 8 +-
libminifi/include/core/CoreComponentState.h | 4 +-
libminifi/include/core/Flow.h | 2 +-
libminifi/include/core/FlowConfiguration.h | 8 +-
libminifi/include/core/FlowFile.h | 6 +-
libminifi/include/core/Funnel.h | 1 +
libminifi/include/core/ObjectFactory.h | 30 +-
libminifi/include/core/ProcessContext.h | 6 +-
libminifi/include/core/ProcessGroup.h | 87 +++--
libminifi/include/core/ProcessSession.h | 6 +-
libminifi/include/core/Processor.h | 53 +--
libminifi/include/core/ProcessorNode.h | 38 +-
libminifi/include/core/Repository.h | 14 +-
libminifi/include/core/RepositoryFactory.h | 4 +-
.../controller/StandardControllerServiceNode.h | 7 -
.../controller/StandardControllerServiceProvider.h | 8 +-
.../include/core/repository/VolatileRepository.h | 41 +--
libminifi/include/core/state/ProcessorController.h | 8 +-
libminifi/include/core/state/UpdateController.h | 4 +-
libminifi/include/core/state/Value.h | 2 +
.../include/core/state/nodes/AgentInformation.h | 28 +-
.../include/core/state/nodes/FlowInformation.h | 4 +-
libminifi/include/core/state/nodes/QueueMetrics.h | 9 +-
.../include/core/state/nodes/SchedulingNodes.h | 22 +-
libminifi/include/core/state/nodes/StateMonitor.h | 4 +-
libminifi/include/core/yaml/YamlConfiguration.h | 10 +-
libminifi/include/core/yaml/YamlConnectionParser.h | 6 +-
libminifi/include/processors/ProcessorUtils.h | 28 +-
libminifi/include/utils/GeneralUtils.h | 10 +
libminifi/include/utils/ListingStateManager.h | 8 +-
libminifi/include/utils/OptionalUtils.h | 27 +-
libminifi/include/utils/ThreadPool.h | 10 +-
libminifi/src/Connection.cpp | 10 +-
libminifi/src/CronDrivenSchedulingAgent.cpp | 2 +-
libminifi/src/EventDrivenSchedulingAgent.cpp | 4 +-
libminifi/src/FlowController.cpp | 122 ++++---
libminifi/src/SchedulingAgent.cpp | 21 +-
libminifi/src/ThreadedSchedulingAgent.cpp | 6 +-
libminifi/src/TimerDrivenSchedulingAgent.cpp | 2 +-
libminifi/src/c2/C2Agent.cpp | 20 +-
libminifi/src/c2/C2Client.cpp | 30 +-
libminifi/src/c2/ControllerSocketProtocol.cpp | 2 +-
libminifi/src/c2/HeartbeatLogger.cpp | 2 +-
.../AbstractCoreComponentStateManagerProvider.cpp | 31 +-
libminifi/src/core/Connectable.cpp | 28 +-
libminifi/src/core/FlowConfiguration.cpp | 13 +-
libminifi/src/core/FlowFile.cpp | 4 +-
libminifi/src/core/Funnel.cpp | 2 +
libminifi/src/core/ProcessGroup.cpp | 152 ++++----
libminifi/src/core/ProcessSession.cpp | 51 +--
libminifi/src/core/Processor.cpp | 128 +++----
libminifi/src/core/ProcessorNode.cpp | 2 +-
libminifi/src/core/RepositoryFactory.cpp | 33 +-
.../controller/StandardControllerServiceNode.cpp | 9 -
.../SiteToSiteProvenanceReportingTask.cpp | 6 +-
libminifi/src/core/state/ProcessorController.cpp | 2 +-
libminifi/src/core/state/Value.cpp | 23 ++
libminifi/src/core/yaml/YamlConfiguration.cpp | 139 ++++----
libminifi/src/core/yaml/YamlConnectionParser.cpp | 10 +-
libminifi/src/utils/file/FileUtils.cpp | 2 +-
libminifi/test/SingleInputTestController.h | 7 +-
libminifi/test/StatefulProcessor.cpp | 1 +
libminifi/test/StatefulProcessor.h | 3 +-
libminifi/test/TestBase.cpp | 51 +--
libminifi/test/TestBase.h | 6 +-
.../test/archive-tests/CompressContentTests.cpp | 10 +-
libminifi/test/archive-tests/MergeFileTests.cpp | 386 +++++++++++----------
libminifi/test/bustache-tests/CMakeLists.txt | 2 -
libminifi/test/flow-tests/CycleTest.cpp | 6 +-
libminifi/test/flow-tests/FlowControllerTests.cpp | 16 +-
libminifi/test/flow-tests/LoopTest.cpp | 4 +-
libminifi/test/flow-tests/MultiLoopTest.cpp | 6 +-
libminifi/test/flow-tests/SessionTests.cpp | 7 +-
libminifi/test/flow-tests/TestControllerWithFlow.h | 7 +-
libminifi/test/integration/IntegrationBase.h | 8 +-
.../integration/OnScheduleErrorHandlingTests.cpp | 9 +-
.../integration/StateTransactionalityTests.cpp | 10 +-
libminifi/test/pcap-tests/PcapTest.cpp | 6 +-
.../test/persistence-tests/PersistenceTests.cpp | 67 ++--
.../rocksdb-tests/DBContentRepositoryTests.cpp | 8 +-
libminifi/test/rocksdb-tests/EncryptionTests.cpp | 10 +-
libminifi/test/rocksdb-tests/RepoTests.cpp | 27 +-
libminifi/test/sensors-tests/SensorTests.cpp | 4 +-
libminifi/test/sql-tests/SQLTestPlan.h | 4 +-
libminifi/test/unit/C2MetricsTests.cpp | 6 +-
.../test/unit/ContentRepositoryDependentTests.h | 13 +
libminifi/test/unit/ControllerTests.cpp | 24 +-
libminifi/test/unit/ProcessSessionTests.cpp | 5 +
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 2 +-
libminifi/test/unit/ProvenanceTestHelper.h | 18 +-
main/MiNiFiMain.cpp | 2 +-
nanofi/include/cxx/C2CallbackAgent.h | 2 +-
nanofi/include/cxx/Instance.h | 2 +-
nanofi/include/cxx/Plan.h | 2 +-
nanofi/src/api/nanofi.cpp | 2 +-
nanofi/src/cxx/C2CallbackAgent.cpp | 2 +-
nanofi/src/cxx/Plan.cpp | 19 +-
snap/snapcraft.yaml | 52 ---
232 files changed, 1629 insertions(+), 1743 deletions(-)
copy
docker/test/integration/minifi/{controllers/KubernetesControllerService.py =>
core/TransientMinifiContainer.py} (61%)
create mode 100644
docker/test/integration/minifi/processors/LogOnDestructionProcessor.py
copy extensions/{pdh => test-processors}/CMakeLists.txt (71%)
rename {libminifi/test => extensions/test-processors}/KamikazeProcessor.cpp
(93%)
rename {libminifi/test => extensions/test-processors}/KamikazeProcessor.h (75%)
copy libminifi/include/io/Sockets.h =>
extensions/test-processors/LogOnDestructionProcessor.cpp (73%)
copy extensions/{sql/processors/PutSQL.h =>
test-processors/LogOnDestructionProcessor.h} (62%)
delete mode 100644 snap/snapcraft.yaml
