| 728 | } |
| 729 | |
| 730 | void AsyncConnection::mark_down() |
| 731 | { |
| 732 | ldout(async_msgr->cct, 1) << __func__ << dendl; |
| 733 | std::lock_guard<std::mutex> l(lock); |
| 734 | protocol->stop(); |
| 735 | } |
| 736 | |
| 737 | void AsyncConnection::handle_write() |
| 738 | { |
no test coverage detected