| 176 | } |
| 177 | |
| 178 | Future<Duration> _run() |
| 179 | { |
| 180 | duration = Owned<Promise<Duration>>(new Promise<Duration>()); |
| 181 | |
| 182 | watch.start(); |
| 183 | |
| 184 | while (requests < concurrency) { |
| 185 | send(server, "ping", message.c_str(), message.size()); |
| 186 | ++requests; |
| 187 | } |
| 188 | |
| 189 | return duration->future(); |
| 190 | } |
| 191 | |
| 192 | void pong(const UPID& from, const string& body) |
| 193 | { |