C++ Actor Framework  0.18
Classes | Public Types | Public Member Functions | Static Public Member Functions | List of all members
caf::policy::downstream_messages Class Reference

Configures a dynamic WDRR queue for holding downstream messages. More...

#include <downstream_messages.hpp>

Collaboration diagram for caf::policy::downstream_messages:
Collaboration graph


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_messagesoperator= (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

Detailed Description

Configures a dynamic WDRR queue for holding downstream messages.

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