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

format code

Browse Source 
Former-commit-id: f809ffd4505ada713620e4996d6fe1004bcc69dc
This commit is contained in:
starlord 2019-10-29 15:37:08 +08:00
parent a05cebf513
commit 96dffcf8ab
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
core/src/server/DBWrapper.cpp
View File

@ -40,12 +40,14 @@ DBWrapper::StartService() {
engine::DBOptions opt;
s = config.GetDBConfigBackendUrl(opt.meta_.backend_uri_);
if (!s.ok()) {
std::cerr << s.ToString() << std::endl;
return s;
}
std::string path;
s = config.GetDBConfigPrimaryPath(path);
if (!s.ok()) {
std::cerr << s.ToString() << std::endl;
return s;
}
@ -55,7 +57,7 @@ DBWrapper::StartService() {
s = config.GetDBConfigSecondaryPath(db_slave_path);
if (!s.ok()) {
std::cerr << s.ToString() << std::endl;
kill(0, SIGUSR1);
return s;
}
StringHelpFunctions::SplitStringByDelimeter(db_slave_path, ";", opt.meta_.slave_paths_);
@ -64,14 +66,14 @@ DBWrapper::StartService() {
s = config.GetCacheConfigCacheInsertData(opt.insert_cache_immediately_);
if (!s.ok()) {
std::cerr << s.ToString() << std::endl;
kill(0, SIGUSR1);
return s;
}
std::string mode;
s = config.GetServerConfigDeployMode(mode);
if (!s.ok()) {
std::cerr << s.ToString() << std::endl;
kill(0, SIGUSR1);
return s;
}
if (mode == "single") {
@ -91,7 +93,7 @@ DBWrapper::StartService() {
s = config.GetEngineConfigOmpThreadNum(omp_thread);
if (!s.ok()) {
std::cerr << s.ToString() << std::endl;
kill(0, SIGUSR1);
return s;
}
if (omp_thread > 0) {
@ -110,7 +112,7 @@ DBWrapper::StartService() {
s = config.GetEngineConfigUseBlasThreshold(use_blas_threshold);
if (!s.ok()) {
std::cerr << s.ToString() << std::endl;
kill(0, SIGUSR1);
return s;
}
faiss::distance_compute_blas_threshold = use_blas_threshold;
@ -121,7 +123,7 @@ DBWrapper::StartService() {
s = config.GetDBConfigArchiveDiskThreshold(disk);
if (!s.ok()) {
std::cerr << s.ToString() << std::endl;
kill(0, SIGUSR1);
return s;
}
if (disk > 0) {
@ -131,7 +133,7 @@ DBWrapper::StartService() {
s = config.GetDBConfigArchiveDaysThreshold(days);
if (!s.ok()) {
std::cerr << s.ToString() << std::endl;
kill(0, SIGUSR1);
return s;
}
if (days > 0) {
@ -174,7 +176,7 @@ DBWrapper::StartService() {
s = config.GetDBConfigPreloadTable(preload_tables);
if (!s.ok()) {
std::cerr << s.ToString() << std::endl;
kill(0, SIGUSR1);
return s;
}
s = PreloadTables(preload_tables);