admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-31 16:05:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(db): fix build bug

Browse Source 
Former-commit-id: 6d069d07a84897e05317143442e3d3b2d55949a4
This commit is contained in:
peng.xu 2019-07-09 19:09:42 +08:00
parent ac31c9bc7d
commit 9fd4048cf4
4 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -497,7 +497,7 @@ Status DBImpl::BuildIndex(const meta::TableFileSchema& file) {
}
Status DBImpl::BuildIndexByTable(const std::string& table_id) {
std::unique_ptr<std::mutex> lock(build_index_mutex_);
std::unique_lock<std::mutex> lock(build_index_mutex_);
meta::TableFilesSchema to_index_files;
meta_ptr_->FilesToIndex(to_index_files);
@ -516,7 +516,7 @@ Status DBImpl::BuildIndexByTable(const std::string& table_id) {
}
void DBImpl::BackgroundBuildIndex() {
std::unique_ptr<std::mutex> lock(build_index_mutex_);
std::unique_lock<std::mutex> lock(build_index_mutex_);
meta::TableFilesSchema to_index_files;
meta_ptr_->FilesToIndex(to_index_files);
Status status;

2
cpp/src/db/DBImpl.h
View File

@ -113,7 +113,7 @@ class DBImpl : public DB {
void BackgroundBuildIndex();
Status
BuildIndexByTable(const std::string& table_id) {
BuildIndexByTable(const std::string& table_id);
Status
BuildIndex(const meta::TableFileSchema &);

5
cpp/src/db/MySQLMetaImpl.cpp
View File

@ -1479,6 +1479,11 @@ namespace meta {
return Status::OK();
}
Status MySQLMetaImpl::UpdateTableFilesToIndex(const std::string& table_id) {
// TODO
return Status::OK();
}
Status MySQLMetaImpl::UpdateTableFiles(TableFilesSchema &files) {
// std::lock_guard<std::recursive_mutex> lock(mysql_mutex);

2
cpp/src/db/MySQLMetaImpl.h
View File

@ -42,6 +42,8 @@ namespace meta {
virtual Status UpdateTableFile(TableFileSchema& file_schema) override;
virtual Status UpdateTableFilesToIndex(const std::string& table_id) override;
virtual Status UpdateTableFiles(TableFilesSchema& files) override;
virtual Status FilesToSearch(const std::string& table_id,