mirrors/citra
1
0
Fork 0
Code Issues Pull requests Releases Activity

Merge pull request #3088 from Subv/clientsession_closing

Browse source 
Kernel/Sessions: Wake up any threads waiting on a ServerSession when its client is closed
This commit is contained in:
Sebastian Valle 2017-11-15 09:15:34 -05:00 committed by GitHub
commit 93742ec510
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 13 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/core/hle/kernel/client_session.cpp
View file

@ -26,9 +26,6 @@ ClientSession::~ClientSession() {
if (hle_handler)
hle_handler->ClientDisconnected(server);
// TODO(Subv): Force a wake up of all the ServerSession's waiting threads and set
// their WaitSynchronization result to 0xC920181A.
// Clean up the list of client threads with pending requests, they are unneeded now that the
// client endpoint is closed.
server->pending_requesting_threads.clear();
@ -36,6 +33,13 @@ ClientSession::~ClientSession() {
}
parent->client = nullptr;
if (server) {
// Notify any threads waiting on the ServerSession that the endpoint has been closed. Note
// that this call has to happen after `Session::client` has been set to nullptr to let the
// ServerSession know that the client endpoint has been closed.
server->WakeupAllWaitingThreads();
}
}
ResultCode ClientSession::SendSyncRequest(SharedPtr<Thread> thread) {

7
src/core/hle/kernel/server_session.cpp
View file

@ -47,8 +47,13 @@ bool ServerSession::ShouldWait(Thread* thread) const {
void ServerSession::Acquire(Thread* thread) {
ASSERT_MSG(!ShouldWait(thread), "object unavailable!");
// If the client endpoint was closed, don't do anything. This ServerSession is now useless and
// will linger until its last handle is closed by the running application.
if (parent->client == nullptr)
return;
// We are now handling a request, pop it from the stack.
// TODO(Subv): What happens if the client endpoint is closed before any requests are made?
ASSERT(!pending_requesting_threads.empty());
currently_handling = pending_requesting_threads.back();
pending_requesting_threads.pop_back();