Function sql_kill

sql/sql_parse.cc:9298–9346

*/

static
void sql_kill(THD *thd, my_thread_id id, killed_state state, killed_type type)
{
#ifdef WITH_WSREP
  if (WSREP(thd))
  {
    if (!(thd->variables.option_bits & OPTION_GTID_BEGIN))
    {
      WSREP_DEBUG("implicit commit before KILL");
      /* Commit the normal transaction if one is active. */
      bool commit_failed= trans_commit_implicit(thd);
      /* Release metadata locks acquired in this transaction. */
      thd->release_transactional_locks();
      if (commit_failed || wsrep_after_statement(thd))
      {
        WSREP_DEBUG("implicit commit failed, MDL released: %lld",
                    (longlong) thd->thread_id);
        return;
      }
      thd->transaction->stmt.mark_trans_did_ddl();
    }
  }

  bool wsrep_high_priority= false;
#endif /* WITH_WSREP */
  uint error= kill_one_thread(thd, id, state, type
#ifdef WITH_WSREP
                              , wsrep_high_priority
#endif
                              );

  if (likely(!error))
  {
    if (!thd->killed)
      my_ok(thd);
    else
      thd->send_kill_message();
  }
#ifdef WITH_WSREP
  else if (wsrep_high_priority)
    my_printf_error(error, "This is a high priority thread/query and"
                    " cannot be killed without compromising"
                    " the consistency of the cluster", MYF(0));
#endif
  else
  {
    my_error(error, MYF(0), id);
  }
}


static void __attribute__ ((noinline))