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 |