tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-23 13:45:04 +02:00
Code Issues Packages Projects Releases Wiki Activity

JsonRpcConnection: use AsioTlsStream::GracefulDisconnect()

Browse Source 
This new helper functions allows deduplicating the timeout handling for
`async_shutdown()`.
This commit is contained in:
Julian Brost 2024-02-12 17:02:35 +01:00
parent 56d5811283
commit 007e3fbe7e
1 changed files with 1 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
lib/remote/jsonrpcconnection.cpp
View File

@ -225,36 +225,10 @@ void JsonRpcConnection::Disconnect()
m_WriterDone.Wait(yc); m_WriterDone.Wait(yc);
/*
* Do not swallow exceptions in a coroutine.
* https://github.com/Icinga/icinga2/issues/7351
* We must not catch `detail::forced_unwind exception` as
* this is used for unwinding the stack.
*
* Just use the error_code dummy here.
*/
boost::system::error_code ec;
m_CheckLivenessTimer.cancel(); m_CheckLivenessTimer.cancel();
m_HeartbeatTimer.cancel(); m_HeartbeatTimer.cancel();
m_Stream->lowest_layer().cancel(ec); m_Stream->GracefulDisconnect(m_IoStrand, yc);
Timeout::Ptr shutdownTimeout (new Timeout(
m_IoStrand.context(),
m_IoStrand,
boost::posix_time::seconds(10),
[this, keepAlive](asio::yield_context yc) {
boost::system::error_code ec;
m_Stream->lowest_layer().cancel(ec);
}
));
m_Stream->next_layer().async_shutdown(yc[ec]);
shutdownTimeout->Cancel();
m_Stream->lowest_layer().shutdown(m_Stream->lowest_layer().shutdown_both, ec);
}); });
} }
} }