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%)