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 9173029 MINIFICPP-1426 MSVC: Use /std:c++latest /permissive- and drop
VS 2017
new a09d158 MINIFICPP-1414 Create in-memory compressed logs
new 88e7429 MINIFICPP-1576 Allow build of all extensions in docker and
cleanup docker files
new e6ecb2e MINIFICPP-1580 Fix Tensorflow extension build
new 89f1713 MINIFICPP-1567 enable linter checks in extensions (part 3)
new dd42a04 MINIFICPP-1595 Pin pip package versions in requirements.txt
new 31fd099 MINIFICPP-1494 Allow InvokeHTTP GET requests without incoming
flowfile
The 6 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:
.dockerignore | 64 +++++-
.github/workflows/ci.yml | 2 +-
.gitignore | 7 -
CMakeLists.txt | 20 +-
PROCESSORS.md | 6 +-
cmake/DockerConfig.cmake | 18 +-
cmake/FindTensorFlow.cmake | 55 ++++--
conf/minifi-log.properties | 9 +
docker/DockerBuild.sh | 16 +-
docker/DockerVerify.sh | 8 +-
docker/Dockerfile | 208 +++++++++-----------
docker/requirements.txt | 6 +
extensions/http-curl/processors/InvokeHTTP.cpp | 7 +-
extensions/http-curl/processors/InvokeHTTP.h | 1 +
extensions/http-curl/tests/CMakeLists.txt | 8 +-
extensions/http-curl/tests/HTTPHandlers.h | 22 +++
.../http-curl/tests/HttpGetIntegrationTest.cpp | 139 -------------
extensions/http-curl/tests/VerifyInvokeHTTP.h | 131 +++++++++++++
.../http-curl/tests/VerifyInvokeHTTPGetTest.cpp | 63 ++++++
...keHTTPTest.cpp => VerifyInvokeHTTPPostTest.cpp} | 121 +-----------
extensions/libarchive/ArchiveLoader.h | 8 +-
extensions/libarchive/ArchiveMetadata.cpp | 215 ++++++++++-----------
extensions/libarchive/ArchiveMetadata.h | 100 +++++-----
extensions/libarchive/ArchiveTests.h | 7 +-
extensions/libarchive/BinFiles.cpp | 3 +-
extensions/libarchive/BinFiles.h | 14 +-
extensions/libarchive/CMakeLists.txt | 4 +-
extensions/libarchive/CompressContent.cpp | 3 -
extensions/libarchive/CompressContent.h | 23 +--
extensions/libarchive/FocusArchiveEntry.cpp | 6 +-
extensions/libarchive/FocusArchiveEntry.h | 8 +-
extensions/libarchive/ManipulateArchive.cpp | 11 +-
extensions/libarchive/ManipulateArchive.h | 17 +-
extensions/libarchive/MergeContent.cpp | 9 +-
extensions/libarchive/MergeContent.h | 13 +-
extensions/libarchive/UnfocusArchiveEntry.cpp | 6 +-
extensions/libarchive/UnfocusArchiveEntry.h | 7 +-
extensions/mqtt/CMakeLists.txt | 4 +-
extensions/mqtt/MQTTLoader.h | 8 +-
.../controllerservice/MQTTControllerService.cpp | 2 +-
.../mqtt/controllerservice/MQTTControllerService.h | 21 +-
extensions/mqtt/processors/AbstractMQTTProcessor.h | 16 +-
extensions/mqtt/processors/ConsumeMQTT.h | 8 +-
extensions/mqtt/processors/ConvertBase.h | 11 +-
extensions/mqtt/processors/ConvertHeartBeat.cpp | 2 +
extensions/mqtt/processors/ConvertHeartBeat.h | 21 +-
extensions/mqtt/processors/ConvertJSONAck.h | 17 +-
extensions/mqtt/processors/ConvertUpdate.cpp | 6 +
extensions/mqtt/processors/ConvertUpdate.h | 20 +-
extensions/mqtt/processors/PublishMQTT.h | 9 +-
extensions/mqtt/protocol/MQTTC2Protocol.cpp | 3 +-
extensions/mqtt/protocol/MQTTC2Protocol.h | 6 +-
extensions/opc/CMakeLists.txt | 1 +
extensions/opc/include/fetchopc.h | 20 +-
extensions/opc/include/opc.h | 19 +-
extensions/opc/include/opcbase.h | 10 +-
extensions/opc/include/putopc.h | 20 +-
extensions/opc/src/fetchopc.cpp | 4 +-
extensions/opc/src/opc.cpp | 148 +++++++-------
extensions/opencv/CMakeLists.txt | 3 +-
extensions/opencv/CaptureRTSPFrame.cpp | 20 +-
extensions/opencv/CaptureRTSPFrame.h | 16 +-
extensions/opencv/FrameIO.h | 73 +++----
extensions/opencv/MotionDetector.cpp | 5 +
extensions/opencv/MotionDetector.h | 26 +--
extensions/opencv/OpenCVLoader.h | 10 +-
extensions/opencv/tests/CaptureRTSPFrameTest.cpp | 2 +-
extensions/openwsman/CMakeLists.txt | 1 +
.../SourceInitiatedSubscriptionListener.h | 5 +-
extensions/pcap/CMakeLists.txt | 4 +-
extensions/pcap/CapturePacket.cpp | 13 +-
extensions/pcap/CapturePacket.h | 15 +-
extensions/pcap/PcapLoader.h | 8 +-
extensions/tensorflow/CMakeLists.txt | 3 +-
extensions/tensorflow/TFApplyGraph.cpp | 11 +-
extensions/tensorflow/TFApplyGraph.h | 2 +-
extensions/tensorflow/TFConvertImageToTensor.cpp | 6 +-
extensions/tensorflow/TFConvertImageToTensor.h | 2 +-
extensions/tensorflow/TFExtractTopLabels.cpp | 11 +-
extensions/tensorflow/TFExtractTopLabels.h | 2 +-
libminifi/CMakeLists.txt | 2 +-
libminifi/include/core/TypedValues.h | 88 +++------
.../include/core/logging/LoggerConfiguration.h | 53 +++--
.../{WindowsEventLogSink.h => LoggerProperties.h} | 57 +++---
.../ActiveCompressor.h} | 56 +++---
.../core/logging/internal/CompressionManager.h | 84 ++++++++
.../include/core/logging/internal/LogBuffer.h | 34 +++-
.../include/core/logging/internal/LogCompressor.h | 23 ++-
.../core/logging/internal/LogCompressorSink.h | 92 +++++++++
libminifi/include/io/BufferStream.h | 8 +
libminifi/include/io/ZlibStream.h | 13 +-
libminifi/include/io/validation.h | 1 +
libminifi/include/utils/Literals.h | 59 ++++++
libminifi/include/utils/StagingQueue.h | 178 +++++++++++++++++
libminifi/include/utils/ValueParser.h | 4 +
libminifi/src/core/TypedValues.cpp | 9 +
libminifi/src/core/logging/LoggerConfiguration.cpp | 55 ++++--
.../core/logging/internal/CompressionManager.cpp | 74 +++++++
.../src/core/logging/internal/LogCompressor.cpp | 24 ++-
.../core/logging/internal/LogCompressorSink.cpp | 81 ++++++++
libminifi/src/io/ZlibStream.cpp | 39 +++-
.../test/archive-tests/ManipulateArchiveTests.cpp | 4 +-
libminifi/test/resources/TestHTTPGet.yml | 20 +-
libminifi/test/resources/TestHTTPGetSecure.yml | 19 +-
.../test/resources/TestHTTPPostChunkedEncoding.yml | 14 +-
libminifi/test/tensorflow-tests/CMakeLists.txt | 2 +-
.../test/tensorflow-tests/TensorFlowTests.cpp | 10 +-
libminifi/test/unit/LoggerTests.cpp | 97 +++++++++-
libminifi/test/unit/StagingQueueTests.cpp | 121 ++++++++++++
thirdparty/openwsman/openwsman.patch | 39 ++++
thirdparty/pcap++/Pcap++/src/PcapLiveDevice.cpp | 9 +-
111 files changed, 2124 insertions(+), 1224 deletions(-)
create mode 100644 docker/requirements.txt
delete mode 100644 extensions/http-curl/tests/HttpGetIntegrationTest.cpp
create mode 100644 extensions/http-curl/tests/VerifyInvokeHTTP.h
create mode 100644 extensions/http-curl/tests/VerifyInvokeHTTPGetTest.cpp
rename extensions/http-curl/tests/{VerifyInvokeHTTPTest.cpp =>
VerifyInvokeHTTPPostTest.cpp} (52%)
copy libminifi/include/core/logging/{WindowsEventLogSink.h =>
LoggerProperties.h} (53%)
copy libminifi/include/core/logging/{WindowsEventLogSink.h =>
internal/ActiveCompressor.h} (55%)
create mode 100644 libminifi/include/core/logging/internal/CompressionManager.h
copy extensions/rocksdb-repos/database/ColumnHandle.h =>
libminifi/include/core/logging/internal/LogBuffer.h (62%)
copy extensions/rocksdb-repos/database/ColumnHandle.h =>
libminifi/include/core/logging/internal/LogCompressor.h (73%)
create mode 100644 libminifi/include/core/logging/internal/LogCompressorSink.h
create mode 100644 libminifi/include/utils/Literals.h
create mode 100644 libminifi/include/utils/StagingQueue.h
create mode 100644 libminifi/src/core/logging/internal/CompressionManager.cpp
copy extensions/rocksdb-repos/database/WriteBatch.cpp =>
libminifi/src/core/logging/internal/LogCompressor.cpp (64%)
create mode 100644 libminifi/src/core/logging/internal/LogCompressorSink.cpp
create mode 100644 libminifi/test/unit/StagingQueueTests.cpp
