| 153 | } |
| 154 | |
| 155 | void 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 | |
| 164 | bool RemoteQueryExecutorReadContext::resumeRoutine() |
| 165 | { |
no test coverage detected