Vita3K/Vita3K-Android
1
0
Fork 0
mirror of https://github.com/Vita3K/Vita3K-Android.git synced 2024-12-04 03:21:20 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

kernel: Implement DONT_WAIT flag for msg pipes

Browse Source
This commit is contained in:
Macdu 2023-05-03 19:23:30 +02:00
parent 64954749d3
commit 26930943a6
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
vita3k/kernel/src/sync_primitives.cpp
View File

@ -1432,6 +1432,8 @@ SceSize msgpipe_recv(KernelState &kernel, const char *export_name, SceUID thread
SceSize copied_size = (SceSize)copyOut();
wakeup_senders();
return copied_size;
} else if (waitMode & SCE_KERNEL_MSG_PIPE_MODE_DONT_WAIT) {
return 0;
} else { // sleep until we can insert
WaitingThreadData wait_data;
wait_data.thread = thread;
@ -1522,8 +1524,6 @@ SceSize msgpipe_send(KernelState &kernel, const char *export_name, SceUID thread
const ThreadStatePtr thread = lock_and_find(thread_id, kernel.threads, kernel.mutex);
std::unique_lock<std::mutex> msgpipe_lock(msgpipe->mutex);
// FIXME implement SCE_KERNEL_MSG_PIPE_MODE_DONT_WAIT (for now, all requests are handled synchronously)
// If ASAP and there's at least 1 free byte, or FULL and there's enough space, copy and return directly.
std::size_t freeSize = msgpipe->data_buffer.Free();
if ((freeSize >= sendSize) || (ASAP && (freeSize >= 1))) {
@ -1532,6 +1532,8 @@ SceSize msgpipe_send(KernelState &kernel, const char *export_name, SceUID thread
wakeup_receivers();
return copied_size;
} else if (waitMode & SCE_KERNEL_MSG_PIPE_MODE_DONT_WAIT) {
return 0;
} else { // Go to sleep until there's more space
WaitingThreadData wait_data;
wait_data.thread = thread;