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

Fix tcp stream related problems

Browse Source
This commit is contained in:
wangbin579 2018-07-20 11:17:47 +08:00
parent 9aad33dc8c
commit a5426c09f5
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/resultset_merge.c
View File

@ -3013,6 +3013,9 @@ check_fail_met(sql_context_t *context, network_queue *send_queue, GPtrArray *rec
server_session_t *ss = g_ptr_array_index(con->servers, p);
if (pkt_type == MYSQLD_PACKET_ERR) {
g_warning("%s: failed query:%s, server:%s", G_STRLOC, orig_sql, ss->server->dst->name->str);
if (con->num_pending_servers > 0) {
con->server_to_be_closed = 1;
}
}
if (context->stmt_type == STMT_CALL) {
if (!(*call_fail_met)) {