MCPcopy Create free account
hub / github.com/ByConity/ByConity / setTimer

Method setTimer

src/DataStreams/RemoteQueryExecutorReadContext.cpp:155–162  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

153}
154
155void RemoteQueryExecutorReadContext::setTimer() const
156{
157 /// Did not get packet yet. Init timeout for the next async reading.
158 timer.reset();
159
160 if (receive_timeout.totalMicroseconds())
161 timer.setRelative(receive_timeout);
162}
163
164bool RemoteQueryExecutorReadContext::resumeRoutine()
165{

Callers 1

readMethod · 0.80

Calls 3

totalMicrosecondsMethod · 0.80
setRelativeMethod · 0.80
resetMethod · 0.45

Tested by

no test coverage detected