This is an automated email from the ASF dual-hosted git repository. lordgamez pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
commit c9a16273a9e06872490137e62858db22722cd97f Author: Martin Zink <[email protected]> AuthorDate: Tue Jun 21 15:28:09 2022 +0200 MINIFICPP-1761 Enable multithreading in PutGCSObject, DeleteGCSObject, FetchGCSObject Signed-off-by: Gabor Gyimesi <[email protected]> This closes #1368 --- extensions/gcp/processors/DeleteGCSObject.h | 2 +- extensions/gcp/processors/FetchGCSObject.h | 2 +- extensions/gcp/processors/PutGCSObject.h | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/extensions/gcp/processors/DeleteGCSObject.h b/extensions/gcp/processors/DeleteGCSObject.h index ae263a978..954db32a9 100644 --- a/extensions/gcp/processors/DeleteGCSObject.h +++ b/extensions/gcp/processors/DeleteGCSObject.h @@ -55,7 +55,7 @@ class DeleteGCSObject : public GCSProcessor { EXTENSIONAPI static constexpr bool SupportsDynamicProperties = false; EXTENSIONAPI static constexpr bool SupportsDynamicRelationships = false; EXTENSIONAPI static constexpr core::annotation::Input InputRequirement = core::annotation::Input::INPUT_REQUIRED; - EXTENSIONAPI static constexpr bool IsSingleThreaded = true; + EXTENSIONAPI static constexpr bool IsSingleThreaded = false; ADD_COMMON_VIRTUAL_FUNCTIONS_FOR_PROCESSORS diff --git a/extensions/gcp/processors/FetchGCSObject.h b/extensions/gcp/processors/FetchGCSObject.h index 74a5e5ea1..c56892f5b 100644 --- a/extensions/gcp/processors/FetchGCSObject.h +++ b/extensions/gcp/processors/FetchGCSObject.h @@ -56,7 +56,7 @@ class FetchGCSObject : public GCSProcessor { EXTENSIONAPI static constexpr bool SupportsDynamicProperties = false; EXTENSIONAPI static constexpr bool SupportsDynamicRelationships = false; EXTENSIONAPI static constexpr core::annotation::Input InputRequirement = core::annotation::Input::INPUT_REQUIRED; - EXTENSIONAPI static constexpr bool IsSingleThreaded = true; + EXTENSIONAPI static constexpr bool IsSingleThreaded = false; ADD_COMMON_VIRTUAL_FUNCTIONS_FOR_PROCESSORS diff --git a/extensions/gcp/processors/PutGCSObject.h b/extensions/gcp/processors/PutGCSObject.h index 6611932cf..f17884cac 100644 --- a/extensions/gcp/processors/PutGCSObject.h +++ b/extensions/gcp/processors/PutGCSObject.h @@ -74,7 +74,7 @@ class PutGCSObject : public GCSProcessor { EXTENSIONAPI static constexpr bool SupportsDynamicProperties = false; EXTENSIONAPI static constexpr bool SupportsDynamicRelationships = false; EXTENSIONAPI static constexpr core::annotation::Input InputRequirement = core::annotation::Input::INPUT_REQUIRED; - EXTENSIONAPI static constexpr bool IsSingleThreaded = true; + EXTENSIONAPI static constexpr bool IsSingleThreaded = false; ADD_COMMON_VIRTUAL_FUNCTIONS_FOR_PROCESSORS
