mirror of
https://github.com/MariaDB/server.git
synced 2025-01-31 02:51:44 +01:00
5e62b6a5e0
Almost all threads have gone - the "ticking" threads, that sleep a while then do some work) (srv_monitor_thread, srv_error_monitor_thread, srv_master_thread) were replaced with timers. Some timers are periodic, e.g the "master" timer. - The btr_defragment_thread is also replaced by a timer , which reschedules it self when current defragment "item" needs throttling - the buf_resize_thread and buf_dump_threads are substitutes with tasks Ditto with page cleaner workers. - purge workers threads are not tasks as well, and purge cleaner coordinator is a combination of a task and timer. - All AIO is outsourced to tpool, Innodb just calls thread_pool::submit_io() and provides the callback. - The srv_slot_t was removed, and innodb_debug_sync used in purge is currently not working, and needs reimplementation.
92 lines
3.5 KiB
C
92 lines
3.5 KiB
C
/*****************************************************************************
|
|
|
|
Copyright (C) 2013, 2014 Facebook, Inc. All Rights Reserved.
|
|
Copyright (C) 2014, 2017, MariaDB Corporation.
|
|
|
|
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.
|
|
|
|
This program is distributed in the hope that it will be useful, but WITHOUT
|
|
ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
|
FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License along with
|
|
this program; if not, write to the Free Software Foundation, Inc.,
|
|
51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA
|
|
|
|
*****************************************************************************/
|
|
|
|
#ifndef btr0defragment_h
|
|
#define btr0defragment_h
|
|
|
|
#include "btr0pcur.h"
|
|
|
|
/* Max number of pages to consider at once during defragmentation. */
|
|
#define BTR_DEFRAGMENT_MAX_N_PAGES 32
|
|
|
|
/** stats in btr_defragment */
|
|
extern Atomic_counter<ulint> btr_defragment_compression_failures;
|
|
extern Atomic_counter<ulint> btr_defragment_failures;
|
|
extern Atomic_counter<ulint> btr_defragment_count;
|
|
|
|
/** Item in the work queue for btr_degrament_thread. */
|
|
struct btr_defragment_item_t
|
|
{
|
|
btr_pcur_t* pcur; /* persistent cursor where
|
|
btr_defragment_n_pages should start */
|
|
os_event_t event; /* if not null, signal after work
|
|
is done */
|
|
bool removed; /* Mark an item as removed */
|
|
ulonglong last_processed; /* timestamp of last time this index
|
|
is processed by defragment thread */
|
|
|
|
btr_defragment_item_t(btr_pcur_t* pcur, os_event_t event);
|
|
~btr_defragment_item_t();
|
|
};
|
|
|
|
/******************************************************************//**
|
|
Initialize defragmentation. */
|
|
void
|
|
btr_defragment_init(void);
|
|
/******************************************************************//**
|
|
Shutdown defragmentation. */
|
|
void
|
|
btr_defragment_shutdown();
|
|
/******************************************************************//**
|
|
Check whether the given index is in btr_defragment_wq. */
|
|
bool
|
|
btr_defragment_find_index(
|
|
dict_index_t* index); /*!< Index to find. */
|
|
/******************************************************************//**
|
|
Add an index to btr_defragment_wq. Return a pointer to os_event if this
|
|
is a synchronized defragmentation. */
|
|
os_event_t
|
|
btr_defragment_add_index(
|
|
dict_index_t* index, /*!< index to be added */
|
|
bool async, /*!< whether this is an async
|
|
defragmentation */
|
|
dberr_t* err); /*!< out: error code */
|
|
/******************************************************************//**
|
|
When table is dropped, this function is called to mark a table as removed in
|
|
btr_efragment_wq. The difference between this function and the remove_index
|
|
function is this will not NULL the event. */
|
|
void
|
|
btr_defragment_remove_table(
|
|
dict_table_t* table); /*!< Index to be removed. */
|
|
/******************************************************************//**
|
|
Mark an index as removed from btr_defragment_wq. */
|
|
void
|
|
btr_defragment_remove_index(
|
|
dict_index_t* index); /*!< Index to be removed. */
|
|
/*********************************************************************//**
|
|
Check whether we should save defragmentation statistics to persistent storage.*/
|
|
UNIV_INTERN
|
|
void
|
|
btr_defragment_save_defrag_stats_if_needed(
|
|
dict_index_t* index); /*!< in: index */
|
|
|
|
/* Stop defragmentation.*/
|
|
void btr_defragment_end();
|
|
extern bool btr_defragment_active;
|
|
#endif
|