iroha::subscription::AsyncDispatcher< kCount, kPoolSize > Class Template Reference

#include "async_dispatcher_impl.hpp"

Inheritance diagram for iroha::subscription::AsyncDispatcher< kCount, kPoolSize >:

Collaboration diagram for iroha::subscription::AsyncDispatcher< kCount, kPoolSize >:

Public Member Functions
	AsyncDispatcher ()
void	dispose () override
void	add (typename Parent::Tid tid, typename Parent::Task &&task) override
void	addDelayed (typename Parent::Tid tid, std::chrono::microseconds timeout, typename Parent::Task &&task) override
std::optional< Tid >	bind (std::shared_ptr< IScheduler > scheduler) override
bool	unbind (Tid tid) override
Public Member Functions inherited from iroha::subscription::IDispatcher
virtual	~IDispatcher ()

Static Public Attributes
static constexpr uint32_t	kHandlersCount = kCount
static constexpr uint32_t	kPoolThreadsCount = kPoolSize
Static Public Attributes inherited from iroha::subscription::IDispatcher
static constexpr Tid	kExecuteInPool = std::numeric_limits<Tid>::max()

Additional Inherited Members
Public Types inherited from iroha::subscription::IDispatcher
using	Tid = uint32_t
using	Task = IScheduler::Task

Constructor & Destructor Documentation

AsyncDispatcher()

template<uint32_t kCount, uint32_t kPoolSize>

iroha::subscription::AsyncDispatcher< kCount, kPoolSize >::AsyncDispatcher ( )

inline

Member Function Documentation

add()

template<uint32_t kCount, uint32_t kPoolSize>

void iroha::subscription::AsyncDispatcher< kCount, kPoolSize >::add ( typename Parent::Tid  tid, typename Parent::Task &&  task  )

inlineoverridevirtual

Implements iroha::subscription::IDispatcher.

addDelayed()

template<uint32_t kCount, uint32_t kPoolSize>

void iroha::subscription::AsyncDispatcher< kCount, kPoolSize >::addDelayed ( typename Parent::Tid  tid, std::chrono::microseconds  timeout, typename Parent::Task &&  task  )

inlineoverridevirtual

Implements iroha::subscription::IDispatcher.

bind()

template<uint32_t kCount, uint32_t kPoolSize>

std::optional<Tid> iroha::subscription::AsyncDispatcher< kCount, kPoolSize >::bind ( std::shared_ptr< IScheduler >  scheduler )

inlineoverridevirtual

Implements iroha::subscription::IDispatcher.

Here is the call graph for this function:

dispose()

template<uint32_t kCount, uint32_t kPoolSize>

void iroha::subscription::AsyncDispatcher< kCount, kPoolSize >::dispose ( )

inlineoverridevirtual

Implements iroha::subscription::IDispatcher.

unbind()

template<uint32_t kCount, uint32_t kPoolSize>

bool iroha::subscription::AsyncDispatcher< kCount, kPoolSize >::unbind ( Tid  tid )

inlineoverridevirtual

Implements iroha::subscription::IDispatcher.

Here is the call graph for this function:

Member Data Documentation

kHandlersCount

template<uint32_t kCount, uint32_t kPoolSize>

constexpr uint32_t iroha::subscription::AsyncDispatcher< kCount, kPoolSize >::kHandlersCount = kCount

static

kPoolThreadsCount

template<uint32_t kCount, uint32_t kPoolSize>

constexpr uint32_t iroha::subscription::AsyncDispatcher< kCount, kPoolSize >::kPoolThreadsCount = kPoolSize

static

---

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

• irohad/subscription/async_dispatcher_impl.hpp