#include <P_ClusterInternal.h>
Inherits Continuation.
Public Member Functions | |
| ClusterAccept (int *, int, int) | |
| void | Init () |
| void | ShutdownDelete () |
| int | ClusterAcceptEvent (int, void *) |
| int | ClusterAcceptMachine (NetVConnection *) |
| ~ClusterAccept () | |
Detailed Description
Definition at line 457 of file P_ClusterInternal.h.
Constructor & Destructor Documentation
| ClusterAccept::ClusterAccept | ( | int * | port, | |
| int | send_bufsize, | |||
| int | recv_bufsize | |||
| ) |
Definition at line 34 of file ClusterConfig.cc.
References ClusterAcceptEvent(), Continuation::mutex, new_ProxyMutex(), and SET_HANDLER.
| ClusterAccept::~ClusterAccept | ( | ) |
Definition at line 47 of file ClusterConfig.cc.
References Continuation::mutex.
Member Function Documentation
| int ClusterAccept::ClusterAcceptEvent | ( | int | event, | |
| void * | data | |||
| ) |
Definition at line 86 of file ClusterConfig.cc.
References Action::cancel(), cluster_port, ClusterAcceptMachine(), ET_CLUSTER, NetProcessor::AcceptOptions::etype, EVENT_IMMEDIATE, EVENT_INTERVAL, NetProcessor::AcceptOptions::ip_family, NetProcessor::AcceptOptions::local_port, NetProcessor::AcceptOptions::localhost_only, NetProcessor::main_accept(), NET_EVENT_ACCEPT, netProcessor, NO_FD, NetProcessor::AcceptOptions::recv_bufsize, NetProcessor::AcceptOptions::send_bufsize, ShutdownDelete(), and Warning.
Referenced by ClusterAccept(), and Init().
| int ClusterAccept::ClusterAcceptMachine | ( | NetVConnection * | NetVC | ) |
Definition at line 136 of file ClusterConfig.cc.
References CL_NOTE, VIO::CLOSE, Debug, VConnection::do_io(), DOT_SEPARATED, ET_CLUSTER, eventProcessor, MachineList::find(), NetVConnection::get_remote_ip(), ClusterHandler::ip, ClusterHandler::machine, ClusterHandler::net_vc, Note, EventProcessor::schedule_imm_signal(), and the_cluster_machines_config().
Referenced by ClusterAcceptEvent().
| void ClusterAccept::Init | ( | ) |
Definition at line 53 of file ClusterConfig.cc.
References ClusterAcceptEvent(), EVENT_INTERVAL, eventProcessor, HRTIME_SECONDS, and EventProcessor::schedule_every().
Referenced by ClusterProcessor::start().
| void ClusterAccept::ShutdownDelete | ( | ) |
Definition at line 66 of file ClusterConfig.cc.
References Action::cancel(), ET_CALL, eventProcessor, Continuation::mutex, MUTEX_TRY_LOCK, EventProcessor::schedule_imm(), and this_ethread().
Referenced by ClusterAcceptEvent(), and ClusterProcessor::~ClusterProcessor().
The documentation for this class was generated from the following files:
