| 505 | } |
| 506 | |
| 507 | void AsyncConnection::connect(const entity_addrvec_t &addrs, int type, |
| 508 | entity_addr_t &target) { |
| 509 | |
| 510 | std::lock_guard<std::mutex> l(lock); |
| 511 | set_peer_type(type); |
| 512 | set_peer_addrs(addrs); |
| 513 | policy = msgr->get_policy(type); |
| 514 | target_addr = target; |
| 515 | _connect(); |
| 516 | } |
| 517 | |
| 518 | void AsyncConnection::_connect() |
| 519 | { |
no test coverage detected