This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
from 828237117 MINIFICPP-1899 - Fix local Docker build failure
new 344c08cb0 MINIFICPP-1525 - Support flow file swapping in Connection
new ba15abcd4 MINIFICPP-1885 Mark extensions not in a static list as
disabled
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:
CMakeLists.txt | 29 ++-
extensions/rocksdb-repos/FlowFileLoader.cpp | 115 ++++++++++
extensions/rocksdb-repos/FlowFileLoader.h | 65 ++++++
extensions/rocksdb-repos/FlowFileRepository.cpp | 1 +
extensions/rocksdb-repos/FlowFileRepository.h | 25 ++-
.../tests/unit/YamlConnectionParserTest.cpp | 9 +
libminifi/include/Connection.h | 10 +
.../PublishedMetricProvider.h => SwapManager.h} | 29 +--
libminifi/include/core/FlowFile.h | 4 +
libminifi/include/core/Repository.h | 3 +-
libminifi/include/core/yaml/YamlConnectionParser.h | 1 +
libminifi/include/utils/FlowFileQueue.h | 72 ++++++-
.../include/utils/{ArrayUtils.h => MinMaxHeap.h} | 64 ++++--
libminifi/include/utils/MinifiConcurrentQueue.h | 11 +-
libminifi/include/utils/TestUtils.h | 18 ++
libminifi/include/utils/TimeUtil.h | 4 +
libminifi/src/Connection.cpp | 31 ++-
libminifi/src/core/FlowConfiguration.cpp | 9 +
libminifi/src/core/yaml/YamlConfiguration.cpp | 1 +
libminifi/src/core/yaml/YamlConnectionParser.cpp | 18 +-
libminifi/src/utils/FlowFileQueue.cpp | 235 +++++++++++++++++---
libminifi/src/utils/ThreadPool.cpp | 8 +-
libminifi/test/Utils.h | 17 ++
libminifi/test/rocksdb-tests/SwapTests.cpp | 137 ++++++++++++
libminifi/test/unit/FlowFileQueueSwapTests.cpp | 183 ++++++++++++++++
libminifi/test/unit/FlowFileQueueTests.cpp | 19 +-
libminifi/test/unit/ProvenanceTestHelper.h | 5 +-
libminifi/test/unit/SwapTestController.h | 240 +++++++++++++++++++++
win_build_vs.bat | 38 +++-
29 files changed, 1316 insertions(+), 85 deletions(-)
create mode 100644 extensions/rocksdb-repos/FlowFileLoader.cpp
create mode 100644 extensions/rocksdb-repos/FlowFileLoader.h
copy libminifi/include/{core/state/PublishedMetricProvider.h => SwapManager.h}
(61%)
copy libminifi/include/utils/{ArrayUtils.h => MinMaxHeap.h} (53%)
create mode 100644 libminifi/test/rocksdb-tests/SwapTests.cpp
create mode 100644 libminifi/test/unit/FlowFileQueueSwapTests.cpp
create mode 100644 libminifi/test/unit/SwapTestController.h