tyler.durden
/
icinga2
mirror of https://github.com/Icinga/icinga2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ApiListener#ListenerCoroutineProc(): catch more edge cases

This commit is contained in:
Alexander A. Klimov 2019-02-18 14:23:59 +01:00
parent a6813ec786
commit e9a64abd09
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/remote/apilistener.cpp
View File

@ -409,19 +409,17 @@ void ApiListener::ListenerCoroutineProc(boost::asio::yield_context yc, const std
namespace asio = boost::asio; namespace asio = boost::asio;
auto& io (server->get_io_service()); auto& io (server->get_io_service());
auto sslConn (std::make_shared<AsioTlsStream>(io, *sslContext));
for (;;) { for (;;) {
try { try {
auto sslConn (std::make_shared<AsioTlsStream>(io, *sslContext));
server->async_accept(sslConn->lowest_layer(), yc); server->async_accept(sslConn->lowest_layer(), yc);
} catch (const std::exception& ex) {
Log(LogCritical, "ApiListener") << "Cannot accept new connection: " << DiagnosticInformation(ex, false);
continue;
}
asio::spawn(io, [this, sslConn](asio::yield_context yc) { NewClientHandler(yc, sslConn, String(), RoleServer); }); asio::spawn(io, [this, sslConn](asio::yield_context yc) { NewClientHandler(yc, sslConn, String(), RoleServer); });
} catch (const std::exception& ex) {
sslConn = std::make_shared<AsioTlsStream>(io, *sslContext); Log(LogCritical, "ApiListener") << "Cannot accept new connection: " << DiagnosticInformation(ex, false);
}
} }
} }