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 922b6e7 MINIFICPP-1567 enable linter checks in extensions (part 2)
new 13a43e6 MINIFICPP-1507 convert InputStream::read to size_t
new 5a3f546 MINIFICPP-1507 convert OutputStream::write to size_t
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/Controller.h | 14 +-
extensions/aws/processors/PutS3Object.h | 11 +-
extensions/aws/s3/S3Wrapper.cpp | 20 +-
extensions/bustache/ApplyTemplate.cpp | 3 +-
extensions/civetweb/processors/ListenHTTP.cpp | 23 +-
extensions/civetweb/processors/ListenHTTP.h | 13 +-
extensions/coap/protocols/CoapC2Protocol.h | 2 +-
extensions/http-curl/client/HTTPCallback.h | 2 +-
extensions/http-curl/client/HTTPStream.cpp | 42 +--
extensions/http-curl/client/HTTPStream.h | 17 +-
extensions/http-curl/tests/CivetStream.h | 8 +-
extensions/http-curl/tests/HTTPHandlers.h | 52 ++-
.../http-curl/tests/unit/InvokeHTTPTests.cpp | 3 +-
extensions/jni/jvm/JniReferenceObjects.h | 7 +-
extensions/libarchive/CompressContent.h | 98 +++--
extensions/libarchive/FocusArchiveEntry.cpp | 9 +-
extensions/libarchive/MergeContent.h | 67 ++--
extensions/libarchive/UnfocusArchiveEntry.cpp | 6 +-
extensions/librdkafka/ConsumeKafka.cpp | 9 +-
extensions/librdkafka/PublishKafka.cpp | 7 +-
extensions/mqtt/processors/ConsumeMQTT.h | 24 +-
extensions/mqtt/processors/ConvertJSONAck.h | 13 +-
extensions/mqtt/processors/ConvertUpdate.cpp | 2 +-
extensions/mqtt/processors/PublishMQTT.h | 23 +-
extensions/opc/include/fetchopc.h | 4 +-
extensions/opc/src/putopc.cpp | 15 +-
extensions/opencv/CaptureRTSPFrame.h | 15 +-
extensions/opencv/FrameIO.h | 7 +-
.../SourceInitiatedSubscriptionListener.cpp | 3 +-
.../rocksdb-repos/DatabaseContentRepository.cpp | 8 +-
extensions/rocksdb-repos/RocksDbStream.cpp | 81 ++---
extensions/rocksdb-repos/RocksDbStream.h | 6 +-
extensions/script/lua/LuaBaseStream.cpp | 17 +-
extensions/script/python/PyBaseStream.cpp | 13 +-
extensions/script/python/PyBaseStream.h | 2 +-
extensions/sensors/SensorBase.h | 23 +-
extensions/sftp/client/SFTPClient.cpp | 24 +-
.../processors/ExecuteProcess.cpp | 17 +-
.../processors/ExecuteProcess.h | 10 +-
.../standard-processors/processors/ExtractText.cpp | 27 +-
.../processors/GenerateFlowFile.cpp | 2 +-
.../processors/GenerateFlowFile.h | 22 +-
.../standard-processors/processors/GetTCP.cpp | 12 +-
extensions/standard-processors/processors/GetTCP.h | 3 +-
.../standard-processors/processors/ListenSyslog.h | 15 +-
.../standard-processors/processors/LogAttribute.h | 20 +-
.../standard-processors/processors/PutFile.cpp | 25 +-
.../standard-processors/processors/PutFile.h | 2 +-
.../standard-processors/processors/TailFile.cpp | 17 +-
.../tests/integration/SecureSocketGetTCPTest.cpp | 20 +-
.../TLSServerSocketSupportedProtocolsTest.cpp | 16 +-
.../standard-processors/tests/unit/GetTCPTests.cpp | 6 +-
extensions/tensorflow/TFApplyGraph.cpp | 20 +-
extensions/tensorflow/TFConvertImageToTensor.cpp | 6 +-
extensions/tensorflow/TFExtractTopLabels.cpp | 19 +-
extensions/usb-camera/CMakeLists.txt | 2 +-
extensions/usb-camera/GetUSBCamera.cpp | 10 +-
.../CollectorInitiatedSubscription.cpp | 9 +-
.../windows-event-log/ConsumeWindowsEventLog.cpp | 3 +-
libminifi/include/io/AtomicEntryStream.h | 39 +-
libminifi/include/io/BufferStream.h | 10 +-
libminifi/include/io/CRCStream.h | 12 +-
libminifi/include/io/ClientSocket.h | 6 +-
libminifi/include/io/DescriptorStream.h | 6 +-
libminifi/include/io/FileStream.h | 6 +-
libminifi/include/io/InputStream.h | 38 +-
libminifi/include/io/OutputStream.h | 30 +-
libminifi/include/io/Stream.h | 9 +-
libminifi/include/io/StreamPipe.h | 18 +-
libminifi/include/io/ZlibStream.h | 4 +-
libminifi/include/io/tls/SecureDescriptorStream.h | 6 +-
libminifi/include/io/tls/TLSServerSocket.h | 8 +-
libminifi/include/io/tls/TLSSocket.h | 8 +-
libminifi/include/provenance/Provenance.h | 16 +-
.../include/serialization/FlowFileV3Serializer.h | 4 +-
libminifi/include/sitetosite/Peer.h | 4 +-
libminifi/include/sitetosite/SiteToSiteClient.h | 95 ++---
libminifi/include/utils/ByteArrayCallback.h | 7 +-
libminifi/include/utils/Enum.h | 4 +-
libminifi/include/utils/GeneralUtils.h | 2 +
libminifi/src/FlowControlProtocol.cpp | 22 +-
libminifi/src/FlowFileRecord.cpp | 189 ++++++----
libminifi/src/c2/ControllerSocketProtocol.cpp | 87 ++---
libminifi/src/core/ContentSession.cpp | 8 +-
libminifi/src/core/ProcessSession.cpp | 16 +-
libminifi/src/core/ProcessSessionReadCallback.cpp | 13 +-
libminifi/src/io/BufferStream.cpp | 18 +-
libminifi/src/io/ClientSocket.cpp | 40 +-
libminifi/src/io/DescriptorStream.cpp | 37 +-
libminifi/src/io/FileStream.cpp | 73 ++--
libminifi/src/io/InputStream.cpp | 58 ++-
libminifi/src/io/OutputStream.cpp | 24 +-
libminifi/src/io/ZlibStream.cpp | 26 +-
libminifi/src/io/tls/SecureDescriptorStream.cpp | 78 ++--
libminifi/src/io/tls/TLSServerSocket.cpp | 79 ++--
libminifi/src/io/tls/TLSSocket.cpp | 62 ++--
libminifi/src/provenance/Provenance.cpp | 402 ++++++++++++---------
.../src/serialization/FlowFileV3Serializer.cpp | 103 +++---
libminifi/src/sitetosite/Peer.cpp | 7 +-
libminifi/src/sitetosite/RawSocketProtocol.cpp | 211 ++++++-----
libminifi/src/sitetosite/SiteToSiteClient.cpp | 173 +++++----
libminifi/src/utils/ByteArrayCallback.cpp | 12 +-
libminifi/test/BufferReader.h | 12 +-
.../test/archive-tests/CompressContentTests.cpp | 45 ++-
libminifi/test/archive-tests/MergeFileTests.cpp | 13 +-
.../test/persistence-tests/PersistenceTests.cpp | 2 +-
.../test/rocksdb-tests/ContentSessionTests.cpp | 13 +-
.../rocksdb-tests/DBContentRepositoryTests.cpp | 12 +-
.../test/rocksdb-tests/RocksDBStreamTests.cpp | 12 +-
libminifi/test/sql-tests/SQLTestPlan.h | 2 +-
libminifi/test/unit/CRCTests.cpp | 14 +-
libminifi/test/unit/FileStreamTests.cpp | 38 +-
libminifi/test/unit/FlowFileSerializationTests.cpp | 4 +-
libminifi/test/unit/SiteToSiteHelper.h | 6 +-
libminifi/test/unit/SocketTests.cpp | 59 +--
libminifi/test/unit/ZlibStreamTests.cpp | 31 +-
nanofi/src/api/nanofi.cpp | 8 +-
nanofi/tests/CSite2SiteTests.cpp | 13 +-
118 files changed, 1687 insertions(+), 1643 deletions(-)
