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

refactor(db): add NextFileId

Browse Source 
Former-commit-id: 51a1f75881a8a1f85e3fdc8ac7217218976cc11c
This commit is contained in:
Xu Peng 2019-05-26 15:17:46 +08:00
parent 2d08fc415f
commit 3958fe5a35
2 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
cpp/src/db/DBMetaImpl.cpp
View File

@ -77,6 +77,14 @@ Status DBMetaImpl::NextGroupId(std::string& group_id) {
return Status::OK();
}
Status DBMetaImpl::NextFileId(std::string& file_id) {
std::stringstream ss;
SimpleIDGenerator g;
ss << g.getNextIDNumber();
file_id = ss.str();
return Status::OK();
}
DBMetaImpl::DBMetaImpl(const DBMetaOptions& options_)
: _options(options_) {
initialize();
@ -225,11 +233,8 @@ Status DBMetaImpl::add_group_file(GroupFileSchema& group_file) {
return status;
}
SimpleIDGenerator g;
std::stringstream ss;
ss << g.getNextIDNumber();
NextFileId(group_file.file_id);
group_file.file_type = GroupFileSchema::NEW;
group_file.file_id = ss.str();
group_file.dimension = group_info.dimension;
group_file.size = 0;
group_file.created_on = utils::GetMicroSecTimeStamp();
@ -240,7 +245,6 @@ Status DBMetaImpl::add_group_file(GroupFileSchema& group_file) {
try {
auto id = ConnectorPtr->insert(group_file);
group_file.id = id;
/* LOG(DEBUG) << "Add group_file of file_id=" << group_file.file_id; */
} catch (...) {
return Status::DBTransactionError("Add file Error");
}

1
cpp/src/db/DBMetaImpl.h
View File

@ -65,6 +65,7 @@ public:
virtual ~DBMetaImpl();
private:
Status NextFileId(std::string& file_id);
Status NextGroupId(std::string& group_id);
Status discard_files_of_size(long to_discard_size);
Status get_group_no_lock(GroupSchema& group_info);