mirror/Sunshine
1
0
Fork 0
mirror of https://github.com/LizardByte/Sunshine.git synced 2025-02-21 00:39:59 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Inform clients of graceful termination when Sunshine exits

Browse Source
This commit is contained in:
Cameron Gutman 2024-02-03 16:52:10 -06:00
parent be6f856840
commit dea1155983
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/stream.cpp
View File

@ -1035,8 +1035,12 @@ namespace stream {
// This thread handles latency-sensitive control messages // This thread handles latency-sensitive control messages
platf::adjust_thread_priority(platf::thread_priority_e::critical); platf::adjust_thread_priority(platf::thread_priority_e::critical);
auto shutdown_event = mail::man->event<bool>(mail::broadcast_shutdown); // Check for both the full shutdown event and the shutdown event for this
while (!shutdown_event->peek()) { // broadcast to ensure we can inform connected clients of our graceful
// termination when we shut down.
auto shutdown_event = mail::man->event<bool>(mail::shutdown);
auto broadcast_shutdown_event = mail::man->event<bool>(mail::broadcast_shutdown);
while (!shutdown_event->peek() && !broadcast_shutdown_event->peek()) {
bool has_session_awaiting_peer = false; bool has_session_awaiting_peer = false;
{ {
@ -1045,6 +1049,11 @@ namespace stream {
auto now = std::chrono::steady_clock::now(); auto now = std::chrono::steady_clock::now();
KITTY_WHILE_LOOP(auto pos = std::begin(*server->_sessions), pos != std::end(*server->_sessions), { KITTY_WHILE_LOOP(auto pos = std::begin(*server->_sessions), pos != std::end(*server->_sessions), {
// Don't perform additional session processing if we're shutting down
if (shutdown_event->peek() || broadcast_shutdown_event->peek()) {
break;
}
auto session = *pos; auto session = *pos;
if (now > session->pingTimeout) { if (now > session->pingTimeout) {