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

feat(db): add more print

Browse Source 
Former-commit-id: 42486eb1e1c804e7b5120dc1f0dd12d2f7bd6a96
This commit is contained in:
Xu Peng 2019-04-28 13:55:43 +08:00
parent 8c01725ff7
commit 32b64ab724
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cpp/src/db/DBImpl.cpp
View File

@ -327,12 +327,14 @@ void DBImpl::background_build_index() {
_pMeta->files_to_index(to_index_files);
Status status;
for (auto& file : to_index_files) {
LOG(DEBUG) << "Buiding index for " << file.location;
status = build_index(file);
if (!status.ok()) {
_bg_error = status;
return;
}
}
LOG(DEBUG) << "All Buiding index Done";
bg_build_index_started_ = false;
bg_build_index_finish_signal_.notify_all();
@ -370,17 +372,21 @@ Status DBImpl::count(const std::string& group_id, long& result) {
DBImpl::~DBImpl() {
{
LOG(DEBUG) << "Start wait background merge thread";
std::unique_lock<std::mutex> lock(_mutex);
_shutting_down.store(true, std::memory_order_release);
while (_bg_compaction_scheduled) {
_bg_work_finish_signal.wait(lock);
}
LOG(DEBUG) << "Stop wait background merge thread";
}
{
LOG(DEBUG) << "Start wait background build index thread";
std::unique_lock<std::mutex> lock(build_index_mutex_);
while (bg_build_index_started_) {
bg_build_index_finish_signal_.wait(lock);
}
LOG(DEBUG) << "Stop wait background build index thread";
}
std::vector<std::string> ids;
_pMemMgr->serialize(ids);