Apache Mesos
Public Member Functions | List of all members
process::SocketManager Class Reference

#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_fdget_persistent_socket (const UPID &to)
 
PID< HttpProxyproxy (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())
 
Encodernext (int_fd s)
 
void close (int_fd s)
 
void exited (const network::inet::Address &address)
 
void exited (ProcessBase *process)
 

Constructor & Destructor Documentation

process::SocketManager::SocketManager ( )
process::SocketManager::~SocketManager ( )

Member Function Documentation

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 ( )
Option<int_fd> process::SocketManager::get_persistent_socket ( const UPID to)
void process::SocketManager::link ( ProcessBase process,
const UPID to,
const ProcessBase::RemoteConnection  remote,
const network::internal::SocketImpl::Kind kind = network::internal::SocketImpl::DEFAULT_KIND() 
)
Encoder* process::SocketManager::next ( int_fd  s)
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)

Member Data Documentation

hashmap<ProcessBase*, hashset<UPID> > process::SocketManager::linkees
hashmap<UPID, hashset<ProcessBase*> > process::SocketManager::linkers
hashmap<network::inet::Address, hashset<UPID> > process::SocketManager::remotes

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