Github user phrocker commented on the issue:
https://github.com/apache/nifi-minifi-cpp/pull/148
diff --git a/libminifi/src/processors/FocusArchiveEntry.cpp
b/libminifi/src/processors/FocusArchiveEntry.cpp
index c262217..42962a6 100644
--- a/libminifi/src/processors/FocusArchiveEntry.cpp
+++ b/libminifi/src/processors/FocusArchiveEntry.cpp
@@ -24,8 +24,6 @@
#include <string.h>
-#include <boost/filesystem.hpp>
-
#include <string>
#include <set>
@@ -154,11 +152,11 @@ void
FocusArchiveEntry::onTrigger(core::ProcessContext *context,
entryVal["entry_name"] = Json::Value(entryMetadata.entryName);
entryVal["entry_type"] = Json::Value(entryMetadata.entryType);
entryVal["entry_perm"] = Json::Value(entryMetadata.entryPerm);
- entryVal["entry_size"] = Json::Value(entryMetadata.entrySize);
+ entryVal["entry_size"] =
Json::Value((uint64_t)entryMetadata.entrySize);
entryVal["entry_uid"] = Json::Value(entryMetadata.entryUID);
entryVal["entry_gid"] = Json::Value(entryMetadata.entryGID);
- entryVal["entry_mtime"] = Json::Value(entryMetadata.entryMTime);
- entryVal["entry_mtime_nsec"] =
Json::Value(entryMetadata.entryMTimeNsec);
+ entryVal["entry_mtime"] =
Json::Value((uint64_t)entryMetadata.entryMTime);
+ entryVal["entry_mtime_nsec"] =
Json::Value((int64_t)entryMetadata.entryMTimeNsec);
if (entryMetadata.entryType == AE_IFREG) {
entryVal["stash_key"] = Json::Value(entryMetadata.stashKey);
@@ -221,7 +219,7 @@ int64_t
FocusArchiveEntry::ReadCallback::process(std::shared_ptr<io::BaseStream>
archive_read_support_filter_all(inputArchive);
// Read callback which reads from ifstream
- auto read = [] (archive * a, void *d, const void **buf) -> int64_t {
+ auto read = [] (struct archive * a, void *d, const void **buf) -> long {
auto data = static_cast<FocusArchiveEntryReadData *>(d);
*buf = data->buf;
int64_t read = 0;
@@ -241,7 +239,7 @@ int64_t
FocusArchiveEntry::ReadCallback::process(std::shared_ptr<io::BaseStream>
};
// Close callback for libarchive
- auto close = [] (archive *, void *) -> int {
+ auto close = [] (struct archive *, void *) -> int {
// Because we do not need to close the stream, do nothing & return
success
return 0;
};
@@ -249,7 +247,7 @@ int64_t
FocusArchiveEntry::ReadCallback::process(std::shared_ptr<io::BaseStream>
// Read each item in the archive
int res;
- if ((res = archive_read_open(inputArchive, &data, NULL, read, close))) {
+ if ((res = archive_read_open(inputArchive, &data, nullptr, read,
close))) {
logger_->log_error(
"FocusArchiveEntry can't open due to archive error: %s",
archive_error_string(inputArchive));
---
