NetworkProcess Class Reference

#include <network.hpp>

Inheritance diagram for NetworkProcess:

Public Member Functions
	NetworkProcess ()
	NetworkProcess (const std::set< process::UPID > &pids)
void	add (const process::UPID &pid)
void	remove (const process::UPID &pid)
void	set (const std::set< process::UPID > &_pids)
process::Future< size_t >	watch (size_t size, Network::WatchMode mode)
template<typename Req , typename Res >
std::set< process::Future< Res > >	broadcast (const Protocol< Req, Res > &protocol, const Req &req, const std::set< process::UPID > &filter)
template<typename M >
Nothing	broadcast (const M &m, const std::set< process::UPID > &filter)
Public Member Functions inherited from ProtobufProcess< NetworkProcess >
	~ProtobufProcess () override
Public Member Functions inherited from process::Process< NetworkProcess >
	~Process () override
PID< NetworkProcess >	self () const
	Returns the PID of the process. More...
Public Member Functions inherited from process::ProcessBase
	ProcessBase (const std::string &id="")
	~ProcessBase () override
const UPID &	self () const
Public Member Functions inherited from process::EventConsumer
virtual	~EventConsumer ()

Protected Member Functions
void	finalize () override
	Invoked when a process is terminated. More...
Protected Member Functions inherited from ProtobufProcess< NetworkProcess >
void	consume (process::MessageEvent &&event) override
void	send (const process::UPID &to, const google::protobuf::Message &message)
void	reply (const google::protobuf::Message &message)
void	install (void(NetworkProcess::*method)(const process::UPID &, const M &))
void	install (void(NetworkProcess::*method)(const process::UPID &, M &&))
void	install (void(NetworkProcess::*method)(const process::UPID &))
void	install (void(NetworkProcess::*method)(const process::UPID &, PC...), MessageProperty< M, P >...param)
void	install (void(NetworkProcess::*method)(const M &))
void	install (void(NetworkProcess::*method)(M &&))
void	install (void(NetworkProcess::*method)())
void	install (void(NetworkProcess::*method)(PC...), MessageProperty< M, P >...param)
Protected Member Functions inherited from process::ProcessBase
virtual void	serve (Event &&event)
	Invoked when an event is serviced. More...
void	consume (DispatchEvent &&event) override
void	consume (HttpEvent &&event) override
void	consume (ExitedEvent &&event) override
void	consume (TerminateEvent &&event) override
virtual void	initialize ()
	Invoked when a process gets spawned. More...
virtual void	exited (const UPID &)
	Invoked when a linked process has exited. More...
virtual void	lost (const UPID &)
	Invoked when a linked process can no longer be monitored. More...
void	send (const UPID &to, const std::string &name, const char *data=nullptr, size_t length=0)
	Sends the message to the specified UPID. More...
void	send (const UPID &to, std::string &&name)
void	send (const UPID &to, std::string &&name, std::string &&data)
UPID	link (const UPID &pid, const RemoteConnection remote=RemoteConnection::REUSE)
	Links with the specified UPID. More...
void	install (const std::string &name, const MessageHandler &handler)
	Sets up a handler for messages with the specified name. More...
template<typename T >
void	install (const std::string &name, void(T::*method)(const UPID &, const std::string &))
	Sets up a handler for messages with the specified name. More...
void	delegate (const std::string &name, const UPID &pid)
	Delegates incoming messages, with the specified name, to the UPID. More...
void	route (const std::string &name, const Option< std::string > &help, const HttpRequestHandler &handler, const RouteOptions &options=RouteOptions())
	Sets up a handler for HTTP requests with the specified name. More...
template<typename T >
void	route (const std::string &name, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &), const RouteOptions &options=RouteOptions())
	Sets up a handler for HTTP requests with the specified name. More...
void	route (const std::string &name, const std::string &realm, const Option< std::string > &help, const AuthenticatedHttpRequestHandler &handler, const RouteOptions &options=RouteOptions())
template<typename T >
void	route (const std::string &name, const Option< std::string > &realm, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &, const Option< http::authentication::Principal > &), const RouteOptions &options=RouteOptions())
	Forwards to the correct overload of process::ProcessBase::route(), depending on whether the authentication realm realm is present. More...
void	provide (const std::string &name, const std::string &path, const std::map< std::string, std::string > &types=mime::types)
	Sets up the default HTTP request handler to provide the static asset(s) at the specified absolute path for the specified name. More...
template<typename T >
size_t	eventCount ()
	Returns the number of events of the given type currently on the event queue. More...

Additional Inherited Members
Protected Types inherited from ProtobufProcess< NetworkProcess >
using	MessageProperty = P(M::*)() const
Protected Types inherited from process::Process< NetworkProcess >
typedef NetworkProcess	Self
typedef NetworkProcess	This
Protected Types inherited from process::ProcessBase
enum	RemoteConnection { RemoteConnection::REUSE, RemoteConnection::RECONNECT }
	Describes the behavior of the link call when the target pid points to a remote process. More...
typedef lambda::function< void(const UPID &, const std::string &)>	MessageHandler
	Any function which takes a "from" UPID and a message body as arguments. More...
typedef lambda::function< Future< http::Response >const http::Request &)>	HttpRequestHandler
	Any function which takes a process::http::Request and returns a process::http::Response. More...
typedef lambda::function< Future< http::Response > const http::Request &, const Option< http::authentication::Principal > &)>	AuthenticatedHttpRequestHandler
	Any function which takes a process::http::Request and an Option<Principal> and returns a process::http::Response. More...

Constructor & Destructor Documentation

NetworkProcess::NetworkProcess ( )

inline

NetworkProcess::NetworkProcess ( const std::set< process::UPID > &  pids )

inlineexplicit

Member Function Documentation

void NetworkProcess::add ( const process::UPID &  pid )

inline

template<typename Req , typename Res >

std::set<process::Future<Res> > NetworkProcess::broadcast ( const Protocol< Req, Res > &  protocol, const Req &  req, const std::set< process::UPID > &  filter  )

inline

template<typename M >

Nothing NetworkProcess::broadcast ( const M &  m, const std::set< process::UPID > &  filter  )

inline

void NetworkProcess::finalize ( )

inlineoverrideprotectedvirtual

Invoked when a process is terminated.

NOTE: this does not get invoked automatically if process::ProcessBase::consume(TerminateEvent&&) is overridden.

Reimplemented from process::ProcessBase.

void NetworkProcess::remove ( const process::UPID &  pid )

inline

void NetworkProcess::set ( const std::set< process::UPID > &  _pids )

inline

process::Future<size_t> NetworkProcess::watch ( size_t  size, Network::WatchMode  mode  )

inline

---

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

• src/log/network.hpp