Method handle_inserts

sql/sql_insert.cc:3860–4144

bool Delayed_insert::handle_inserts(void)
{
  int error;
  ulong max_rows;
  bool using_ignore= 0, using_opt_replace= 0, using_bin_log;
  delayed_row *row;
  Write_record write;
  DBUG_ENTER("handle_inserts");

  /* Allow client to insert new rows */
  mysql_mutex_unlock(&mutex);

  table->next_number_field=table->found_next_number_field;
  table->use_all_columns();

  THD_STAGE_INFO(&thd, stage_upgrading_lock);
  if (thr_upgrade_write_delay_lock(*thd.lock->locks, delayed_lock,
                                   thd.variables.lock_wait_timeout))
  {
    /*
      This can happen if thread is killed either by a shutdown
      or if another thread is removing the current table definition
      from the table cache.
    */
    my_error(ER_DELAYED_CANT_CHANGE_LOCK, MYF(ME_FATAL | ME_ERROR_LOG),
             table->s->table_name.str);
    goto err;
  }

  THD_STAGE_INFO(&thd, stage_insert);
  max_rows= delayed_insert_limit;
  if (thd.killed || table->s->tdc->flushed)
  {
    thd.set_killed(KILL_SYSTEM_THREAD);
    max_rows= ULONG_MAX;                     // Do as much as possible
  }

  if (table->file->ha_rnd_init_with_error(0))
    goto err;
  /*
    We have to call prepare_for_row_logging() as the second call to
    handler_writes() will not have called decide_logging_format.
  */
  table->file->prepare_for_row_logging();
  table->file->prepare_for_modify(true, true);
  using_bin_log= table->file->row_logging;

  /*
    We can't use row caching when using the binary log because if
    we get a crash, then binary log will contain rows that are not yet
    written to disk, which will cause problems in replication.
  */
  if (!using_bin_log && !table->s->long_unique_table)
    table->file->extra(HA_EXTRA_WRITE_CACHE);

  mysql_mutex_lock(&mutex);

  while ((row=rows.get()))