|
| InterpCtxTimer (val::SpTimer &timer_p, MsgHandlerBase &ir_p, interp::shpfrm &global) |
|
virtual void | removeTimer (val::SpTimer &tmr) |
|
virtual int | interpret (InterpState &state, const val::Value *retval=nullptr) |
| pass the iterator to InterpState for easier deletion! LLL
|
|
virtual void | sendGcStateMessage (const string &ip, int port, Global::conn_id_t peerid, const InterpState &state) |
| When deleting a state, sends or displays an error message.
|
|
int | interpretTimer (int fd) |
|
| InterpCtx (MsgHandlerBase &ir_p, interp::shpfrm &global) |
|
size_t | readRspData (Global::reqid_t reqid, Global::reqid_t sourceid, const char *buf, size_t len) |
|
ssize_t | readReqData (Global::conn_id_t peerid, Global::reqid_t reqid, Global::reqid_t sourceid, const char *buf, size_t len) |
|
ssize_t | readAppendData (const char *buf, size_t len) |
| Read a buffer containing an array to append.
|
|
ssize_t | readAppendVectorData (const char *buf, size_t len) |
| Read a buffer containing a vector to append.
|
|
Global::conn_id_t | connect (const string &ip_p, int port_p) |
| Establish connection to given ip/port.
|
|
void | addTimer (val::SpTimer &tmr) |
| Add a timer.
|
|
void | sendReq (const string &varName, val::VConn con, E *e, const val::SpVList &vl, val::SpFuture &future) |
|
void | setStop () |
|
void | gc_requests (std::chrono::system_clock::time_point::duration ttl) |
|
void | gc_states (std::chrono::system_clock::time_point::duration ttl) |
|
void | reset () |
| Terminate all pending requests and reset the interpreter state.
|
|
const MsgStats & | getMsgStats () const |
| Stats:
|
|
void | resetMsgStats () |
|
const NetStats & | getNetStats () const |
|
void | resetNetStats () |
|
const CtxStats & | getCtxStats () const |
|
void | resetCtxStats () |
|
zcore::NetInfo | getNetInfo () const |
| Info:
|
|
zcore::MsgInfo | getMsgInfo () const |
|
zcore::CtxInfo | getCtxInfo () const |
|