PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V > Class Template Reference

#include <pfs_buffer_container.h>

Public Types
typedef T	value_type
	Type of elements in the buffer. More...
typedef U	array_type
	Type of pages in the buffer. More...
typedef V	allocator_type
typedef PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >	container_type
	This container type. More...
typedef PFS_buffer_const_iterator< T >	const_iterator_type
typedef PFS_buffer_scalable_iterator< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >	iterator_type
typedef PFS_buffer_processor< T >	processor_type
typedef void(*	function_type) (value_type *)

Public Member Functions
	PFS_buffer_scalable_container (allocator_type *allocator)
int	init (long max_size)
void	cleanup ()
size_t	get_row_count ()
size_t	get_row_size () const
size_t	get_memory ()
value_type *	allocate (pfs_dirty_state *dirty_state)
void	dirty_to_free (pfs_dirty_state *dirty_state, value_type *safe_pfs)
void	deallocate (value_type *safe_pfs)
iterator_type	iterate ()
iterator_type	iterate (uint index)
void	apply (function_type fct)
void	apply_all (function_type fct)
void	apply (processor_type &proc)
void	apply_all (processor_type &proc)
value_type *	get (uint index)
value_type *	get (uint index, bool *has_more)
value_type *	sanitize (value_type *unsafe)

Static Public Member Functions
static void	static_deallocate (value_type *safe_pfs)

Public Attributes
ulong	m_lost

Static Public Attributes
static const size_t	MAX_SIZE = PFS_PAGE_SIZE * PFS_PAGE_COUNT

Private Member Functions
uint	get_page_logical_size (uint page_index)
value_type *	scan_next (uint &index, uint *found_index)

Private Attributes
bool	m_initialized
bool	m_full
size_t	m_max
PFS_cacheline_atomic_size_t	m_monotonic
PFS_cacheline_atomic_size_t	m_max_page_index
size_t	m_max_page_count
size_t	m_last_page_size
std::atomic< array_type * >	m_pages [PFS_PAGE_COUNT]
allocator_type *	m_allocator
native_mutex_t	m_critical_section

Friends
class	PFS_buffer_scalable_iterator< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >

Member Typedef Documentation

allocator_type

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

typedef V PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::allocator_type

array_type

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

typedef U PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::array_type

Type of pages in the buffer.

The following attributes are required:

• PFS_opaque_container *m_container 

const_iterator_type

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

typedef PFS_buffer_const_iterator<T> PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::const_iterator_type

container_type

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

typedef PFS_buffer_scalable_container<T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V> PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::container_type

This container type.

function_type

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

typedef void(* PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::function_type) (value_type *)

iterator_type

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

typedef PFS_buffer_scalable_iterator<T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V> PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::iterator_type

processor_type

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

typedef PFS_buffer_processor<T> PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::processor_type

value_type

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

typedef T PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::value_type

Type of elements in the buffer.

The following attributes are required:

• pfs_lock m_lock 

• PFS_opaque_container_page *m_page 

Constructor & Destructor Documentation

PFS_buffer_scalable_container()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::PFS_buffer_scalable_container ( allocator_type *  allocator )

inlineexplicit

Member Function Documentation

allocate()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

value_type * PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::allocate ( pfs_dirty_state *  dirty_state )

inline

apply() [1/2]

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

void PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::apply ( function_type  fct )

inline

apply() [2/2]

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

void PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::apply ( processor_type &  proc )

inline

apply_all() [1/2]

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

void PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::apply_all ( function_type  fct )

inline

apply_all() [2/2]

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

void PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::apply_all ( processor_type &  proc )

inline

cleanup()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

void PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::cleanup ( void  )

inline

deallocate()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

void PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::deallocate ( value_type *  safe_pfs )

inline

dirty_to_free()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

void PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::dirty_to_free ( pfs_dirty_state *  dirty_state, value_type *  safe_pfs  )

inline

get() [1/2]

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

value_type * PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::get ( uint  index )

inline

get() [2/2]

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

value_type * PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::get ( uint  index, bool *  has_more  )

inline

get_memory()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

size_t PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::get_memory ( )

inline

get_page_logical_size()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

uint PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::get_page_logical_size ( uint  page_index )

inlineprivate

get_row_count()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

size_t PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::get_row_count ( )

inline

get_row_size()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

size_t PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::get_row_size ( ) const

inline

init()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

int PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::init ( long  max_size )

inline

iterate() [1/2]

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

iterator_type PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::iterate ( )

inline

iterate() [2/2]

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

iterator_type PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::iterate ( uint  index )

inline

sanitize()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

value_type * PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::sanitize ( value_type *  unsafe )

inline

scan_next()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

value_type * PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::scan_next ( uint &  index, uint *  found_index  )

inlineprivate

static_deallocate()

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

static void PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::static_deallocate ( value_type *  safe_pfs )

inlinestatic

Friends And Related Function Documentation

PFS_buffer_scalable_iterator< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

friend class PFS_buffer_scalable_iterator< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >

friend

Member Data Documentation

m_allocator

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

allocator_type* PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_allocator

private

m_critical_section

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

native_mutex_t PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_critical_section

private

m_full

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

bool PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_full

private

m_initialized

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

bool PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_initialized

private

m_last_page_size

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

size_t PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_last_page_size

private

m_lost

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

ulong PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_lost

m_max

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

size_t PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_max

private

m_max_page_count

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

size_t PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_max_page_count

private

m_max_page_index

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

PFS_cacheline_atomic_size_t PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_max_page_index

private

m_monotonic

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

PFS_cacheline_atomic_size_t PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_monotonic

private

m_pages

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

std::atomic<array_type *> PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::m_pages[PFS_PAGE_COUNT]

private

MAX_SIZE

template<class T , int PFS_PAGE_SIZE, int PFS_PAGE_COUNT, class U = PFS_buffer_default_array<T>, class V = PFS_buffer_default_allocator<T>>

const size_t PFS_buffer_scalable_container< T, PFS_PAGE_SIZE, PFS_PAGE_COUNT, U, V >::MAX_SIZE = PFS_PAGE_SIZE * PFS_PAGE_COUNT

static

---

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

• storage/perfschema/pfs_buffer_container.h