test/acl
1
0
Fork 0
mirror of https://gitee.com/acl-dev/acl.git synced 2024-12-02 11:57:43 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

modify redis_cluster.cpp for supporting slot cache

Browse Source
This commit is contained in:
zsx 2015-03-02 14:47:19 +08:00
parent 358a73d07e
commit 7678442e78
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
lib_acl_cpp/src/redis/redis_command.cpp
View File

@ -314,7 +314,9 @@ redis_client* redis_command::peek_conn(redis_cluster* cluster, int slot)
if (slot < 0)
conns = (redis_pool*) cluster->peek();
else if ((conns = cluster->peek_slot(slot)) == NULL)
{
conns = (redis_pool*) cluster->peek();
}
if (conns == NULL)
{
@ -349,7 +351,7 @@ const redis_result* redis_command::run(redis_cluster* cluster, size_t nchild)
}
redis_result_t type;
bool last_moved;
bool last_moved = false;
int n = 0;
while (n++ < redirect_max_)
@ -384,7 +386,6 @@ const redis_result* redis_command::run(redis_cluster* cluster, size_t nchild)
}
else
{
last_moved = false;
// 将连接对象归还给连接池对象
conn->get_pool()->put(conn, true);
}