buf0flu.h

Go to the documentation of this file.

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

Copyright (c) 1995, 2013, Oracle and/or its affiliates. All Rights Reserved.

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, Suite 500, Boston, MA 02110-1335 USA

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

/**************************************************/
#ifndef buf0flu_h
#define buf0flu_h

#include "univ.i"
#include "ut0byte.h"
#include "log0log.h"
#ifndef UNIV_HOTBACKUP
#include "mtr0types.h"
#include "buf0types.h"

extern ibool buf_page_cleaner_is_active;

/********************************************************************/
UNIV_INTERN
void
buf_flush_remove(
/*=============*/
        buf_page_t*     bpage); 
/*******************************************************************/
UNIV_INTERN
void
buf_flush_relocate_on_flush_list(
/*=============================*/
        buf_page_t*     bpage,  
        buf_page_t*     dpage); 
/********************************************************************/
UNIV_INTERN
void
buf_flush_write_complete(
/*=====================*/
        buf_page_t*     bpage); 
#endif /* !UNIV_HOTBACKUP */
/********************************************************************/
UNIV_INTERN
void
buf_flush_init_for_writing(
/*=======================*/
        byte*   page,           
        void*   page_zip_,      
        lsn_t   newest_lsn);    
#ifndef UNIV_HOTBACKUP
# if defined UNIV_DEBUG || defined UNIV_IBUF_DEBUG
/********************************************************************/
UNIV_INTERN
ibool
buf_flush_page_try(
/*===============*/
        buf_pool_t*     buf_pool,       
        buf_block_t*    block)          
        __attribute__((nonnull, warn_unused_result));
# endif /* UNIV_DEBUG || UNIV_IBUF_DEBUG */
/*******************************************************************/
UNIV_INTERN
bool
buf_flush_list(
/*===========*/
        ulint           min_n,          
        lsn_t           lsn_limit,      
        ulint*          n_processed);   
/******************************************************************/
UNIV_INTERN
ibool
buf_flush_single_page_from_LRU(
/*===========================*/
        buf_pool_t*     buf_pool);      
/******************************************************************/
UNIV_INTERN
void
buf_flush_wait_batch_end(
/*=====================*/
        buf_pool_t*     buf_pool,       
        buf_flush_t     type);          
/******************************************************************/
UNIV_INTERN
void
buf_flush_wait_batch_end_wait_only(
/*===============================*/
        buf_pool_t*     buf_pool,       
        buf_flush_t     type);          
/********************************************************************/
UNIV_INLINE
void
buf_flush_note_modification(
/*========================*/
        buf_block_t*    block,  
        mtr_t*          mtr);   
/********************************************************************/
UNIV_INLINE
void
buf_flush_recv_note_modification(
/*=============================*/
        buf_block_t*    block,          
        lsn_t           start_lsn,      
        lsn_t           end_lsn);       
/********************************************************************/
UNIV_INTERN
ibool
buf_flush_ready_for_replace(
/*========================*/
        buf_page_t*     bpage); 
/******************************************************************/
extern "C" UNIV_INTERN
os_thread_ret_t
DECLARE_THREAD(buf_flush_page_cleaner_thread)(
/*==========================================*/
        void*   arg);           
/*********************************************************************/
UNIV_INTERN
ulint
buf_flush_LRU_tail(void);
/*====================*/
/*********************************************************************/
UNIV_INTERN
void
buf_flush_wait_LRU_batch_end(void);
/*==============================*/

#if defined UNIV_DEBUG || defined UNIV_BUF_DEBUG
/******************************************************************/
UNIV_INTERN
ibool
buf_flush_validate(
/*===============*/
        buf_pool_t*     buf_pool);
#endif /* UNIV_DEBUG || UNIV_BUF_DEBUG */

/********************************************************************/
UNIV_INTERN
void
buf_flush_init_flush_rbt(void);
/*==========================*/

/********************************************************************/
UNIV_INTERN
void
buf_flush_free_flush_rbt(void);
/*==========================*/

/********************************************************************/
UNIV_INTERN
bool
buf_flush_page(
/*===========*/
        buf_pool_t*     buf_pool,       
        buf_page_t*     bpage,          
        buf_flush_t     flush_type,     
        bool            sync);          
/********************************************************************/
UNIV_INTERN
bool
buf_flush_ready_for_flush(
/*======================*/
        buf_page_t*     bpage,  
        buf_flush_t     flush_type)
        __attribute__((warn_unused_result));

#ifdef UNIV_DEBUG
/******************************************************************/
UNIV_INTERN
ulint
buf_pool_get_dirty_pages_count(
/*===========================*/
        buf_pool_t*     buf_pool,       
        ulint           id);            
/******************************************************************/
UNIV_INTERN
ulint
buf_flush_get_dirty_pages_count(
/*============================*/
        ulint           id);            
#endif /* UNIV_DEBUG */

#endif /* !UNIV_HOTBACKUP */

#ifndef UNIV_NONINL
#include "buf0flu.ic"
#endif

#endif