| 2704 | DBUG_VOID_RETURN; |
| 2705 | } |
| 2706 | ~Delayed_insert() override |
| 2707 | { |
| 2708 | /* The following is not really needed, but just for safety */ |
| 2709 | delayed_row *row; |
| 2710 | while ((row=rows.get())) |
| 2711 | delete row; |
| 2712 | if (table) |
| 2713 | { |
| 2714 | close_thread_tables(&thd); |
| 2715 | thd.mdl_context.release_transactional_locks(&thd); |
| 2716 | } |
| 2717 | mysql_mutex_destroy(&mutex); |
| 2718 | mysql_cond_destroy(&cond); |
| 2719 | mysql_cond_destroy(&cond_client); |
| 2720 | |
| 2721 | server_threads.erase(&thd); |
| 2722 | mysql_mutex_assert_owner(&LOCK_delayed_insert); |
| 2723 | delayed_insert_threads--; |
| 2724 | |
| 2725 | my_free(thd.query()); |
| 2726 | thd.reset_query_inner(); |
| 2727 | thd.security_ctx->user= 0; |
| 2728 | thd.security_ctx->host= 0; |
| 2729 | } |
| 2730 | |
| 2731 | /* The following is for checking when we can delete ourselves */ |
| 2732 | inline void lock() |
nothing calls this directly
no test coverage detected