Inheritance diagram for zcore::InterpCtx:

Public Member Functions
	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.

virtual void	removeTimer (val::SpTimer &tmr)

void	sendReq (const string &varName, val::VConn con, E *e, const val::SpVList &vl, val::SpFuture &future)

void	setStop ()

virtual int	interpret (InterpState &state, const val::Value *retval=nullptr)=0

virtual void	sendGcStateMessage (const string &ip, int port, Global::conn_id_t peerid, const InterpState &state)=0
	When deleting a state, sends or displays an error message.

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

Public Attributes
std::shared_ptr< interp::BaseFrame >	r

MsgHandlerBase &	ir

std::map< Global::reqid_t, ReqState >	requests

Global::reqid_t	currentState

InterpState *	s

Static Public Attributes
static volatile sig_atomic_t	sigint = 0

Protected Attributes
CtxStats	stats

std::map< Global::reqid_t, InterpState >	states

Member Function Documentation

◆ readRspData()

size_t zcore::InterpCtx::readRspData	(	Global::reqid_t	reqid,
		Global::reqid_t	sourceid,
		const char *	buf,
		size_t	len
	)

that's OK, we may have been interrupted, the query could have been garbage collected (if it evaluated to an error), we might have restarted, etc.

◆ removeTimer()

void zcore::InterpCtx::removeTimer ( val::SpTimer & tmr )

virtual

carefull, can we remove timer to self? LLL

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

src/interp_ctx.hpp
src/interp_ctx.cpp

Public Member Functions

Public Attributes

Static Public Attributes

Protected Attributes

Member Function Documentation

◆ readRspData()

◆ removeTimer()