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 <benqiu2...@gmail.com>
Authored: Fri Mar 31 17:53:06 2017 -0700
Committer: Bin Qiu <benqiu2...@gmail.com>
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()) {

Reply via email to