iroha::subscription::IDispatcher Struct Reference

#include "dispatcher.hpp"

Inheritance diagram for iroha::subscription::IDispatcher:

Collaboration diagram for iroha::subscription::IDispatcher:

Public Types
using	Tid = uint32_t
using	Task = IScheduler::Task

Public Member Functions
virtual	~IDispatcher ()
virtual std::optional< Tid >	bind (std::shared_ptr< IScheduler > scheduler)=0
virtual bool	unbind (Tid tid)=0
virtual void	dispose ()=0
virtual void	add (Tid tid, Task &&task)=0
virtual void	addDelayed (Tid tid, std::chrono::microseconds timeout, Task &&task)=0

Static Public Attributes
static constexpr Tid	kExecuteInPool = std::numeric_limits<Tid>::max()

Member Typedef Documentation

Task

using iroha::subscription::IDispatcher::Task = IScheduler::Task

Tid

using iroha::subscription::IDispatcher::Tid = uint32_t

Constructor & Destructor Documentation

~IDispatcher()

virtual iroha::subscription::IDispatcher::~IDispatcher ( )

inlinevirtual

Here is the call graph for this function:

Member Function Documentation

add()

virtual void iroha::subscription::IDispatcher::add ( Tid  tid, Task &&  task  )

pure virtual

Implemented in iroha::subscription::AsyncDispatcher< kCount, kPoolSize >, and iroha::subscription::SyncDispatcher< kCount, kPoolSize >.

Here is the caller graph for this function:

addDelayed()

virtual void iroha::subscription::IDispatcher::addDelayed ( Tid  tid, std::chrono::microseconds  timeout, Task &&  task  )

pure virtual

Implemented in iroha::subscription::AsyncDispatcher< kCount, kPoolSize >, and iroha::subscription::SyncDispatcher< kCount, kPoolSize >.

Here is the caller graph for this function:

bind()

virtual std::optional<Tid> iroha::subscription::IDispatcher::bind ( std::shared_ptr< IScheduler >  scheduler )

pure virtual

Implemented in iroha::subscription::AsyncDispatcher< kCount, kPoolSize >, and iroha::subscription::SyncDispatcher< kCount, kPoolSize >.

Here is the caller graph for this function:

dispose()

virtual void iroha::subscription::IDispatcher::dispose ( )

pure virtual

Implemented in iroha::subscription::AsyncDispatcher< kCount, kPoolSize >, and iroha::subscription::SyncDispatcher< kCount, kPoolSize >.

Here is the caller graph for this function:

unbind()

virtual bool iroha::subscription::IDispatcher::unbind ( Tid  tid )

pure virtual

Implemented in iroha::subscription::AsyncDispatcher< kCount, kPoolSize >, and iroha::subscription::SyncDispatcher< kCount, kPoolSize >.

Here is the caller graph for this function:

Member Data Documentation

kExecuteInPool

constexpr Tid iroha::subscription::IDispatcher::kExecuteInPool = std::numeric_limits<Tid>::max()

static

---

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

• irohad/subscription/dispatcher.hpp