diff options
author | unknown <marko@hundin.mysql.fi> | 2004-02-20 16:34:09 +0200 |
---|---|---|
committer | unknown <marko@hundin.mysql.fi> | 2004-02-20 16:34:09 +0200 |
commit | 0eacf58fd5ebc665ce799a673739c97d6157b13b (patch) | |
tree | 96c04a7ccc804314e3737d02fc081513e1e827db /innobase/srv | |
parent | f443541a36769eaacf9228ad517ed224c827c565 (diff) | |
download | mariadb-git-0eacf58fd5ebc665ce799a673739c97d6157b13b.tar.gz |
Many files:
Removed unused code
.del-os0trash.c~8cae5c1695501117:
Delete: innobase/os/os0trash.c
dict0crea.c:
Protect all sprintf(%s) with assertions
BitKeeper/deleted/.del-os0trash.c~8cae5c1695501117:
Delete: innobase/os/os0trash.c
innobase/btr/btr0sea.c:
Removed unused code
innobase/buf/buf0buf.c:
Removed unused code
innobase/com/com0shm.c:
Removed unused code
innobase/data/data0data.c:
Removed unused code
innobase/dict/dict0crea.c:
Removed unused code
innobase/fsp/fsp0fsp.c:
Removed unused code
innobase/ha/ha0ha.c:
Removed unused code
innobase/include/btr0cur.h:
Removed unused code
innobase/include/btr0sea.h:
Removed unused code
innobase/include/buf0buf.ic:
Removed unused code
innobase/include/data0data.h:
Removed unused code
innobase/include/dict0crea.h:
Removed unused code
innobase/include/dict0dict.h:
Removed unused code
innobase/include/ibuf0ibuf.h:
Removed unused code
innobase/include/lock0lock.h:
Removed unused code
innobase/include/mem0dbg.h:
Removed unused code
innobase/include/mem0mem.ic:
Removed unused code
innobase/include/mtr0log.h:
Removed unused code
innobase/include/mtr0mtr.h:
Removed unused code
innobase/include/os0proc.h:
Removed unused code
innobase/include/os0thread.h:
Removed unused code
innobase/include/rem0cmp.ic:
Removed unused code
innobase/include/row0row.h:
Removed unused code
innobase/include/srv0srv.h:
Removed unused code
innobase/include/sync0sync.h:
Removed unused code
innobase/lock/lock0lock.c:
Removed unused code
innobase/log/log0recv.c:
Removed unused code
innobase/mem/mem0dbg.c:
Removed unused code
innobase/mtr/mtr0mtr.c:
Removed unused code
innobase/os/os0proc.c:
Removed unused code
innobase/page/page0page.c:
Removed unused code
innobase/que/que0que.c:
Removed unused code
innobase/rem/rem0cmp.c:
Removed unused code
innobase/row/row0ins.c:
Removed unused code
innobase/row/row0mysql.c:
Removed unused code
innobase/row/row0row.c:
Removed unused code
innobase/srv/srv0srv.c:
Removed unused code
innobase/srv/srv0start.c:
Removed unused code
innobase/sync/sync0sync.c:
Removed unused code
innobase/trx/trx0rec.c:
Removed unused code
innobase/trx/trx0trx.c:
Removed unused code
innobase/ut/ut0dbg.c:
Removed unused code
innobase/ut/ut0mem.c:
Removed unused code
innobase/ut/ut0ut.c:
Removed unused code
Diffstat (limited to 'innobase/srv')
-rw-r--r-- | innobase/srv/srv0srv.c | 257 | ||||
-rw-r--r-- | innobase/srv/srv0start.c | 74 |
2 files changed, 3 insertions, 328 deletions
diff --git a/innobase/srv/srv0srv.c b/innobase/srv/srv0srv.c index 9f4c9228850..cea17e9f223 100644 --- a/innobase/srv/srv0srv.c +++ b/innobase/srv/srv0srv.c @@ -721,247 +721,9 @@ srv_get_thread_type(void) return(type); } -/*********************************************************************** -Increments by 1 the count of active threads of the type given -and releases master thread if necessary. */ -static -void -srv_inc_thread_count( -/*=================*/ - ulint type) /* in: type of the thread */ -{ - mutex_enter(&kernel_mutex); - - srv_activity_count++; - - srv_n_threads_active[type]++; - - if (srv_n_threads_active[SRV_MASTER] == 0) { - - srv_release_threads(SRV_MASTER, 1); - } - - mutex_exit(&kernel_mutex); -} - -/*********************************************************************** -Decrements by 1 the count of active threads of the type given. */ -static -void -srv_dec_thread_count( -/*=================*/ - ulint type) /* in: type of the thread */ - -{ - mutex_enter(&kernel_mutex); - - /* FIXME: the following assertion sometimes fails: */ - - if (srv_n_threads_active[type] == 0) { - printf("Error: thread type %lu\n", type); - - ut_ad(0); - } - - srv_n_threads_active[type]--; - - mutex_exit(&kernel_mutex); -} - -/*********************************************************************** -Calculates the number of allowed utility threads for a thread to decide if -it has to suspend itself in the thread table. */ -static -ulint -srv_max_n_utilities( -/*================*/ - /* out: maximum number of allowed utilities - of the type given */ - ulint type) /* in: utility type */ -{ - ulint ret; - - if (srv_n_threads_active[SRV_COM] == 0) { - if (srv_meter[type] > srv_meter_low_water[type]) { - return(srv_n_threads[type] / 2); - } else { - return(0); - } - } else { - - if (srv_meter[type] < srv_meter_foreground[type]) { - return(0); - } - ret = 1 + ((srv_n_threads[type] - * (ulint)(srv_meter[type] - srv_meter_foreground[type])) - / (ulint)(1000 - srv_meter_foreground[type])); - if (ret > srv_n_threads[type]) { - return(srv_n_threads[type]); - } else { - return(ret); - } - } -} - -/*********************************************************************** -Increments the utility meter by the value given and releases utility -threads if necessary. */ - -void -srv_increment_meter( -/*================*/ - ulint type, /* in: utility type */ - ulint n) /* in: value to add to meter */ -{ - ulint m; - - mutex_enter(&kernel_mutex); - - srv_meter[type] += n; - - m = srv_max_n_utilities(type); - - if (m > srv_n_threads_active[type]) { - - srv_release_threads(type, m - srv_n_threads_active[type]); - } - - mutex_exit(&kernel_mutex); -} - -/*********************************************************************** -Releases max number of utility threads if no queries are active and -the high-water mark for the utility is exceeded. */ - -void -srv_release_max_if_no_queries(void) -/*===============================*/ -{ - ulint m; - ulint type; - - mutex_enter(&kernel_mutex); - - if (srv_n_threads_active[SRV_COM] > 0) { - mutex_exit(&kernel_mutex); - - return; - } - - type = SRV_RECOVERY; - - m = srv_n_threads[type] / 2; - - if ((srv_meter[type] > srv_meter_high_water[type]) - && (srv_n_threads_active[type] < m)) { - - srv_release_threads(type, m - srv_n_threads_active[type]); - - printf("Releasing max background\n"); - } - - mutex_exit(&kernel_mutex); -} - -/************************************************************************* -Creates the first communication endpoint for the server. This -first call also initializes the com0com.* module. */ - -void -srv_communication_init( -/*===================*/ - char* endpoint) /* in: server address */ -{ - ulint ret; - ulint len; - - srv_sys->endpoint = com_endpoint_create(COM_SHM); - - ut_a(srv_sys->endpoint); - - len = ODBC_DATAGRAM_SIZE; - - ret = com_endpoint_set_option(srv_sys->endpoint, - COM_OPT_MAX_DGRAM_SIZE, - (byte*)&len, sizeof(ulint)); - ut_a(ret == 0); - - ret = com_bind(srv_sys->endpoint, endpoint, ut_strlen(endpoint)); - - ut_a(ret == 0); -} - -/************************************************************************* -Creates the utility threads. */ - -void -srv_create_utility_threads(void) -/*============================*/ -{ -/* os_thread_t thread; - os_thread_id_t thr_id; */ - ulint i; - - mutex_enter(&kernel_mutex); - - srv_n_threads[SRV_RECOVERY] = 1; - srv_n_threads_active[SRV_RECOVERY] = 1; - - mutex_exit(&kernel_mutex); - - for (i = 0; i < 1; i++) { - /* thread = os_thread_create(srv_recovery_thread, NULL, &thr_id); */ - - /* ut_a(thread); */ - } - -/* thread = os_thread_create(srv_purge_thread, NULL, &thr_id); - - ut_a(thread); */ -} - -/************************************************************************* -Creates the communication threads. */ - -void -srv_create_com_threads(void) -/*========================*/ -{ - /* os_thread_t thread; - os_thread_id_t thr_id; */ - ulint i; - - srv_n_threads[SRV_COM] = srv_n_com_threads; - - for (i = 0; i < srv_n_com_threads; i++) { - /* thread = os_thread_create(srv_com_thread, NULL, &thr_id); */ - /* ut_a(thread); */ - } -} - -/************************************************************************* -Creates the worker threads. */ - -void -srv_create_worker_threads(void) -/*===========================*/ -{ -/* os_thread_t thread; - os_thread_id_t thr_id; */ - ulint i; - - srv_n_threads[SRV_WORKER] = srv_n_worker_threads; - srv_n_threads_active[SRV_WORKER] = srv_n_worker_threads; - - for (i = 0; i < srv_n_worker_threads; i++) { - /* thread = os_thread_create(srv_worker_thread, NULL, &thr_id); */ - /* ut_a(thread); */ - } -} - /************************************************************************* Initializes the server. */ - +static void srv_init(void) /*==========*/ @@ -1762,13 +1524,13 @@ srv_sprintf_innodb_monitor( #ifdef UNIV_LINUX buf += sprintf(buf, - "Main thread process no. %lu, id %lu, state: %s\n", + "Main thread process no. %lu, id %lu, state: %.29s\n", srv_main_thread_process_no, srv_main_thread_id, srv_main_thread_op_info); #else buf += sprintf(buf, - "Main thread id %lu, state: %s\n", + "Main thread id %lu, state: %.29s\n", srv_main_thread_id, srv_main_thread_op_info); #endif @@ -2018,13 +1780,6 @@ loop: srv_refresh_innodb_monitor_stats(); } -/* mem_print_new_info(); - - if (cnt % 10 == 0) { - - mem_print_info(); - } -*/ sync_array_print_long_waits(); /* Flush stdout and stderr so that a database user gets their output @@ -2490,12 +2245,6 @@ flush_loop: goto background_loop; } -/* mem_print_new_info(); - */ - -#ifdef UNIV_SEARCH_PERF_STAT -/* btr_search_print_info(); */ -#endif /* There is no work for background operations either: suspend master thread to wait for more server activity */ diff --git a/innobase/srv/srv0start.c b/innobase/srv/srv0start.c index b7606685607..d5e92422d88 100644 --- a/innobase/srv/srv0start.c +++ b/innobase/srv/srv0start.c @@ -868,80 +868,6 @@ open_or_create_data_files( return(DB_SUCCESS); } -#ifdef notdefined -/********************************************************************* -This thread is used to measure contention of latches. */ -static -ulint -test_measure_cont( -/*==============*/ - void* arg) -{ - ulint i, j; - ulint pcount, kcount, s_scount, s_xcount, s_mcount, lcount; - - UT_NOT_USED(arg); - - fprintf(stderr, "Starting contention measurement\n"); - - for (i = 0; i < 1000; i++) { - - pcount = 0; - kcount = 0; - s_scount = 0; - s_xcount = 0; - s_mcount = 0; - lcount = 0; - - for (j = 0; j < 100; j++) { - - if (srv_measure_by_spin) { - ut_delay(ut_rnd_interval(0, 20000)); - } else { - os_thread_sleep(20000); - } - - if (kernel_mutex.lock_word) { - kcount++; - } - - if (buf_pool->mutex.lock_word) { - pcount++; - } - - if (log_sys->mutex.lock_word) { - lcount++; - } - - if (btr_search_latch.reader_count) { - s_scount++; - } - - if (btr_search_latch.writer != RW_LOCK_NOT_LOCKED) { - s_xcount++; - } - - if (btr_search_latch.mutex.lock_word) { - s_mcount++; - } - } - - fprintf(stderr, - "Mutex res. l %lu, p %lu, k %lu s x %lu s s %lu s mut %lu of %lu\n", - lcount, pcount, kcount, s_xcount, s_scount, s_mcount, j); - -/* sync_print_wait_info(); */ - - fprintf(stderr, - "log i/o %lu n non sea %lu n succ %lu n h fail %lu\n", - log_sys->n_log_ios, btr_cur_n_non_sea, - btr_search_n_succ, btr_search_n_hash_fail); - } - - return(0); -} -#endif - /******************************************************************** Starts InnoDB and creates a new database if database files are not found and the user wants. Server parameters are |