|
ztsdb
|
#include <msg_handler.hpp>
Public Member Functions | |
| virtual Global::conn_id_t | connect (const string &ip, int port, InterpCtx &ic) |
| virtual size_t | sendReq (InterpCtx *reqCtx, Global::reqid_t reqid, Global::reqid_t sourceid, val::VConn con, const E *e, const val::SpVList &boundvars) |
| virtual size_t | sendRsp (Global::conn_id_t id, Global::reqid_t reqid, Global::reqid_t sourceid, const val::Value &rsp) |
| virtual void | suspendKeyboardPoll () |
| virtual void | enableKeyboardPoll () |
| virtual void | addTimer (int fd, std::unique_ptr< InterpCtxTimer > ctx) |
| virtual void | removeTimer (int fd) |
| virtual const NetStats & | getNetStats () const |
| virtual void | resetNetStats () |
| virtual zcore::NetInfo | getNetInfo () const |
| virtual zcore::MsgInfo | getMsgInfo () const |
| const MsgStats & | getMsgStats () |
| void | resetMsgStats () |
Protected Attributes | |
| MsgStats | stats |
Provide a minimal InterpRun that has few dependencies. This allows us to do unit testing of the interpreter without having to include the communication layer, etc.
1.8.17