admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(db): fix runtime error due to missing return value

Browse Source 
Former-commit-id: daa9d86441d94dd0c3d82a49d1d276676915f124
This commit is contained in:
Xu Peng 2019-04-15 16:34:47 +08:00
parent b162ab0a04
commit bf0afceec3
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cpp/src/db/memvectors.cpp
View File

@ -1,6 +1,7 @@
#include <faiss/IndexFlat.h>
#include <faiss/MetaIndexes.h>
#include <faiss/index_io.h>
#include <iostream>
#include "memvectors.h"
#include "db_meta.h"
@ -74,7 +75,7 @@ Status MemManager::add_vectors(const std::string& group_id_,
size_t n_,
const float* vectors_,
IDNumbers& vector_ids_) {
std::lock_guard<std::mutex> lock(_mutex);
std::unique_lock<std::mutex> lock(_mutex);
return add_vectors_no_lock(group_id_, n_, vectors_, vector_ids_);
}
@ -92,11 +93,12 @@ Status MemManager::add_vectors_no_lock(const std::string& group_id,
}
Status MemManager::mark_memory_as_immutable() {
std::lock_guard<std::mutex> lock(_mutex);
std::unique_lock<std::mutex> lock(_mutex);
for (auto& kv: _memMap) {
_immMems.push_back(kv.second);
}
_memMap.clear();
return Status::OK();
}
/* bool MemManager::need_serialize(double interval) { */
@ -118,7 +120,7 @@ Status MemManager::serialize() {
mem->serialize();
}
_immMems.clear();
/* _last_compact_time = std::time(nullptr); */
return Status::OK();
}