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 513cb5f53 MINIFICPP-2267 - Add dynamic library to package on intel
macos
new 05e591ea9 MINIFICPP-1415 Pass references to onTrigger and onSchedule
instead of shared_ptr
new 70f0bb980 MINIFICPP-2258 Update LIBLZMA_URL (gentoo structure changed)
The 2 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:
cmake/BundledLibLZMA.cmake | 2 +-
extensions/aws/processors/DeleteS3Object.cpp | 20 +--
extensions/aws/processors/DeleteS3Object.h | 4 +-
extensions/aws/processors/FetchS3Object.cpp | 38 +++---
extensions/aws/processors/FetchS3Object.h | 6 +-
extensions/aws/processors/ListS3.cpp | 28 ++--
extensions/aws/processors/ListS3.h | 4 +-
extensions/aws/processors/PutS3Object.cpp | 80 +++++------
extensions/aws/processors/PutS3Object.h | 14 +-
extensions/aws/processors/S3Processor.cpp | 40 +++---
extensions/aws/processors/S3Processor.h | 10 +-
.../processors/AzureBlobStorageProcessorBase.cpp | 17 ++-
.../processors/AzureBlobStorageProcessorBase.h | 2 +-
.../AzureDataLakeStorageProcessorBase.cpp | 5 +-
.../processors/AzureDataLakeStorageProcessorBase.h | 2 +-
.../azure/processors/DeleteAzureBlobStorage.cpp | 18 ++-
.../azure/processors/DeleteAzureBlobStorage.h | 4 +-
.../processors/DeleteAzureDataLakeStorage.cpp | 15 +--
.../azure/processors/DeleteAzureDataLakeStorage.h | 2 +-
.../azure/processors/FetchAzureBlobStorage.cpp | 23 ++--
.../azure/processors/FetchAzureBlobStorage.h | 2 +-
.../azure/processors/FetchAzureDataLakeStorage.cpp | 23 ++--
.../azure/processors/FetchAzureDataLakeStorage.h | 2 +-
.../azure/processors/ListAzureBlobStorage.cpp | 19 ++-
extensions/azure/processors/ListAzureBlobStorage.h | 4 +-
.../azure/processors/ListAzureDataLakeStorage.cpp | 22 ++-
.../azure/processors/ListAzureDataLakeStorage.h | 4 +-
.../azure/processors/PutAzureBlobStorage.cpp | 34 +++--
extensions/azure/processors/PutAzureBlobStorage.h | 4 +-
.../azure/processors/PutAzureDataLakeStorage.cpp | 40 +++---
.../azure/processors/PutAzureDataLakeStorage.h | 4 +-
extensions/bustache/ApplyTemplate.cpp | 11 +-
extensions/bustache/ApplyTemplate.h | 2 +-
extensions/civetweb/processors/ListenHTTP.cpp | 29 ++--
extensions/civetweb/processors/ListenHTTP.h | 4 +-
extensions/elasticsearch/PostElasticsearch.cpp | 22 ++-
extensions/elasticsearch/PostElasticsearch.h | 4 +-
extensions/gcp/processors/DeleteGCSObject.cpp | 24 ++--
extensions/gcp/processors/DeleteGCSObject.h | 2 +-
extensions/gcp/processors/FetchGCSObject.cpp | 31 +++--
extensions/gcp/processors/FetchGCSObject.h | 4 +-
extensions/gcp/processors/GCSProcessor.cpp | 9 +-
extensions/gcp/processors/GCSProcessor.h | 2 +-
extensions/gcp/processors/ListGCSBucket.cpp | 15 +--
extensions/gcp/processors/ListGCSBucket.h | 4 +-
extensions/gcp/processors/PutGCSObject.cpp | 37 +++--
extensions/gcp/processors/PutGCSObject.h | 4 +-
extensions/gps/GetGPS.cpp | 14 +-
extensions/gps/GetGPS.h | 4 +-
extensions/http-curl/processors/InvokeHTTP.cpp | 150 +++++++++------------
extensions/http-curl/processors/InvokeHTTP.h | 24 +++-
extensions/http-curl/sitetosite/HTTPProtocol.cpp | 2 +-
extensions/http-curl/sitetosite/HTTPProtocol.h | 4 +-
.../http-curl/tests/unit/InvokeHTTPTests.cpp | 18 +--
extensions/jni/ExecuteJavaProcessor.cpp | 6 +-
extensions/jni/ExecuteJavaProcessor.h | 3 +-
.../processors/CollectKubernetesPodMetrics.cpp | 18 ++-
.../processors/CollectKubernetesPodMetrics.h | 4 +-
extensions/libarchive/BinFiles.cpp | 26 ++--
extensions/libarchive/BinFiles.h | 6 +-
extensions/libarchive/CompressContent.cpp | 56 ++++----
extensions/libarchive/CompressContent.h | 26 ++--
extensions/libarchive/FocusArchiveEntry.cpp | 18 +--
extensions/libarchive/FocusArchiveEntry.h | 2 +-
extensions/libarchive/ManipulateArchive.cpp | 26 ++--
extensions/libarchive/ManipulateArchive.h | 4 +-
extensions/libarchive/MergeContent.cpp | 26 ++--
extensions/libarchive/MergeContent.h | 4 +-
extensions/libarchive/UnfocusArchiveEntry.cpp | 19 ++-
extensions/libarchive/UnfocusArchiveEntry.h | 2 +-
.../libarchive/tests/CompressContentTests.cpp | 18 +--
extensions/libarchive/tests/MergeFileTests.cpp | 50 +++----
extensions/librdkafka/ConsumeKafka.cpp | 39 +++---
extensions/librdkafka/ConsumeKafka.h | 4 +-
extensions/librdkafka/PublishKafka.cpp | 68 +++++-----
extensions/librdkafka/PublishKafka.h | 8 +-
extensions/lua/LuaScriptExecutor.h | 2 +-
.../mqtt/processors/AbstractMQTTProcessor.cpp | 40 +++---
extensions/mqtt/processors/AbstractMQTTProcessor.h | 8 +-
extensions/mqtt/processors/ConsumeMQTT.cpp | 40 +++---
extensions/mqtt/processors/ConsumeMQTT.h | 8 +-
extensions/mqtt/processors/PublishMQTT.cpp | 28 ++--
extensions/mqtt/processors/PublishMQTT.h | 8 +-
extensions/opc/include/fetchopc.h | 8 +-
extensions/opc/include/opcbase.h | 2 +-
extensions/opc/include/putopc.h | 4 +-
extensions/opc/src/fetchopc.cpp | 26 ++--
extensions/opc/src/opcbase.cpp | 14 +-
extensions/opc/src/putopc.cpp | 54 ++++----
extensions/opencv/CaptureRTSPFrame.cpp | 37 +++--
extensions/opencv/CaptureRTSPFrame.h | 8 +-
extensions/opencv/MotionDetector.cpp | 30 ++---
extensions/opencv/MotionDetector.h | 4 +-
.../SourceInitiatedSubscriptionListener.cpp | 4 +-
.../SourceInitiatedSubscriptionListener.h | 4 +-
extensions/pcap/CMakeLists.txt | 11 +-
extensions/pcap/CapturePacket.cpp | 18 +--
extensions/pcap/CapturePacket.h | 4 +-
extensions/pdh/PerformanceDataMonitor.cpp | 36 ++---
extensions/pdh/PerformanceDataMonitor.h | 14 +-
extensions/procfs/processors/ProcFsMonitor.cpp | 24 ++--
extensions/procfs/processors/ProcFsMonitor.h | 5 +-
extensions/python/ExecutePythonProcessor.cpp | 4 +-
extensions/python/ExecutePythonProcessor.h | 4 +-
extensions/rocksdb-repos/tests/SwapTests.cpp | 8 +-
extensions/script/ExecuteScript.cpp | 13 +-
extensions/script/ExecuteScript.h | 8 +-
extensions/sensors/GetEnvironmentalSensors.cpp | 12 +-
extensions/sensors/GetEnvironmentalSensors.h | 4 +-
extensions/sensors/GetMovementSensors.cpp | 8 +-
extensions/sensors/GetMovementSensors.h | 2 +-
extensions/sensors/SensorBase.cpp | 4 +-
extensions/sensors/SensorBase.h | 4 +-
extensions/sftp/processors/FetchSFTP.cpp | 40 +++---
extensions/sftp/processors/FetchSFTP.h | 4 +-
extensions/sftp/processors/ListSFTP.cpp | 92 ++++++-------
extensions/sftp/processors/ListSFTP.h | 22 +--
extensions/sftp/processors/PutSFTP.cpp | 70 +++++-----
extensions/sftp/processors/PutSFTP.h | 6 +-
extensions/sftp/processors/SFTPProcessorBase.cpp | 38 +++---
extensions/sftp/processors/SFTPProcessorBase.h | 4 +-
extensions/smb/FetchSmb.cpp | 21 ++-
extensions/smb/FetchSmb.h | 4 +-
extensions/smb/ListSmb.cpp | 35 +++--
extensions/smb/ListSmb.h | 4 +-
extensions/smb/PutSmb.cpp | 29 ++--
extensions/smb/PutSmb.h | 4 +-
extensions/smb/SmbConnectionControllerService.cpp | 4 +-
extensions/splunk/PutSplunkHTTP.cpp | 61 ++++-----
extensions/splunk/PutSplunkHTTP.h | 12 +-
extensions/splunk/QuerySplunkIndexingStatus.cpp | 18 ++-
extensions/splunk/QuerySplunkIndexingStatus.h | 4 +-
extensions/splunk/SplunkHECProcessor.cpp | 11 +-
extensions/splunk/SplunkHECProcessor.h | 2 +-
extensions/sql/processors/SQLProcessor.cpp | 12 +-
extensions/sql/processors/SQLProcessor.h | 5 +-
.../processors/AppendHostInfo.cpp | 16 +--
.../processors/AppendHostInfo.h | 4 +-
.../processors/AttributesToJSON.cpp | 24 ++--
.../processors/AttributesToJSON.h | 4 +-
.../processors/DefragmentText.cpp | 57 ++++----
.../processors/DefragmentText.h | 14 +-
.../processors/ExecuteProcess.cpp | 18 ++-
.../processors/ExecuteProcess.h | 4 +-
.../standard-processors/processors/ExtractText.cpp | 8 +-
.../standard-processors/processors/ExtractText.h | 2 +-
.../standard-processors/processors/FetchFile.cpp | 36 +++--
.../standard-processors/processors/FetchFile.h | 4 +-
.../processors/GenerateFlowFile.cpp | 22 +--
.../processors/GenerateFlowFile.h | 4 +-
.../standard-processors/processors/GetFile.cpp | 28 ++--
.../standard-processors/processors/GetFile.h | 4 +-
.../standard-processors/processors/GetTCP.cpp | 26 ++--
extensions/standard-processors/processors/GetTCP.h | 10 +-
.../standard-processors/processors/HashContent.cpp | 18 +--
.../standard-processors/processors/HashContent.h | 4 +-
.../standard-processors/processors/ListFile.cpp | 32 ++---
.../standard-processors/processors/ListFile.h | 4 +-
.../processors/ListenSyslog.cpp | 12 +-
.../standard-processors/processors/ListenSyslog.h | 2 +-
.../standard-processors/processors/ListenTCP.cpp | 5 +-
.../standard-processors/processors/ListenTCP.h | 2 +-
.../standard-processors/processors/ListenUDP.cpp | 5 +-
.../standard-processors/processors/ListenUDP.h | 2 +-
.../processors/LogAttribute.cpp | 22 +--
.../standard-processors/processors/LogAttribute.h | 4 +-
.../processors/NetworkListenerProcessor.cpp | 6 +-
.../processors/NetworkListenerProcessor.h | 2 +-
.../standard-processors/processors/PutFile.cpp | 32 ++---
.../standard-processors/processors/PutFile.h | 8 +-
.../standard-processors/processors/PutTCP.cpp | 38 +++---
extensions/standard-processors/processors/PutTCP.h | 4 +-
.../standard-processors/processors/PutUDP.cpp | 28 ++--
extensions/standard-processors/processors/PutUDP.h | 4 +-
.../standard-processors/processors/ReplaceText.cpp | 47 +++----
.../standard-processors/processors/ReplaceText.h | 10 +-
.../processors/RetryFlowFile.cpp | 34 ++---
.../standard-processors/processors/RetryFlowFile.h | 8 +-
.../processors/RouteOnAttribute.cpp | 16 +--
.../processors/RouteOnAttribute.h | 2 +-
.../standard-processors/processors/RouteText.cpp | 36 +++--
.../standard-processors/processors/RouteText.h | 4 +-
.../standard-processors/processors/TailFile.cpp | 68 +++++-----
.../standard-processors/processors/TailFile.h | 29 ++--
.../processors/UpdateAttribute.cpp | 14 +-
.../processors/UpdateAttribute.h | 4 +-
.../tests/unit/DefragmentTextTests.cpp | 8 +-
.../tests/unit/ProcessorTests.cpp | 29 ++--
extensions/systemd/ConsumeJournald.cpp | 29 ++--
extensions/systemd/ConsumeJournald.h | 4 +-
extensions/test-processors/KamikazeProcessor.cpp | 8 +-
extensions/test-processors/KamikazeProcessor.h | 4 +-
extensions/usb-camera/GetUSBCamera.cpp | 26 ++--
extensions/usb-camera/GetUSBCamera.h | 8 +-
.../CollectorInitiatedSubscription.cpp | 76 +++++------
.../CollectorInitiatedSubscription.h | 10 +-
.../windows-event-log/ConsumeWindowsEventLog.cpp | 59 ++++----
.../windows-event-log/ConsumeWindowsEventLog.h | 9 +-
extensions/windows-event-log/TailEventLog.cpp | 18 +--
extensions/windows-event-log/TailEventLog.h | 4 +-
libminifi/include/ForwardingNode.h | 2 +-
libminifi/include/RemoteProcessorGroupPort.h | 4 +-
libminifi/include/core/ProcessSession.h | 2 +-
libminifi/include/core/Processor.h | 21 ++-
.../reporting/SiteToSiteProvenanceReportingTask.h | 6 +-
libminifi/include/sitetosite/RawSocketProtocol.h | 2 +-
libminifi/include/sitetosite/SiteToSiteClient.h | 10 +-
libminifi/src/ForwardingNode.cpp | 6 +-
libminifi/src/RemoteProcessorGroupPort.cpp | 28 ++--
libminifi/src/ThreadedSchedulingAgent.cpp | 10 +-
libminifi/src/core/Processor.cpp | 31 +----
.../SiteToSiteProvenanceReportingTask.cpp | 12 +-
libminifi/src/sitetosite/RawSocketProtocol.cpp | 12 +-
libminifi/src/sitetosite/SiteToSiteClient.cpp | 44 +++---
libminifi/test/ReadFromFlowFileTestProcessor.cpp | 13 +-
libminifi/test/ReadFromFlowFileTestProcessor.h | 6 +-
libminifi/test/StatefulProcessor.cpp | 7 +-
libminifi/test/StatefulProcessor.h | 4 +-
libminifi/test/TestBase.cpp | 2 +-
libminifi/test/WriteToFlowFileTestProcessor.cpp | 13 +-
libminifi/test/WriteToFlowFileTestProcessor.h | 4 +-
libminifi/test/flow-tests/CustomProcessors.h | 18 +--
.../test/persistence-tests/PersistenceTests.cpp | 12 +-
libminifi/test/unit/MockClasses.h | 10 +-
libminifi/test/unit/SchedulingAgentTests.cpp | 4 +-
nanofi/include/cxx/CallbackProcessor.h | 4 +-
nanofi/include/cxx/Instance.h | 4 +-
nanofi/src/cxx/CallbackProcessor.cpp | 8 +-
nanofi/src/cxx/Plan.cpp | 4 +-
229 files changed, 1789 insertions(+), 1956 deletions(-)
