Flush_observer Class Reference

We use Flush_observer to track flushing of non-redo logged pages in bulk create index(btr0load.cc).Since we disable redo logging during a index build, we need to make sure that all dirty pages modified by the index build are flushed to disk before any redo logged operations go to the index. More...

#include <buf0flu.h>

Public Member Functions
	Flush_observer (const trx_t &trx, Alter_stage *stage) noexcept
	Constructor. More...
	~Flush_observer () noexcept
	Destructor. More...
std::ostream &	print (std::ostream &out) const
	Print information about the current object. More...
bool	is_complete (size_t instance_no)
	Check pages have been flushed and removed from the flush list in a buffer pool instance. More...
void	interrupted ()
	Interrupt observer not to wait. More...
bool	check_interrupted ()
	Check whether trx is interrupted. More...
void	flush ()
	Flush dirty pages. More...
void	notify_flush (buf_pool_t *buf_pool, buf_page_t *bpage)
	Notify observer of flushing a page. More...
void	notify_remove (buf_pool_t *buf_pool, buf_page_t *bpage)
	Notify observer of removing a page from flush list. More...
const trx_t &	get_trx () const
	Returns the transaction the observer was created for. More...

Private Types
using	Counter = std::atomic_int
using	Counters = std::vector< Counter, ut::allocator< Counter > >

Private Member Functions
bool	validate () const noexcept

Private Attributes
const trx_t &	m_trx
	Trx instance. More...
Alter_stage *	m_stage {}
	Performance schema accounting object, used by ALTER TABLE. More...
Counters	m_flushed {}
	Flush request sent, per buffer pool. More...
Counters	m_removed {}
	Flush request finished, per buffer pool. More...
Counter	m_n_ref_count {}
	Number of pages using this instance. More...
bool	m_interrupted {}
	True if the operation was interrupted. More...

Detailed Description

We use Flush_observer to track flushing of non-redo logged pages in bulk create index(btr0load.cc).Since we disable redo logging during a index build, we need to make sure that all dirty pages modified by the index build are flushed to disk before any redo logged operations go to the index.

Member Typedef Documentation

Counter

using Flush_observer::Counter = std::atomic_int

private

Counters

using Flush_observer::Counters = std::vector<Counter, ut::allocator<Counter> >

private

Constructor & Destructor Documentation

Flush_observer()

Flush_observer::Flush_observer ( const trx_t &  trx, Alter_stage *  stage  )

noexcept

Constructor.

Parameters

[in]	trx	trx instance
[in,out]	stage	PFS progress monitoring instance, it's used by ALTER TABLE. It is passed to log_preflush_pool_modified_pages() for accounting.

~Flush_observer()

Flush_observer::~Flush_observer ( )

noexcept

Destructor.

Member Function Documentation

check_interrupted()

bool Flush_observer::check_interrupted

(

)

Check whether trx is interrupted.

Returns

true if trx is interrupted

flush()

void Flush_observer::flush

(

)

Flush dirty pages.

get_trx()

const trx_t & Flush_observer::get_trx ( ) const

inline

Returns the transaction the observer was created for.

interrupted()

void Flush_observer::interrupted ( )

inline

Interrupt observer not to wait.

is_complete()

bool Flush_observer::is_complete ( size_t  instance_no )

inline

Check pages have been flushed and removed from the flush list in a buffer pool instance.

Parameters

[in]

instance_no

buffer pool instance no

Returns

true if the pages were removed from the flush list

notify_flush()

void Flush_observer::notify_flush	(	buf_pool_t *	buf_pool,
		buf_page_t *	bpage
	)

Notify observer of flushing a page.

Parameters

[in]	buf_pool	buffer pool instance
[in]	bpage	buffer page to flush

notify_remove()

void Flush_observer::notify_remove	(	buf_pool_t *	buf_pool,
		buf_page_t *	bpage
	)

Notify observer of removing a page from flush list.

Parameters

[in]	buf_pool	buffer pool instance
[in]	bpage	buffer page flushed

print()

std::ostream & Flush_observer::print

(

std::ostream &

out

)

const

Print information about the current object.

Parameters

[in,out]

out

output stream to be used.

Returns

the output stream.

validate()

bool Flush_observer::validate ( ) const

privatenoexcept

Member Data Documentation

m_flushed

Counters Flush_observer::m_flushed {}

private

Flush request sent, per buffer pool.

m_interrupted

bool Flush_observer::m_interrupted {}

private

True if the operation was interrupted.

m_n_ref_count

Counter Flush_observer::m_n_ref_count {}

private

Number of pages using this instance.

m_removed

Counters Flush_observer::m_removed {}

private

Flush request finished, per buffer pool.

m_stage

Alter_stage* Flush_observer::m_stage {}

private

Performance schema accounting object, used by ALTER TABLE.

If not nullptr, then stage->begin_phase_flush() will be called initially, specifying the number of pages to be attempted to be flushed and subsequently, stage->inc() will be called for each page we attempt to flush.

m_trx

const trx_t& Flush_observer::m_trx

private

Trx instance.

---

The documentation for this class was generated from the following files:

• storage/innobase/include/buf0flu.h
• storage/innobase/buf/buf0flu.cc