This is an automated email from the ASF dual-hosted git repository.
szaszm pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
from d93b84e5a MINIFICPP-1945 Fix memory leak in ConsumeWindowsEventLog
new 0014de517 MINIFICPP-1938 Enable parallel onTrigger calls for Azure and
AWS processors
new 7ab10859f MINIFICPP-1648 Input/OutputStreamCallback should use
Input/OutputStream instead of BaseStream
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:
controller/MiNiFiController.cpp | 1 -
extensions/aws/processors/DeleteS3Object.h | 2 +-
extensions/aws/processors/FetchS3Object.cpp | 16 ++-----
extensions/aws/processors/FetchS3Object.h | 2 +-
extensions/aws/processors/PutS3Object.h | 4 +-
extensions/aws/s3/S3Wrapper.cpp | 6 +--
extensions/aws/s3/S3Wrapper.h | 7 ++-
.../azure/processors/DeleteAzureBlobStorage.h | 2 +-
.../azure/processors/DeleteAzureDataLakeStorage.h | 2 +-
.../azure/processors/FetchAzureBlobStorage.cpp | 2 +-
.../azure/processors/FetchAzureDataLakeStorage.cpp | 2 +-
.../azure/processors/FetchAzureDataLakeStorage.h | 2 +-
extensions/azure/processors/PutAzureBlobStorage.h | 2 +-
.../azure/processors/PutAzureDataLakeStorage.cpp | 2 +-
.../azure/processors/PutAzureDataLakeStorage.h | 4 +-
extensions/azure/storage/AzureBlobStorage.cpp | 2 +-
extensions/azure/storage/AzureBlobStorage.h | 2 +-
.../azure/storage/AzureBlobStorageClient.cpp | 40 +++++++----------
extensions/azure/storage/AzureBlobStorageClient.h | 5 +--
extensions/azure/storage/AzureDataLakeStorage.cpp | 2 +-
extensions/azure/storage/AzureDataLakeStorage.h | 2 +-
.../azure/storage/AzureDataLakeStorageClient.cpp | 26 ++++-------
.../azure/storage/AzureDataLakeStorageClient.h | 13 +++---
extensions/coap/protocols/CoapC2Protocol.cpp | 6 +--
extensions/coap/protocols/CoapC2Protocol.h | 14 +++---
extensions/coap/tests/CoapC2VerifyHeartbeat.cpp | 1 -
extensions/gcp/processors/FetchGCSObject.cpp | 2 +-
extensions/gcp/processors/PutGCSObject.cpp | 2 +-
extensions/http-curl/client/HTTPCallback.h | 2 +-
extensions/http-curl/sitetosite/HTTPProtocol.cpp | 2 +-
extensions/http-curl/sitetosite/HTTPProtocol.h | 2 +-
extensions/http-curl/tests/CivetStream.h | 1 -
extensions/http-curl/tests/HTTPHandlers.h | 2 +-
.../http-curl/tests/unit/InvokeHTTPTests.cpp | 1 -
extensions/jni/jvm/JniProcessSession.h | 1 -
extensions/jni/jvm/JniReferenceObjects.h | 4 +-
extensions/libarchive/CompressContent.h | 4 +-
extensions/libarchive/FocusArchiveEntry.cpp | 6 +--
extensions/libarchive/FocusArchiveEntry.h | 2 +-
extensions/libarchive/MergeContent.h | 6 +--
extensions/libarchive/UnfocusArchiveEntry.cpp | 4 +-
extensions/libarchive/UnfocusArchiveEntry.h | 2 +-
extensions/librdkafka/PublishKafka.cpp | 4 +-
extensions/mqtt/processors/ConsumeMQTT.cpp | 2 +-
extensions/mqtt/processors/PublishMQTT.cpp | 2 +-
extensions/mqtt/processors/PublishMQTT.h | 2 +-
extensions/opencv/CaptureRTSPFrame.cpp | 14 ++----
extensions/opencv/MotionDetector.cpp | 2 +-
.../lua/{LuaBaseStream.cpp => LuaInputStream.cpp} | 22 +++-------
.../lua/{LuaBaseStream.h => LuaInputStream.h} | 27 +++---------
.../script/lua/LuaOutputStream.cpp | 31 ++++++--------
.../lua/{LuaBaseStream.h => LuaOutputStream.h} | 26 +++--------
extensions/script/lua/LuaProcessSession.cpp | 22 +++-------
extensions/script/lua/LuaProcessSession.h | 17 +++-----
extensions/script/lua/LuaScriptEngine.cpp | 10 +++--
.../python/{PyBaseStream.cpp => PyInputStream.cpp} | 12 ++----
.../python/{PyBaseStream.h => PyInputStream.h} | 9 ++--
.../python/{PyBaseStream.h => PyOutputStream.cpp} | 27 +++++-------
.../python/{PyBaseStream.h => PyOutputStream.h} | 10 ++---
extensions/script/python/PyProcessSession.cpp | 8 ++--
extensions/script/python/PyProcessSession.h | 3 +-
extensions/script/python/PythonBindings.h | 13 +++---
extensions/sftp/client/SFTPClient.cpp | 24 +++++------
extensions/sftp/client/SFTPClient.h | 6 +--
extensions/sftp/processors/FetchSFTP.cpp | 7 +--
extensions/sftp/processors/PutSFTP.cpp | 2 +-
.../processors/ExecuteProcess.h | 1 -
.../standard-processors/processors/ExtractText.cpp | 2 +-
.../standard-processors/processors/ExtractText.h | 2 +-
.../standard-processors/processors/HashContent.cpp | 14 ++----
.../standard-processors/processors/HashContent.h | 14 +++---
.../standard-processors/processors/PutFile.cpp | 4 +-
.../standard-processors/processors/PutFile.h | 21 +++------
.../standard-processors/processors/RouteText.cpp | 2 +-
.../standard-processors/processors/TailFile.cpp | 8 ++--
extensions/tensorflow/TFApplyGraph.cpp | 6 +--
extensions/tensorflow/TFApplyGraph.h | 8 ++--
extensions/tensorflow/TFConvertImageToTensor.cpp | 4 +-
extensions/tensorflow/TFConvertImageToTensor.h | 6 ++-
extensions/tensorflow/TFExtractTopLabels.cpp | 4 +-
extensions/tensorflow/TFExtractTopLabels.h | 6 ++-
extensions/usb-camera/GetUSBCamera.cpp | 2 +-
extensions/usb-camera/GetUSBCamera.h | 2 +-
libminifi/include/FlowFileRecord.h | 1 -
libminifi/include/c2/PayloadSerializer.h | 15 ++++---
libminifi/include/core/ContentRepository.h | 1 -
libminifi/include/core/ProcessSession.h | 6 +--
.../include/core/ProcessSessionReadCallback.h | 23 +++-------
libminifi/include/io/BaseStream.h | 12 +-----
libminifi/include/io/CRCStream.h | 3 +-
libminifi/include/io/StreamCallback.h | 9 ++--
libminifi/include/io/StreamPipe.h | 7 +--
libminifi/include/io/StreamSlice.h | 12 +++---
libminifi/include/io/ZlibStream.h | 2 +-
libminifi/include/sitetosite/SiteToSiteClient.h | 19 ++------
libminifi/include/utils/ByteArrayCallback.h | 20 ++-------
libminifi/include/utils/FileReaderCallback.h | 14 ++----
libminifi/include/utils/JsonCallback.h | 6 +--
.../utils/LineByLineInputOutputStreamCallback.h | 5 ++-
libminifi/src/core/ProcessSession.cpp | 14 +++---
libminifi/src/core/ProcessSessionReadCallback.cpp | 21 +++------
libminifi/src/io/BaseStream.cpp | 33 --------------
libminifi/src/io/StreamSlice.cpp | 2 +-
libminifi/src/sitetosite/SiteToSiteClient.cpp | 6 +--
libminifi/src/utils/ByteArrayCallback.cpp | 29 ++-----------
libminifi/src/utils/FileReaderCallback.cpp | 14 ++----
.../utils/LineByLineInputOutputStreamCallback.cpp | 2 +-
.../test/archive-tests/CompressContentTests.cpp | 2 +-
libminifi/test/archive-tests/MergeFileTests.cpp | 4 +-
.../test/rocksdb-tests/ContentSessionTests.cpp | 4 +-
libminifi/test/rocksdb-tests/SwapTests.cpp | 2 +-
libminifi/test/unit/CRCTests.cpp | 22 +++++-----
.../test/unit/ContentRepositoryDependentTests.h | 2 +-
libminifi/test/unit/FlowFileSerializationTests.cpp | 1 -
libminifi/test/unit/SerializationTests.cpp | 1 -
libminifi/test/unit/StreamTests.cpp | 8 ++--
nanofi/include/cxx/CallbackProcessor.h | 1 -
nanofi/include/cxx/ReflexiveSession.h | 50 +++++++---------------
118 files changed, 360 insertions(+), 633 deletions(-)
rename extensions/script/lua/{LuaBaseStream.cpp => LuaInputStream.cpp} (77%)
copy extensions/script/lua/{LuaBaseStream.h => LuaInputStream.h} (67%)
copy libminifi/src/core/repository/VolatileRepository.cpp =>
extensions/script/lua/LuaOutputStream.cpp (68%)
rename extensions/script/lua/{LuaBaseStream.h => LuaOutputStream.h} (67%)
rename extensions/script/python/{PyBaseStream.cpp => PyInputStream.cpp} (80%)
copy extensions/script/python/{PyBaseStream.h => PyInputStream.h} (84%)
copy extensions/script/python/{PyBaseStream.h => PyOutputStream.cpp} (72%)
rename extensions/script/python/{PyBaseStream.h => PyOutputStream.h} (83%)
delete mode 100644 libminifi/src/io/BaseStream.cpp
