Method get_local_table

sql/sql_insert.cc:3011–3209

*/

TABLE *Delayed_insert::get_local_table(THD* client_thd)
{
  my_ptrdiff_t adjust_ptrs;
  Field **field,**org_field, *found_next_number_field;
  TABLE *copy;
  TABLE_SHARE *share;
  uchar *bitmap;
  char *copy_tmp;
  uint bitmaps_used;
  Field **default_fields, **virtual_fields;
  uchar *record;
  DBUG_ENTER("Delayed_insert::get_local_table");

  /* First request insert thread to get a lock */
  status=1;
  tables_in_use++;
  if (!thd.lock)				// Table is not locked
  {
    THD_STAGE_INFO(client_thd, stage_waiting_for_handler_lock);
    mysql_cond_signal(&cond);			// Tell handler to lock table
    while (!thd.killed && !thd.lock && ! client_thd->killed)
    {
      mysql_cond_wait(&cond_client, &mutex);
    }
    THD_STAGE_INFO(client_thd, stage_got_handler_lock);
    if (client_thd->killed)
      goto error2;
    if (thd.killed)
    {
      /*
        Check how the insert thread was killed. If it was killed
        by FLUSH TABLES which calls kill_delayed_threads_for_table(),
        then is_error is not set.
        In this case, return without setting an error,
        which means that the insert will be converted to a normal insert.
      */
      if (thd.is_error())
      {
        /*
          Copy the error message. Note that we don't treat fatal
          errors in the delayed thread as fatal errors in the
          main thread. If delayed thread was killed, we don't
          want to send "Server shutdown in progress" in the
          INSERT THREAD.

          The thread could be killed with an error message if
          di->handle_inserts() or di->open_and_lock_table() fails.
        */
        my_message(thd.get_stmt_da()->sql_errno(),
                   thd.get_stmt_da()->message(), MYF(0));
      }
      goto error2;
    }
  }
  share= table->s;

  /*
    Allocate memory for the TABLE object, the field pointers array,