diff options
| author | Vicențiu Ciorbaru <vicentiu@mariadb.org> | 2017-08-02 12:17:21 +0300 |
|---|---|---|
| committer | Vicențiu Ciorbaru <vicentiu@mariadb.org> | 2017-08-03 11:48:44 +0300 |
| commit | b1a2031ff96f132bf065d6b41593a842478a6659 (patch) | |
| tree | 572f7607c4660f555a9e3da9c431f9c7c68bfae3 /storage/tokudb/hatoku_hton.cc | |
| parent | 97c53cdfcc01a4f47d2757f5ca0b040f0e5a30e5 (diff) | |
| download | mariadb-git-b1a2031ff96f132bf065d6b41593a842478a6659.tar.gz | |
5.6.36-82.1
Diffstat (limited to 'storage/tokudb/hatoku_hton.cc')
| -rw-r--r-- | storage/tokudb/hatoku_hton.cc | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/storage/tokudb/hatoku_hton.cc b/storage/tokudb/hatoku_hton.cc index 5e49e8d95d0..2ae9cdc071b 100644 --- a/storage/tokudb/hatoku_hton.cc +++ b/storage/tokudb/hatoku_hton.cc @@ -67,6 +67,7 @@ static bool tokudb_show_status( static void tokudb_handle_fatal_signal(handlerton* hton, THD* thd, int sig); #endif static int tokudb_close_connection(handlerton* hton, THD* thd); +static void tokudb_kill_connection(handlerton *hton, THD *thd); static int tokudb_commit(handlerton* hton, THD* thd, bool all); static int tokudb_rollback(handlerton* hton, THD* thd, bool all); #if TOKU_INCLUDE_XA @@ -343,6 +344,7 @@ static int tokudb_init_func(void *p) { tokudb_hton->create = tokudb_create_handler; tokudb_hton->close_connection = tokudb_close_connection; + tokudb_hton->kill_connection = tokudb_kill_connection; tokudb_hton->savepoint_offset = sizeof(SP_INFO_T); tokudb_hton->savepoint_set = tokudb_savepoint; @@ -766,6 +768,12 @@ static int tokudb_close_connection(handlerton* hton, THD* thd) { return error; } +void tokudb_kill_connection(handlerton *hton, THD *thd) { + TOKUDB_DBUG_ENTER(""); + db_env->kill_waiter(db_env, thd); + DBUG_VOID_RETURN; +} + bool tokudb_flush_logs(handlerton * hton) { TOKUDB_DBUG_ENTER(""); int error; |