|
| MsgHandler (net::NetHandler &com_p, interp::shpfrm &global_p, int fd_read_data_p, int fd_read_sig_p, int fd_input_p=STDIN_FILENO, bool once_p=false, const std::string &initialCode="") |
|
int | run () |
|
Global::conn_id_t | connect (const string &ip, int port, InterpCtx &ic) |
|
size_t | sendReq (InterpCtx *reqCtx, Global::reqid_t reqid, Global::reqid_t sourceid, val::VConn con, const E *e, const val::SpVList &boundvars) |
|
size_t | sendRsp (Global::conn_id_t id, Global::reqid_t reqid, Global::reqid_t sourceid, const val::Value &rsp) |
|
void | suspendKeyboardPoll () |
|
void | enableKeyboardPoll () |
|
void | addTimer (int fd, std::unique_ptr< InterpCtxTimer > ctx) |
|
void | removeTimer (int fd) |
|
const InterpCtxLocal & | getLocalCtx () const |
|
const NetStats & | getNetStats () const |
|
void | resetNetStats () |
|
zcore::NetInfo | getNetInfo () const |
|
zcore::MsgInfo | getMsgInfo () const |
|
Public Member Functions inherited from zcore::MsgHandlerBase |
const MsgStats & | getMsgStats () |
|
void | resetMsgStats () |
|
|
static volatile sig_atomic_t | waitingOnResp = 0 |
|
◆ MsgHandler()
zcore::MsgHandler::MsgHandler |
( |
net::NetHandler & |
com_p, |
|
|
interp::shpfrm & |
global_p, |
|
|
int |
fd_read_data_p, |
|
|
int |
fd_read_sig_p, |
|
|
int |
fd_input_p = STDIN_FILENO , |
|
|
bool |
once_p = false , |
|
|
const std::string & |
initialCode = "" |
|
) |
| |
- Todo:
- it's OK; at some point we can try to see if we can
◆ run()
- Todo:
- it's OK; at some point we can try to see if we can limit the cases where we can't get location info...
The documentation for this struct was generated from the following files: