| 255 | } |
| 256 | |
| 257 | void onBackendMessage(const TcpConnectionPtr& conn, Buffer* buf, Timestamp) |
| 258 | { |
| 259 | size_t len = buf->readableBytes(); |
| 260 | transferred_.addAndGet(len); |
| 261 | receivedMessages_.incrementAndGet(); |
| 262 | sendToClient(buf); |
| 263 | } |
| 264 | |
| 265 | void printStatistics() |
| 266 | { |
nothing calls this directly
no test coverage detected