Repository: nifi-minifi-cpp Updated Branches: refs/heads/master 6867106d3 -> 46158ceac
MINIFI-357 fixing PutFile bug that caused all writes to fail This closes #121. 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/46158cea Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/46158cea Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/46158cea Branch: refs/heads/master Commit: 46158ceac2c192d266ef3b3e7f39d4f45599c87f Parents: 6867106 Author: Dustin Rodrigues <[email protected]> Authored: Sun Jul 30 00:44:44 2017 -0700 Committer: Marc Parisi <[email protected]> Committed: Mon Jul 31 08:36:18 2017 -0400 ---------------------------------------------------------------------- libminifi/src/processors/PutFile.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/46158cea/libminifi/src/processors/PutFile.cpp ---------------------------------------------------------------------- diff --git a/libminifi/src/processors/PutFile.cpp b/libminifi/src/processors/PutFile.cpp index b425ae9..824c7d1 100644 --- a/libminifi/src/processors/PutFile.cpp +++ b/libminifi/src/processors/PutFile.cpp @@ -164,8 +164,8 @@ int64_t PutFile::ReadCallback::process(std::shared_ptr<io::BaseStream> stream) { _tmpFileOs.write(reinterpret_cast<char*>(buffer), read); size += read; } while (size < stream->getSize()); - return size; _writeSucceeded = true; + return size; } // Renames tmp file to final destination
