[FEAT MERGE]client session

2023-12-11 05:12:34 +00:00
parent f77f3b7f69
commit 820c5f4e6d
52 changed files with 1008 additions and 66 deletions
--- a/src/observer/mysql/obmp_stmt_fetch.cpp
+++ b/src/observer/mysql/obmp_stmt_fetch.cpp
@ -695,6 +695,8 @@ int ObMPStmtFetch::process()
    if (OB_UNLIKELY(!session.is_valid())) {
      ret = OB_ERR_UNEXPECTED;
      LOG_ERROR("invalid session", K_(cursor_id), K(ret));
+    } else if (OB_FAIL(process_kill_client_session(session))) {
+      LOG_WARN("client session has been killed", K(ret));
    } else if (OB_UNLIKELY(session.is_zombie())) {
      //session has been killed some moment ago
      ret = OB_ERR_SESSION_INTERRUPTED;