You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ph...@apache.org on 2018/01/16 17:49:29 UTC
nifi-minifi-cpp git commit: MINIFICPP-313: correctly implement unique
flowfiles param for GenerateFlowFile
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 <ph...@apache.org>
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 <du...@gmail.com>
Authored: Fri Jan 12 15:47:37 2018 -0500
Committer: Marc Parisi <ph...@apache.org>
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;