You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by sz...@apache.org on 2021/12/13 14:51:31 UTC
[nifi-minifi-cpp] branch main updated (f9d8834 -> 83b16aa)
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 f9d8834 MINIFICPP-1694 Change unnecessary errors to warnings
add 83b16aa MINIFICPP-1338 Handle processor state persistence through the session
No new revisions were added by this update.
Summary of changes:
cmake/BuildTests.cmake | 7 +-
extensions/coap/tests/CoapIntegrationBase.h | 6 +-
extensions/http-curl/tests/C2ConfigEncryption.cpp | 4 +-
extensions/http-curl/tests/C2FailedUpdateTest.cpp | 4 +-
.../http-curl/tests/C2FetchFlowIfMissingTest.cpp | 4 +-
extensions/http-curl/tests/C2UpdateTest.cpp | 4 +-
extensions/http-curl/tests/HTTPIntegrationBase.h | 6 +-
extensions/http-curl/tests/HTTPSiteToSiteTests.cpp | 6 +-
.../http-curl/tests/HttpPostIntegrationTest.cpp | 4 +-
.../http-curl/tests/TimeoutHTTPSiteToSiteTests.cpp | 6 +-
extensions/http-curl/tests/VerifyInvokeHTTP.h | 4 +-
.../SourceInitiatedSubscriptionListener.cpp | 1 -
.../RocksDbPersistableKeyValueStoreService.cpp | 4 +-
extensions/sql/processors/QueryDatabaseTable.cpp | 1 -
.../UnorderedMapKeyValueStoreService.cpp | 1 -
.../controllers/UnorderedMapKeyValueStoreService.h | 8 +-
...UnorderedMapPersistableKeyValueStoreService.cpp | 7 +-
.../UnorderedMapPersistableKeyValueStoreService.h | 5 +-
.../standard-processors/processors/TailFile.h | 2 +-
.../tests/integration/TailFileTest.cpp | 4 +-
.../tests/unit/ProcessorTests.cpp | 4 +-
extensions/systemd/ConsumeJournald.cpp | 1 -
.../CollectorInitiatedSubscription.cpp | 1 -
.../windows-event-log/ConsumeWindowsEventLog.cpp | 5 +-
.../windows-event-log/ConsumeWindowsEventLog.h | 3 +-
.../windows-event-log/tests/BookmarkTests.cpp | 5 +-
.../AbstractCoreComponentStateManagerProvider.h | 29 +-
libminifi/include/core/CoreComponentState.h | 7 +-
libminifi/include/core/ProcessContext.h | 19 +-
libminifi/include/core/ProcessSession.h | 11 +-
libminifi/include/core/Processor.h | 2 +-
.../AbstractAutoPersistingKeyValueStoreService.cpp | 5 +-
.../AbstractCoreComponentStateManagerProvider.cpp | 204 +++++--
libminifi/src/core/ProcessSession.cpp | 25 +
libminifi/test/KamikazeProcessor.cpp | 2 -
libminifi/test/KamikazeProcessor.h | 2 -
libminifi/test/StatefulProcessor.cpp | 68 +++
.../StatefulProcessor.h} | 38 +-
libminifi/test/integration/IntegrationBase.h | 8 +-
.../integration/OnScheduleErrorHandlingTests.cpp | 2 +-
.../test/integration/ProvenanceReportingTest.cpp | 4 +-
.../integration/StateTransactionalityTests.cpp | 618 +++++++++++++++++++++
libminifi/test/resources/C2PauseResumeTest.yml | 3 +-
.../test/resources/C2VerifyHeartbeatAndStop.yml | 3 +-
.../resources/C2VerifyHeartbeatAndStopSecure.yml | 3 +-
libminifi/test/resources/C2VerifyServeResults.yml | 3 +-
.../test/resources/C2VerifyServeResultsSecure.yml | 3 +-
libminifi/test/resources/CoapC2VerifyServe.yml | 3 +-
libminifi/test/resources/TestBad.yml | 3 +-
.../resources/TestC2DescribeCoreComponentState.yml | 6 +-
libminifi/test/resources/TestEnvironmental.yml | 3 +-
libminifi/test/resources/TestGetTCPSecure.yml | 3 +-
.../test/resources/TestGetTCPSecureEmptyPass.yml | 3 +-
.../resources/TestGetTCPSecureWithFilePass.yml | 3 +-
.../test/resources/TestGetTCPSecureWithPass.yml | 3 +-
libminifi/test/resources/TestHTTPGet.yml | 3 +-
libminifi/test/resources/TestHTTPGetSecure.yml | 3 +-
libminifi/test/resources/TestHTTPPost.yml | 3 +-
libminifi/test/resources/TestNull.yml | 3 +-
libminifi/test/resources/TestPcap.yml | 3 +-
libminifi/test/resources/TestPcapLinux.yml | 3 +-
...duleRetry.yml => TestStateTransactionality.yml} | 10 +-
libminifi/test/resources/TestTailFile.yml | 2 +-
libminifi/test/resources/TestTailFileCron.yml | 2 +-
libminifi/test/resources/decrypted.config.yml | 3 +-
65 files changed, 1034 insertions(+), 194 deletions(-)
create mode 100644 libminifi/test/StatefulProcessor.cpp
copy libminifi/{include/serialization/FlowFileSerializer.h => test/StatefulProcessor.h} (54%)
create mode 100644 libminifi/test/integration/StateTransactionalityTests.cpp
copy libminifi/test/resources/{TestOnScheduleRetry.yml => TestStateTransactionality.yml} (84%)