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.