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

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_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: