| 516 | } |
| 517 | |
| 518 | void AsyncConnection::_connect() |
| 519 | { |
| 520 | ldout(async_msgr->cct, 10) << __func__ << dendl; |
| 521 | |
| 522 | state = STATE_CONNECTING; |
| 523 | protocol->connect(); |
| 524 | // rescheduler connection in order to avoid lock dep |
| 525 | // may called by external thread(send_message) |
| 526 | center->dispatch_event_external(read_handler); |
| 527 | } |
| 528 | |
| 529 | void AsyncConnection::accept(ConnectedSocket socket, |
| 530 | const entity_addr_t &listen_addr, |
no test coverage detected