test/cetus
1
0
Fork 0
mirror of https://gitee.com/wangbin579/cetus.git synced 2024-12-01 19:37:38 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix dead session for save settings, etc

Browse Source
This commit is contained in:
wangbin579 2019-07-01 16:36:16 +03:00
parent af51d0e3e8
commit 5ca40123c8
3 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CMakeLists.txt
View File

@ -66,7 +66,7 @@ EXECUTE_PROCESS(COMMAND git describe --tags
MESSAGE(STATUS "building from ${GIT_REVISION}")
SET(CPACK_PACKAGE_VERSION_MAJOR "2")
SET(CPACK_PACKAGE_VERSION_MINOR "3")
SET(CPACK_PACKAGE_VERSION_PATCH "4")
SET(CPACK_PACKAGE_VERSION_PATCH "5")
SET(CPACK_PACKAGE_VENDOR "MySQL")
SET(PACKAGE_NAME cetus)

2
doc/proxy.conf.example
View File

@ -45,7 +45,7 @@ log-backtrace-on-crash=true
# For performance
enable-tcp-stream=true
enable-fast-stream=false
enable-fast-stream=true
# For MGR
group-replication-mode=0

7
plugins/admin/admin-plugin.c
View File

@ -440,10 +440,6 @@ int construct_channel_info(network_mysqld_con *con, char *sql)
}
int num = cetus_last_process;
if (con->ask_one_worker) {
num = 1;
}
int i;
for (i = 0; i < num; i++) {
g_debug("%s: pass sql info to s:%i pid:%d to:%d", G_STRLOC,
@ -459,6 +455,9 @@ int construct_channel_info(network_mysqld_con *con, char *sql)
event_set(&(cetus_processes[i].event), fd, EV_READ, network_read_sql_resp, con);
chassis_event_add_with_timeout(cycle, &(cetus_processes[i].event), NULL);
con->num_read_pending++;
if (con->ask_one_worker) {
break;
}
} else {
g_message("%s:fd is not valid:%d, num:%d, pending:%d", G_STRLOC, fd, num, con->num_read_pending);
}