Repository: nifi-minifi-cpp Updated Branches: refs/heads/master e272487d0 -> 7f252d2a9
MINIFICPP-313: correctly implement unique flowfiles param for GenerateFlowFile This closes #240. Signed-off-by: Marc Parisi <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/commit/7f252d2a Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/7f252d2a Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/7f252d2a Branch: refs/heads/master Commit: 7f252d2a9f747420a58c929cb436b46b4b2321ba Parents: e272487 Author: Dustin Rodrigues <[email protected]> Authored: Fri Jan 12 15:47:37 2018 -0500 Committer: Marc Parisi <[email protected]> Committed: Tue Jan 16 12:49:18 2018 -0500 ---------------------------------------------------------------------- libminifi/include/processors/GenerateFlowFile.h | 2 +- libminifi/src/processors/GenerateFlowFile.cpp | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7f252d2a/libminifi/include/processors/GenerateFlowFile.h ---------------------------------------------------------------------- diff --git a/libminifi/include/processors/GenerateFlowFile.h b/libminifi/include/processors/GenerateFlowFile.h index 7551e88..660ff05 100644 --- a/libminifi/include/processors/GenerateFlowFile.h +++ b/libminifi/include/processors/GenerateFlowFile.h @@ -87,7 +87,7 @@ class GenerateFlowFile : public core::Processor { private: // Generated data char * _data; - // Size of the generate data + // Size of the generated data uint64_t _dataSize; }; http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7f252d2a/libminifi/src/processors/GenerateFlowFile.cpp ---------------------------------------------------------------------- diff --git a/libminifi/src/processors/GenerateFlowFile.cpp b/libminifi/src/processors/GenerateFlowFile.cpp index 32ca26b..82abe82 100644 --- a/libminifi/src/processors/GenerateFlowFile.cpp +++ b/libminifi/src/processors/GenerateFlowFile.cpp @@ -82,7 +82,7 @@ void GenerateFlowFile::onTrigger(core::ProcessContext *context, core::ProcessSes org::apache::nifi::minifi::utils::StringUtils::StringToBool(value, uniqueFlowFile); } - if (!uniqueFlowFile) { + if (uniqueFlowFile) { char *data; data = new char[fileSize]; if (!data) @@ -114,7 +114,7 @@ void GenerateFlowFile::onTrigger(core::ProcessContext *context, core::ProcessSes delete[] data; } else { if (!_data) { - // We have not created the unique data yet + // We have not created the data yet _data = new char[fileSize]; _dataSize = fileSize; char *current = _data;
