bughz/predixy
1
0
Fork 0
mirror of https://github.com/joyieldInc/predixy.git synced 2025-12-24 22:46:41 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add self node in first cluster node response

Browse Source
This commit is contained in:
Nidhi Agarwal 2020-05-13 08:17:44 +05:30
parent 393ff81e69
commit a5fd715245
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/ClusterServerPool.cpp
View File

@ -113,9 +113,7 @@ void ClusterServerPool::handleResponse(Handler* h, ConnectConnection* s, Request
auto it = mServs.find(addr); auto it = mServs.find(addr);
Server* serv = it == mServs.end() ? nullptr : it->second; Server* serv = it == mServs.end() ? nullptr : it->second;
if (!serv) { if (!serv) {
if (strstr(p.flags().data(), "myself")) { if (const char* t = strchr(p.addr().data(), '@')) {
serv = s->server();
} else if (const char* t = strchr(p.addr().data(), '@')) {
addr = String(p.addr().data(), t - p.addr().data()); addr = String(p.addr().data(), t - p.addr().data());
it = mServs.find(addr); it = mServs.find(addr);
serv = it == mServs.end() ? nullptr : it->second; serv = it == mServs.end() ? nullptr : it->second;