MINIFI-227: Provenance report (make_shared)
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/257bb8fe Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/257bb8fe Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/257bb8fe Branch: refs/heads/MINIFI-227 Commit: 257bb8fe69165145c672929376b2599e2cf9ce1d Parents: 770932a Author: Bin Qiu <[email protected]> Authored: Fri Apr 7 09:17:31 2017 -0700 Committer: Bin Qiu <[email protected]> Committed: Fri Apr 7 09:17:31 2017 -0700 ---------------------------------------------------------------------- libminifi/include/provenance/ProvenanceRepository.h | 2 +- libminifi/src/core/Processor.cpp | 6 ++---- 2 files changed, 3 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/257bb8fe/libminifi/include/provenance/ProvenanceRepository.h ---------------------------------------------------------------------- diff --git a/libminifi/include/provenance/ProvenanceRepository.h b/libminifi/include/provenance/ProvenanceRepository.h index d7154d2..b96021c 100644 --- a/libminifi/include/provenance/ProvenanceRepository.h +++ b/libminifi/include/provenance/ProvenanceRepository.h @@ -159,7 +159,7 @@ class ProvenanceRepository : public core::Repository, leveldb::Iterator* it = db_->NewIterator( leveldb::ReadOptions()); for (it->SeekToFirst(); it->Valid(); it->Next()) { - std::shared_ptr<ProvenanceEventRecord> eventRead (new ProvenanceEventRecord()); + std::shared_ptr<ProvenanceEventRecord> eventRead = std::make_shared<ProvenanceEventRecord>(); std::string key = it->key().ToString(); if (records.size() >= maxSize) break; http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/257bb8fe/libminifi/src/core/Processor.cpp ---------------------------------------------------------------------- diff --git a/libminifi/src/core/Processor.cpp b/libminifi/src/core/Processor.cpp index 74636f7..9d44d39 100644 --- a/libminifi/src/core/Processor.cpp +++ b/libminifi/src/core/Processor.cpp @@ -201,8 +201,7 @@ std::shared_ptr<Site2SiteClientProtocol> Processor::obtainSite2SiteProtocol( if (!protocols_created_) { for (int i = 0; i < this->max_concurrent_tasks_; i++) { // create the protocol pool based on max threads allowed - std::shared_ptr<Site2SiteClientProtocol> protocol( - new Site2SiteClientProtocol(0)); + std::shared_ptr<Site2SiteClientProtocol> protocol = std::make_shared<Site2SiteClientProtocol>(nullptr); protocols_created_ = true; protocol->setPortId(portId); std::unique_ptr<org::apache::nifi::minifi::io::DataStream> str = @@ -222,8 +221,7 @@ std::shared_ptr<Site2SiteClientProtocol> Processor::obtainSite2SiteProtocol( return return_pointer; } else { // create the protocol on demand if we exceed the pool - std::shared_ptr<Site2SiteClientProtocol> protocol( - new Site2SiteClientProtocol(0)); + std::shared_ptr<Site2SiteClientProtocol> protocol = std::make_shared<Site2SiteClientProtocol>(nullptr); protocol->setPortId(portId); std::unique_ptr<org::apache::nifi::minifi::io::DataStream> str = std::unique_ptr < org::apache::nifi::minifi::io::DataStream
