|
Apache Mesos
|
#include <socket_manager.hpp>
Public Member Functions | |
| SocketManager () | |
| ~SocketManager () | |
| void | finalize () |
| void | accepted (const network::inet::Socket &socket) |
| void | link (ProcessBase *process, const UPID &to, const ProcessBase::RemoteConnection remote, const network::internal::SocketImpl::Kind &kind=network::internal::SocketImpl::DEFAULT_KIND()) |
| Option< int_fd > | get_persistent_socket (const UPID &to) |
| PID< HttpProxy > | proxy (const network::inet::Socket &socket) |
| void | unproxy (const network::inet::Socket &socket) |
| void | send (Encoder *encoder, bool persist, const network::inet::Socket &socket) |
| void | send (const http::Response &response, const http::Request &request, const network::inet::Socket &socket) |
| void | send (Message &&message, const network::internal::SocketImpl::Kind &kind=network::internal::SocketImpl::DEFAULT_KIND()) |
| Encoder * | next (int_fd s) |
| void | close (int_fd s) |
| void | exited (const network::inet::Address &address) |
| void | exited (ProcessBase *process) |
| process::SocketManager::SocketManager | ( | ) |
| process::SocketManager::~SocketManager | ( | ) |
| void process::SocketManager::accepted | ( | const network::inet::Socket & | socket | ) |
| void process::SocketManager::close | ( | int_fd | s | ) |
| void process::SocketManager::exited | ( | const network::inet::Address & | address | ) |
| void process::SocketManager::exited | ( | ProcessBase * | process | ) |
| void process::SocketManager::finalize | ( | ) |
| void process::SocketManager::link | ( | ProcessBase * | process, |
| const UPID & | to, | ||
| const ProcessBase::RemoteConnection | remote, | ||
| const network::internal::SocketImpl::Kind & | kind = network::internal::SocketImpl::DEFAULT_KIND() |
||
| ) |
| PID<HttpProxy> process::SocketManager::proxy | ( | const network::inet::Socket & | socket | ) |
| void process::SocketManager::send | ( | Encoder * | encoder, |
| bool | persist, | ||
| const network::inet::Socket & | socket | ||
| ) |
| void process::SocketManager::send | ( | const http::Response & | response, |
| const http::Request & | request, | ||
| const network::inet::Socket & | socket | ||
| ) |
| void process::SocketManager::send | ( | Message && | message, |
| const network::internal::SocketImpl::Kind & | kind = network::internal::SocketImpl::DEFAULT_KIND() |
||
| ) |
| void process::SocketManager::unproxy | ( | const network::inet::Socket & | socket | ) |
| hashmap<ProcessBase*, hashset<UPID> > process::SocketManager::linkees |
| hashmap<UPID, hashset<ProcessBase*> > process::SocketManager::linkers |
| hashmap<network::inet::Address, hashset<UPID> > process::SocketManager::remotes |
1.8.5