| 1516 | } |
| 1517 | |
| 1518 | void StartAccept(TTcpAcceptor* a) { |
| 1519 | const auto s = MakeAtomicShared<TTcpSocket>(EP_.Size() ? EP_.GetExecutor().GetIOService() : EA_.GetIOService()); |
| 1520 | a->AsyncAccept(*s, std::bind(&TServer::OnAccept, this, a, s, _1, _2)); |
| 1521 | } |
| 1522 | |
| 1523 | void OnAccept(TTcpAcceptor* a, TTcpSocketRef s, const TErrorCode& ec, IHandlingContext&) { |
| 1524 | if (Y_UNLIKELY(ec)) { |
nothing calls this directly
no test coverage detected