From 72f096bfca062911c4b3d4e89e1f475cd0533c1d Mon Sep 17 00:00:00 2001 From: Xu Peng Date: Sun, 5 May 2019 12:55:42 +0800 Subject: [PATCH] refactor(db): typedef ptr for memvectors Former-commit-id: 92289614937b7803fc41bf5cb7d50f468192aaa4 --- cpp/src/db/DBImpl.h | 4 ++-- cpp/src/db/MemManager.cpp | 6 +++--- cpp/src/db/MemManager.h | 11 ++++++----- 3 files changed, 11 insertions(+), 10 deletions(-) diff --git a/cpp/src/db/DBImpl.h b/cpp/src/db/DBImpl.h index d23269836e..9b17fa0251 100644 --- a/cpp/src/db/DBImpl.h +++ b/cpp/src/db/DBImpl.h @@ -22,6 +22,7 @@ template class DBImpl : public DB { public: typedef typename meta::Meta::Ptr MetaPtr; + typedef typename MemManager::Ptr MemManagerPtr; DBImpl(const Options& options); @@ -49,7 +50,6 @@ public: virtual ~DBImpl(); private: - typedef MemManager MemManagerT; void background_build_index(); Status build_index(const meta::GroupFileSchema&); @@ -81,7 +81,7 @@ private: std::condition_variable bg_build_index_finish_signal_; MetaPtr _pMeta; - std::shared_ptr _pMemMgr; + MemManagerPtr _pMemMgr; }; // DBImpl diff --git a/cpp/src/db/MemManager.cpp b/cpp/src/db/MemManager.cpp index cf557b41df..de076d825e 100644 --- a/cpp/src/db/MemManager.cpp +++ b/cpp/src/db/MemManager.cpp @@ -72,7 +72,7 @@ MemVectors::~MemVectors() { */ template -typename MemManager::VectorsPtr MemManager::get_mem_by_group( +typename MemManager::MemVectorsPtr MemManager::get_mem_by_group( const std::string& group_id) { auto memIt = _memMap.find(group_id); if (memIt != _memMap.end()) { @@ -86,7 +86,7 @@ typename MemManager::VectorsPtr MemManager::get_mem_by_group( return nullptr; } - _memMap[group_id] = VectorsPtr(new MemVectors(_pMeta, group_file, options_)); + _memMap[group_id] = MemVectorsPtr(new MemVectors(_pMeta, group_file, options_)); return _memMap[group_id]; } @@ -104,7 +104,7 @@ Status MemManager::add_vectors_no_lock(const std::string& group_id, size_t n, const float* vectors, IDNumbers& vector_ids) { - VectorsPtr mem = get_mem_by_group(group_id); + MemVectorsPtr mem = get_mem_by_group(group_id); if (mem == nullptr) { return Status::NotFound("Group " + group_id + " not found!"); } diff --git a/cpp/src/db/MemManager.h b/cpp/src/db/MemManager.h index b2494e4de8..de2a48b2f0 100644 --- a/cpp/src/db/MemManager.h +++ b/cpp/src/db/MemManager.h @@ -24,6 +24,7 @@ class MemVectors { public: typedef typename EngineT::Ptr EnginePtr; typedef typename meta::Meta::Ptr MetaPtr; + typedef std::shared_ptr> Ptr; explicit MemVectors(const std::shared_ptr&, const meta::GroupFileSchema&, const Options&); @@ -58,14 +59,14 @@ private: template class MemManager { public: - typedef MemVectors ItemT; - typedef std::shared_ptr VectorsPtr; typedef typename meta::Meta::Ptr MetaPtr; + typedef typename MemVectors::Ptr MemVectorsPtr; + typedef std::shared_ptr> Ptr; MemManager(const std::shared_ptr& meta_, const Options& options) : _pMeta(meta_), options_(options) {} - VectorsPtr get_mem_by_group(const std::string& group_id_); + MemVectorsPtr get_mem_by_group(const std::string& group_id_); Status add_vectors(const std::string& group_id_, size_t n_, const float* vectors_, IDNumbers& vector_ids_); @@ -77,8 +78,8 @@ private: size_t n_, const float* vectors_, IDNumbers& vector_ids_); Status mark_memory_as_immutable(); - typedef std::map MemMap; - typedef std::vector ImmMemPool; + typedef std::map MemMap; + typedef std::vector ImmMemPool; MemMap _memMap; ImmMemPool _immMems; MetaPtr _pMeta;