C++ Actor Framework 0.18
|
Configures a dynamic WDRR queue for holding downstream messages. More...
#include <downstream_messages.hpp>
Classes | |
class | nested |
Configures a nested DRR queue. More... | |
Public Types | |
using | mapped_type = mailbox_element |
using | task_size_type = size_t |
using | deficit_type = size_t |
using | pointer = mapped_type * |
using | unique_pointer = mailbox_element_ptr |
using | key_type = stream_slot |
using | nested_queue_type = intrusive::drr_queue< nested > |
using | queue_map_type = std::map< key_type, nested_queue_type > |
Public Member Functions | |
downstream_messages (const downstream_messages &)=default | |
downstream_messages & | operator= (const downstream_messages &)=default |
constexpr | downstream_messages (unit_t) |
Static Public Member Functions | |
static key_type | id_of (mailbox_element &x) noexcept |
static bool | enabled (const nested_queue_type &q) noexcept |
static deficit_type | quantum (const nested_queue_type &q, deficit_type x) noexcept |
static task_size_type | task_size (const mailbox_element &) noexcept |
static void | cleanup (nested_queue_type &) noexcept |
static bool | push_back (nested_queue_type &sub_queue, pointer ptr) noexcept |
static void | lifo_append (nested_queue_type &sub_queue, pointer ptr) noexcept |
static void | stop_lifo_append (nested_queue_type &sub_queue) noexcept |
Configures a dynamic WDRR queue for holding downstream messages.