Function delayed_get_table

sql/sql_insert.cc:2832–2977

*/

static
bool delayed_get_table(THD *thd, MDL_request *grl_protection_request,
                       TABLE_LIST *table_list)
{
  int error;
  Delayed_insert *di;
  DBUG_ENTER("delayed_get_table");

  /* Must be set in the parser */
  DBUG_ASSERT(table_list->db.str);

  /* Find the thread which handles this table. */
  if (!(di= find_handler(thd, table_list)))
  {
    /*
      No match. Create a new thread to handle the table, but
      no more than max_insert_delayed_threads.
    */
    if (delayed_insert_threads >= thd->variables.max_insert_delayed_threads)
      DBUG_RETURN(0);
    THD_STAGE_INFO(thd, stage_creating_delayed_handler);
    mysql_mutex_lock(&LOCK_delayed_create);
    /*
      The first search above was done without LOCK_delayed_create.
      Another thread might have created the handler in between. Search again.
    */
    if (! (di= find_handler(thd, table_list)))
    {
      if (!(di= new Delayed_insert(thd->lex)))
        goto end_create;

      /*
        Annotating delayed inserts is not supported.
      */
      di->thd.variables.binlog_annotate_row_events= 0;

      di->thd.set_db(&table_list->db);
      di->thd.set_query(my_strndup(PSI_INSTRUMENT_ME,
                                   table_list->table_name.str,
                                   table_list->table_name.length,
                                   MYF(MY_WME | ME_FATAL)),
                        table_list->table_name.length, system_charset_info);
      if (di->thd.db.str == NULL || di->thd.query() == NULL)
      {
        /* The error is reported */
	delete di;
        goto end_create;
      }
      di->table_list= *table_list;			// Needed to open table
      /* Replace volatile strings with local copies */
      di->table_list.alias.str=    di->table_list.table_name.str=    di->thd.query();
      di->table_list.alias.length= di->table_list.table_name.length= di->thd.query_length();
      di->table_list.db= Lex_ident_db(di->thd.db);
      /*
        Nulify select_lex because, if the thread that spawned the current one
        disconnects, the select_lex will point to freed memory.
      */
      di->table_list.select_lex= NULL;