fastmm::store::StoreThread Class Reference

#include <fastmm/store/store_thread.hpp>

Public Member Functions
	StoreThread (MsgRing &ring, std::unique_ptr< Backend > backend, const StoreThreadOptions &opts={})
	~StoreThread ()
	StoreThread (const StoreThread &)=delete
StoreThread &	operator= (const StoreThread &)=delete
Backend &	backend () noexcept
void	start ()
	spawns the drain thread
void	stop ()
	joins, drains what is left, commits
std::size_t	drain_once ()
	Single-threaded driving (tests): drains and commits everything the ring holds now.
StoreThreadStats	stats () const noexcept

Constructor & Destructor Documentation

StoreThread() [1/2]

fastmm::store::StoreThread::StoreThread	(	MsgRing &	ring,
		std::unique_ptr< Backend >	backend,
		const StoreThreadOptions &	opts = {}
	)

~StoreThread()

fastmm::store::StoreThread::~StoreThread

(

)

StoreThread() [2/2]

fastmm::store::StoreThread::StoreThread ( const StoreThread &  )

delete

Member Function Documentation

operator=()

StoreThread & fastmm::store::StoreThread::operator= ( const StoreThread &  )

delete

backend()

Backend & fastmm::store::StoreThread::backend ( )

inlinenoexcept

start()

void fastmm::store::StoreThread::start

(

)

spawns the drain thread

stop()

void fastmm::store::StoreThread::stop

(

)

joins, drains what is left, commits

drain_once()

std::size_t fastmm::store::StoreThread::drain_once

(

)

Single-threaded driving (tests): drains and commits everything the ring holds now.

stats()

StoreThreadStats fastmm::store::StoreThread::stats ( ) const

noexcept