From commits-return-44815-archive-asf-public=cust-asf.ponee.io@nifi.apache.org Wed Jun 23 16:56:25 2021 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-he-de.apache.org (mxout1-he-de.apache.org [95.216.194.37]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id AF405180636 for ; Wed, 23 Jun 2021 18:56:25 +0200 (CEST) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-he-de.apache.org (ASF Mail Server at mxout1-he-de.apache.org) with SMTP id A33E262224 for ; Wed, 23 Jun 2021 16:56:00 +0000 (UTC) Received: (qmail 29698 invoked by uid 500); 23 Jun 2021 16:55:49 -0000 Mailing-List: contact commits-help@nifi.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@nifi.apache.org Delivered-To: mailing list commits@nifi.apache.org Received: (qmail 29642 invoked by uid 99); 23 Jun 2021 16:55:49 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 23 Jun 2021 16:55:49 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 2B47F821E0; Wed, 23 Jun 2021 16:55:49 +0000 (UTC) Date: Wed, 23 Jun 2021 16:55:48 +0000 To: "commits@nifi.apache.org" Subject: [nifi-minifi-cpp] branch main updated (9173029 -> 31fd099) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <162446734879.17647.16161136135857412236@gitbox.apache.org> From: szaszm@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: nifi-minifi-cpp X-Git-Refname: refs/heads/main X-Git-Reftype: branch X-Git-Oldrev: 9173029cbc0c2d0ea909111ac273a47b3f2a3cb3 X-Git-Newrev: 31fd0999ac656f28600a952d0b5aad66365d816b X-Git-NotificationType: ref_changed X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated 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