ztsdb
|
#include <interp_ctx.hpp>
Public Member Functions | |
RspState (const string &ip_p, int port_p, Global::conn_id_t peerid_p, const string &s, val::SpFuture &future_p) | |
void | readData (const char *buf, size_t len) |
Public Attributes | |
const string | ip |
const int | port |
const Global::conn_id_t | peerid |
const string | name |
IncomingRspState | state |
size_t | valstack_idx |
vector< ValState > | valstack |
std::chrono::system_clock::time_point | timestamp |
val::SpFuture | future |
This structure represents the state of an incoming response (to one of our outgoing requests). An incoming response is always one 'Value', which is decoded and stored in 'valstack'.
std::chrono::system_clock::time_point zcore::RspState::timestamp |
so we can free response states that take too long to complete