| 57 | } |
| 58 | |
| 59 | void onMessage(const TcpConnectionPtr& conn, Buffer* buf, Timestamp) |
| 60 | { |
| 61 | size_t len = buf->readableBytes(); |
| 62 | transferredBytes_.addAndGet(len); |
| 63 | receivedMessages_.incrementAndGet(); |
| 64 | conn->send(buf); |
| 65 | } |
| 66 | |
| 67 | void printThroughput() |
| 68 | { |
nothing calls this directly
no test coverage detected