Subordination
A framework for distributed programming
sbn::socket_pipeline< K, S, R > Member List

This is the complete list of members for sbn::socket_pipeline< K, S, R >, including all inherited members.

_handlers (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >protected
_kernels (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >protected
_mutex (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >mutableprotected
_name (defined in sbn::pipeline_base)sbn::pipeline_baseprotected
_number (defined in sbn::pipeline_base)sbn::pipeline_baseprotected
_semaphore (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >mutableprotected
_start (defined in sbn::pipeline_base)sbn::pipeline_baseprotected
_start_timeout (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >protected
_state (defined in sbn::pipeline_base)sbn::pipeline_baseprotected
_threads (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >protected
add_client(const sys::socket_address &addr) (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >inline
add_server(const ifaddr_type &rhs) (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >inline
add_server(const sys::socket_address &rhs, addr_type netmask) (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
addr_type typedef (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
base_pipeline typedef (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
basic_pipeline()=default (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >
basic_pipeline(unsigned concurrency) noexcept (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >inlineexplicit
basic_pipeline(basic_pipeline &&rhs) noexcept (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >inline
basic_pipeline(const basic_pipeline &)=delete (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >
basic_socket_pipeline(basic_socket_pipeline &&rhs) noexcept (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inline
basic_socket_pipeline() (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inline
basic_socket_pipeline(const basic_socket_pipeline &)=delete (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
clock_type typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
concurrency() const noexcept (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >inline
do_run() override (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inlineprotectedvirtual
duration typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
emplace_handler(const sys::epoll_event &ev, const event_handler_ptr &ptr) (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inlineprotected
emplace_handler(const sys::epoll_event &ev, const std::shared_ptr< X > &ptr) (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inlineprotected
emplace_notify_handler(const event_handler_ptr &ptr) (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inlineprotected
emplace_notify_handler(const std::shared_ptr< X > &ptr) (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inlineprotected
forward(foreign_kernel *hdr) (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
handler_const_iterator typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
handler_container_type typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
handler_type typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
has_start_time_point() const noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
has_started() const noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
has_stopped() const noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
ifaddr_type typedef (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
is_running() const noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
is_starting() const noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
is_stopping() const noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
kernel_pool typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
kernel_sack typedef (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >protected
kernel_type typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
local_server (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >friend
lock_type typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
log(const Args &... args) const (defined in sbn::pipeline_base)sbn::pipeline_baseinline
log_error(const std::exception &err) const (defined in sbn::pipeline_base)sbn::pipeline_baseinline
mutex() noexcept (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inline
mutex_type typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
name() const noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
operator=(const socket_pipeline &)=delete (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
operator=(socket_pipeline &&)=delete (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
operator=(const basic_socket_pipeline &)=delete (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
operator=(const basic_pipeline &)=delete (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >
operator=(pipeline_base &)=delete (defined in sbn::pipeline_base)sbn::pipeline_base
other_mutex() noexcept (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inline
pipeline_base()=default (defined in sbn::pipeline_base)sbn::pipeline_base
pipeline_base(pipeline_base &&)=default (defined in sbn::pipeline_base)sbn::pipeline_base
pipeline_base(const pipeline_base &)=delete (defined in sbn::pipeline_base)sbn::pipeline_base
poller() noexcept (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inlineprotected
poller() const noexcept (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inlineprotected
port() const noexcept (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >inline
print_state(std::ostream &out) (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
queue_popper typedef (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >protected
remote_client (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >friend
remote_client_type typedef (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
remove_server(const ifaddr_type &interface_address) (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
router_type typedef (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
run(Thread_context *) overridesbn::basic_socket_pipeline< K >inlineprotectedvirtual
sem_type typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
send(kernel_type *k) (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >inline
send(kernel_type **kernels, size_t n) (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >inline
server_ptr typedef (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
server_type typedef (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
servers_begin() const noexcept (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >inline
servers_end() const noexcept (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >inline
set_client_weight(const sys::socket_address &addr, weight_type new_weight) (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
set_name(const char *rhs) noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
set_number(unsigned rhs) noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
set_other_mutex(mutex_type *rhs) noexcept (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inline
set_port(sys::port_type rhs) noexcept (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >inline
set_start_timeout(const duration &rhs) noexcept (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >inlineprotected
setstate(pipeline_state rhs) noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
socket_notify_handler (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >friend
socket_pipeline() (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
socket_pipeline(const socket_pipeline &)=delete (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
socket_pipeline(socket_pipeline &&)=delete (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
socket_type typedef (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
start() (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >inline
start_time_point() const noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
state() const noexcept (defined in sbn::pipeline_base)sbn::pipeline_baseinline
stop() (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >inline
stop_client(const sys::socket_address &addr) (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >
thread_pool typedef (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >
time_point typedef (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
use_localhost(bool b) noexcept (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >inline
wait() (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >inline
xstop() (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >inlineprotected
~basic_pipeline() (defined in sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >)sbn::basic_pipeline< T, Kernels, Traits, Threads, Mutex, Lock, Semaphore >inline
~basic_socket_pipeline()=default (defined in sbn::basic_socket_pipeline< K >)sbn::basic_socket_pipeline< K >
~pipeline_base()=default (defined in sbn::pipeline_base)sbn::pipeline_basevirtual
~socket_pipeline()=default (defined in sbn::socket_pipeline< K, S, R >)sbn::socket_pipeline< K, S, R >