~drizzle-trunk/drizzle/development

/*****************************************************************************

 

Copyright (c) 2008, 2009 Google Inc.

 

Portions of this file contain modifications contributed and copyrighted by

Google, Inc. Those modifications are gratefully acknowledged and are described

incorporated with their permission, and subject to the conditions contained in

the file COPYING.Google.

 

This program is free software; you can redistribute it and/or modify it under

the terms of the GNU General Public License as published by the Free Software

Foundation; version 2 of the License.

St, Fifth Floor, Boston, MA 02110-1301 USA

 

*****************************************************************************/

 

/**************************************************//**

@file srv/srv0srv.c

#include "sync0sync.h"

#include "thr0loc.h"

#include "que0que.h"

#include "log0recv.h"

#include "pars0pars.h"

#include "usr0sess.h"

#include "row0mysql.h"

#include "ha_prototypes.h"

#include "trx0i_s.h"

 

/* This is set to TRUE if the MySQL user has set it in MySQL; currently

affects only FOREIGN KEY definition parsing */

in microseconds, in order to reduce the lagging of the purge thread. */

UNIV_INTERN ulint       srv_dml_needed_delay = 0;

 

UNIV_INTERN ibool       srv_error_monitor_active = FALSE;

 

UNIV_INTERN const char* srv_main_thread_op_info = "";

/** Whether to check file format during startup.  A value of

DICT_TF_FORMAT_MAX + 1 means no checking ie. FALSE.  The default is to

set it to the highest format we support. */

 

#if DICT_TF_FORMAT_51

# error "DICT_TF_FORMAT_51 must be 0!"

on duplicate key checking and foreign key checking */

UNIV_INTERN ibool       srv_locks_unsafe_for_binlog = FALSE;

 

UNIV_INTERN ulint       srv_n_data_files = 0;

UNIV_INTERN char**      srv_data_file_names = NULL;

/* size in database pages */

the checkpoints. */

UNIV_INTERN bool        srv_adaptive_flushing   = TRUE;

 

collation */

#if defined(BUILD_DRIZZLE)

UNIV_INTERN const byte  srv_latin1_ordering[256]        /* The sort order table of the latin1

UNIV_INTERN my_bool     srv_use_sys_malloc      = TRUE;

/* requested size in kilobytes */

UNIV_INTERN ulint       srv_buf_pool_size       = ULINT_MAX;

/* previously requested size */

UNIV_INTERN ulint       srv_buf_pool_old_size;

/* current size in kilobytes */

 

UNIV_INTERN ulong       srv_max_buf_pool_modified_pct   = 75;

 

/* variable counts amount of data read in total (in bytes) */

UNIV_INTERN ulint srv_data_read = 0;

 

reading of a disk page */

UNIV_INTERN ulint srv_buf_pool_reads = 0;

 

/* structure to pass status variables to MySQL */

UNIV_INTERN export_struc export_vars;

 

UNIV_INTERN ib_int64_t  srv_n_lock_wait_time            = 0;

UNIV_INTERN ulint               srv_n_lock_max_wait_time        = 0;

 

 

/*

  Set the following to 0 if you want InnoDB to write messages on

 

/* Mutex for locking srv_monitor_file */

UNIV_INTERN mutex_t     srv_monitor_file_mutex;

/* Temporary file for innodb monitor output */

UNIV_INTERN FILE*       srv_monitor_file;

/* Mutex for locking srv_dict_tmpfile.

static ulint   srv_main_flush_loops             = 0;

/* Log writes involving flush. */

static ulint   srv_log_writes_and_flush         = 0;

 

/* This is only ever touched by the master thread. It records the

time when the last flush of log file has happened. The master

static ulint    srv_meter_foreground[SRV_MASTER + 1];

#endif

 

/***********************************************************************

Prints counters for work done by srv_master_thread. */

static

                srv_main_1_second_loops, srv_main_sleeps,

                srv_main_10_second_loops, srv_main_background_loops,

                srv_main_flush_loops);

}

 

/*********************************************************************//**

Sets the info describing an i/o thread current state. */

UNIV_INTERN

        srv_sys = mem_alloc(sizeof(srv_sys_t));

 

        kernel_mutex_temp = mem_alloc(sizeof(mutex_t));

 

 

        srv_sys->threads = mem_alloc(OS_THREAD_MAX_N * sizeof(srv_slot_t));

 

}

 

/*********************************************************************//**

UNIV_INTERN

void

srv_free(void)

/*==========*/

{

        os_fast_mutex_free(&srv_conc_mutex);

}

 

/*********************************************************************//**

/*==================*/

{

        ut_mem_init();

        os_sync_init();

        sync_init();

        mem_init(srv_mem_pool_size);

                row_mysql_unfreeze_data_dictionary(trx);

                break;

        case RW_X_LATCH:

                /* Release fast index creation latch */

                row_mysql_unlock_data_dictionary(trx);

                break;

                row_mysql_freeze_data_dictionary(trx);

                break;

        case RW_X_LATCH:

                row_mysql_lock_data_dictionary(trx);

                break;

        }

                    start_time != -1 && finish_time != -1) {

                        srv_n_lock_max_wait_time = diff_time;

                }

        }

 

        if (trx->was_chosen_as_deadlock_victim) {

 

                trx->error_state = DB_LOCK_WAIT_TIMEOUT;

        }

}

 

/********************************************************************//**

 

        log_refresh_stats();

 

 

        srv_n_rows_inserted_old = srv_n_rows_inserted;

        srv_n_rows_updated_old = srv_n_rows_updated;

}

 

/******************************************************************//**

UNIV_INTERN

srv_printf_innodb_monitor(

/*======================*/

        FILE*   file,           /*!< in: output stream */

        ulint*  trx_start,      /*!< out: file position of the start of

                                the list of active transactions */

        ulint*  trx_end)        /*!< out: file position of the end of

        double  time_elapsed;

        time_t  current_time;

        ulint   n_reserved;