milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix typo bug 

Former-commit-id: 8b544b2158f89fea48a174e2f64128fa61706259
pull/191/head
JinHai-CN 2019-11-03 15:14:42 +08:00
parent 3b17eb7481
commit 47d52d250d
3 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
core/src/scheduler/job/BuildIndexJob.cpp
View File

@ -50,7 +50,10 @@ void
BuildIndexJob::BuildIndexDone(size_t to_index_id) { BuildIndexJob::BuildIndexDone(size_t to_index_id) {
std::unique_lock<std::mutex> lock(mutex_); std::unique_lock<std::mutex> lock(mutex_);
to_index_files_.erase(to_index_id); to_index_files_.erase(to_index_id);
cv_.notify_all(); if (to_index_files_.empty()) {
cv_.notify_all();
}
SERVER_LOG_DEBUG << "BuildIndexJob " << id() << " finish index file: " << to_index_id; SERVER_LOG_DEBUG << "BuildIndexJob " << id() << " finish index file: " << to_index_id;
} }

5
core/src/scheduler/job/SearchJob.cpp
View File

@ -49,7 +49,10 @@ void
SearchJob::SearchDone(size_t index_id) { SearchJob::SearchDone(size_t index_id) {
std::unique_lock<std::mutex> lock(mutex_); std::unique_lock<std::mutex> lock(mutex_);
index_files_.erase(index_id); index_files_.erase(index_id);
cv_.notify_all(); if (index_files_.empty()) {
cv_.notify_all();
}
SERVER_LOG_DEBUG << "SearchJob " << id() << " finish index file: " << index_id; SERVER_LOG_DEBUG << "SearchJob " << id() << " finish index file: " << index_id;
} }

2
core/src/wrapper/ConfAdapter.cpp
View File

@ -109,7 +109,7 @@ IVFSQConfAdapter::Match(const TempMetaConf& metaconf) {
conf->nlist = MatchNlist(metaconf.size, metaconf.nlist); conf->nlist = MatchNlist(metaconf.size, metaconf.nlist);
conf->d = metaconf.dim; conf->d = metaconf.dim;
conf->metric_type = metaconf.metric_type; conf->metric_type = metaconf.metric_type;
conf->gpu_id = conf->gpu_id; conf->gpu_id = metaconf->gpu_id;
conf->nbits = 8; conf->nbits = 8;
MatchBase(conf); MatchBase(conf);
return conf; return conf;