Repository: nifi-minifi-cpp Updated Branches: refs/heads/MINIFI-227 [created] 0ff00a541
MINIFI-227: Provenance report 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/8cc6906f Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/8cc6906f Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/8cc6906f Branch: refs/heads/MINIFI-227 Commit: 8cc6906ff060b68585abef925cf13d0d0f376857 Parents: 1e1823a Author: Bin Qiu <[email protected]> Authored: Fri Mar 31 17:53:06 2017 -0700 Committer: Bin Qiu <[email protected]> Committed: Fri Mar 31 18:04:20 2017 -0700 ---------------------------------------------------------------------- libminifi/src/provenance/ProvenanceRepository.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/8cc6906f/libminifi/src/provenance/ProvenanceRepository.cpp ---------------------------------------------------------------------- diff --git a/libminifi/src/provenance/ProvenanceRepository.cpp b/libminifi/src/provenance/ProvenanceRepository.cpp index c4a41e0..d4448fd 100644 --- a/libminifi/src/provenance/ProvenanceRepository.cpp +++ b/libminifi/src/provenance/ProvenanceRepository.cpp @@ -36,7 +36,7 @@ void ProvenanceRepository::run() { uint64_t curTime = getTimeMillis(); uint64_t size = repoSize(); if (size >= purgeThreshold) { - // std::lock_guard<std::mutex> lock(mutex_); + std::lock_guard<std::mutex> lock(mutex_); std::vector<std::string> purgeList; leveldb::Iterator* it = db_->NewIterator(leveldb::ReadOptions()); for (it->SeekToFirst(); it->Valid(); it->Next()) {
