| 361 | } |
| 362 | |
| 363 | void Connection::CallAwaitingResponse::HandleTimeout(ev::timer &watcher, int revents) { |
| 364 | if (remaining_timeout > 0) { |
| 365 | if (watcher.remaining() < -1.0) { |
| 366 | LOG(WARNING) << "RPC call timeout handler was delayed by " |
| 367 | << -watcher.remaining() << "s! This may be due to a process-wide " |
| 368 | << "pause such as swapping, logging-related delays, or allocator lock " |
| 369 | << "contention. Will allow an additional " |
| 370 | << remaining_timeout << "s for a response."; |
| 371 | } |
| 372 | |
| 373 | watcher.set(remaining_timeout, 0); |
| 374 | watcher.start(); |
| 375 | remaining_timeout = 0; |
| 376 | return; |
| 377 | } |
| 378 | |
| 379 | conn->HandleOutboundCallTimeout(this); |
| 380 | } |
| 381 | |
| 382 | void Connection::HandleOutboundCallTimeout(CallAwaitingResponse *car) { |
| 383 | DCHECK(reactor_thread_->IsCurrentThread()); |
nothing calls this directly
no test coverage detected