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

mysql meta connection pool issue (#2413) 

Signed-off-by: groot <yihua.mo@zilliz.com>
pull/2412/head^2
groot 2020-05-22 20:26:15 -05:00 committed by GitHub
parent e40f0b3939
commit 4f6fe96550
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
core/src/db/meta/MySQLConnectionPool.cpp
View File

@ -11,6 +11,7 @@
#include "db/meta/MySQLConnectionPool.h"
#include <fiu-local.h>
#include <thread>
namespace milvus {
namespace engine {
@ -24,7 +25,7 @@ namespace meta {
mysqlpp::Connection*
MySQLConnectionPool::grab() {
while (conns_in_use_ > max_pool_size_) {
sleep(1);
std::this_thread::sleep_for(std::chrono::milliseconds(10));
}
++conns_in_use_;

6
core/src/db/meta/MySQLMetaImpl.cpp
View File

@ -314,9 +314,9 @@ MySQLMetaImpl::Initialize() {
}
// step 3: connect mysql
int thread_hint = std::thread::hardware_concurrency();
int max_pool_size = (thread_hint == 0) ? 8 : thread_hint;
unsigned int port = 0;
unsigned int thread_hint = std::thread::hardware_concurrency();
int max_pool_size = (thread_hint > 8) ? thread_hint : 8;
int port = 0;
if (!uri_info.port_.empty()) {
port = std::stoi(uri_info.port_);
}