ztsdb
Public Member Functions | Public Attributes | List of all members
zcore::InterpCtxTimer Struct Reference
Inheritance diagram for zcore::InterpCtxTimer:
zcore::InterpCtx

Public Member Functions

 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)
 
- Public Member Functions inherited from zcore::InterpCtx
 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 MsgStatsgetMsgStats () const
 Stats:
 
void resetMsgStats ()
 
const NetStatsgetNetStats () const
 
void resetNetStats ()
 
const CtxStatsgetCtxStats () const
 
void resetCtxStats ()
 
zcore::NetInfo getNetInfo () const
 Info:
 
zcore::MsgInfo getMsgInfo () const
 
zcore::CtxInfo getCtxInfo () const
 

Public Attributes

std::weak_ptr< val::VTimertimer_wptr
 
- Public Attributes inherited from zcore::InterpCtx
std::shared_ptr< interp::BaseFramer
 
MsgHandlerBaseir
 
std::map< Global::reqid_t, ReqStaterequests
 
Global::reqid_t currentState
 
InterpStates
 

Additional Inherited Members

- Static Public Attributes inherited from zcore::InterpCtx
static volatile sig_atomic_t sigint = 0
 
- Protected Attributes inherited from zcore::InterpCtx
CtxStats stats
 
std::map< Global::reqid_t, InterpStatestates
 

The documentation for this struct was generated from the following files: