Function processlist_callback

sql/sql_show.cc:3491–3617

static my_bool processlist_callback(THD *tmp, processlist_callback_arg *arg)
{
  Security_context *tmp_sctx= tmp->security_ctx;
  CHARSET_INFO *cs= system_charset_info;
  const char *val;
  ulonglong max_counter;
  bool got_thd_data;
  char *user=
          arg->thd->security_ctx->master_access & PRIV_STMT_SHOW_PROCESSLIST ?
          NullS : arg->thd->security_ctx->priv_user;

  if (!thd_visible_in_processlist(user, tmp))
    return 0;

  restore_record(arg->table, s->default_values);
  /* ID */
  arg->table->field[0]->store((longlong) tmp->thread_id, TRUE);
  /* USER */
  val= tmp_sctx->user && (tmp_sctx->user != slave_user &&
       tmp_sctx->user != wsrep_user) ? tmp_sctx->user :
       (tmp->system_thread ? "system user" : "unauthenticated user");
  arg->table->field[1]->store(val, strlen(val), cs);
  /* HOST */
  if (tmp->peer_port && (tmp_sctx->host || tmp_sctx->ip) &&
      arg->thd->security_ctx->host_or_ip[0])
  {
    char host[LIST_PROCESS_HOST_LEN + 1];
    my_snprintf(host, LIST_PROCESS_HOST_LEN, "%s:%u",
                tmp_sctx->host_or_ip, tmp->peer_port);
    arg->table->field[2]->store(host, strlen(host), cs);
  }
  else
    arg->table->field[2]->store(tmp_sctx->host_or_ip,
                                strlen(tmp_sctx->host_or_ip), cs);

  if ((got_thd_data= !trylock_short(&tmp->LOCK_thd_data)))
  {
    /* DB */
    if (tmp->db.str)
    {
      arg->table->field[3]->store(tmp->db.str, tmp->db.length, cs);
      arg->table->field[3]->set_notnull();
    }
  }

  /* COMMAND */
  if ((val= (char *) (!got_thd_data ? "Busy" :
                      (tmp->killed >= KILL_QUERY ?
                       "Killed" : 0))))
    arg->table->field[4]->store(val, strlen(val), cs);
  else
    arg->table->field[4]->store(command_name[tmp->get_command()].str,
                                command_name[tmp->get_command()].length, cs);

  /* MYSQL_TIME */
  ulonglong utime= tmp->start_utime;
  ulonglong utime_after_query_snapshot= tmp->utime_after_query;
  if (utime < utime_after_query_snapshot)