nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sza...@apache.org
Subject [nifi-minifi-cpp] branch main updated (9173029 -> 31fd099)
Date Wed, 23 Jun 2021 16:55:48 GMT
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

Mime
View raw message