bughz/predixy
1
0
Fork 0
mirror of https://github.com/joyieldInc/predixy.git synced 2025-12-25 06:56:42 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

force to ping redis when it is failed

Browse Source
This commit is contained in:
ken 2023-08-17 11:02:31 +08:00
parent c15f54e274
commit 930abec3c3
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/ConnectConnectionPool.cpp
View File

@ -177,12 +177,21 @@ void ConnectConnectionPool::check()
if (!mServ->fail() || !mServ->online()) { if (!mServ->fail() || !mServ->online()) {
return; return;
} }
int db = 0;
if (mServ->activate()) { if (mServ->activate()) {
auto c = mShareConns.empty() ? nullptr : mShareConns[0]; auto c = mShareConns.empty() ? nullptr : mShareConns[db];
if (!c) { if (!c) {
return; c = ConnectConnectionAlloc::create(mServ, true);
c->setDb(db);
++mStats.connections;
mShareConns[db] = c;
logNotice("h %d create server connection %s %d",
mHandler->id(), c->peer(), c->fd());
} }
if (c->fd() >= 0) { if (c->fd() >= 0) {
// Force share connections to ping redis when redis is failed.
RequestPtr req = RequestAlloc::create(Request::PingServ);
mHandler->handleRequest(req, c);
return; return;
} }
c->reopen(); c->reopen();