fix kill 15 issues
This commit is contained in:
3
deps/oblib/src/rpc/obmysql/ob_sql_nio.cpp
vendored
3
deps/oblib/src/rpc/obmysql/ob_sql_nio.cpp
vendored
@ -746,6 +746,9 @@ public:
|
||||
while (cur != head) {
|
||||
ObSqlSock* s = CONTAINER_OF(cur, ObSqlSock, all_list_link_);
|
||||
cur = cur->next_;
|
||||
s->on_disconnect();
|
||||
ObSqlSockSession *sess = (ObSqlSockSession *)s->sess_;
|
||||
sess->destroy();
|
||||
s->do_close();
|
||||
}
|
||||
}
|
||||
|
||||
@ -531,6 +531,10 @@ void ObServer::destroy()
|
||||
ob_service_.destroy();
|
||||
FLOG_INFO("ob service destroyed");
|
||||
|
||||
FLOG_INFO("begin to destroy session manager");
|
||||
session_mgr_.destroy();
|
||||
FLOG_INFO("session manager destroyed");
|
||||
|
||||
FLOG_INFO("begin to destroy locality manager");
|
||||
locality_manager_.destroy();
|
||||
FLOG_INFO("locality manager destroyed");
|
||||
|
||||
@ -251,6 +251,8 @@ int ObTabletLSService::destroy()
|
||||
int ret = OB_SUCCESS;
|
||||
stopped_ = true;
|
||||
inited_ = false;
|
||||
inner_cache_.destroy();
|
||||
async_queue_.destroy();
|
||||
return ret;
|
||||
}
|
||||
|
||||
|
||||
@ -286,6 +286,13 @@ int ObSQLSessionMgr::init()
|
||||
return ret;
|
||||
}
|
||||
|
||||
void ObSQLSessionMgr::destroy()
|
||||
{
|
||||
sessinfo_map_.destroy();
|
||||
sessid_sequence_.destroy();
|
||||
sess_hold_map_.destroy();
|
||||
}
|
||||
|
||||
uint64_t ObSQLSessionMgr::extract_server_id(uint32_t sessid)
|
||||
{
|
||||
uint64_t server_id = sessid >> LOCAL_SEQ_LEN;
|
||||
|
||||
@ -72,6 +72,7 @@ public:
|
||||
* @param conn : connection information
|
||||
* @param sess_info : point to the ObSQLSessionInfo that the function created; used as value
|
||||
*/
|
||||
void destroy();
|
||||
int create_session(observer::ObSMConnection *conn, ObSQLSessionInfo *&sess_info);
|
||||
// create session by session id and proxy session id.
|
||||
// need call revert_session if return success.
|
||||
|
||||
Reference in New Issue
Block a user