LV2: Fixup reservation notifications

rpcs3/Emu/Cell/lv2/sys_sync.h

@@ -8,6 +8,7 @@
 #include "Emu/Cell/timers.hpp"
 #include "Emu/IdManager.h"
 #include "Emu/IPC.h"
+#include "Emu/Memory/vm.h"
 
 #include <thread>
 
@@ -60,6 +61,12 @@ enum
 
 enum ppu_thread_status : u32;
 
+
+namespace vm
+{
+	extern u8 g_reservations[65536 / 128 * 64];
+}
+
 // Base class for some kernel objects (shared set of 8192 objects).
 struct lv2_obj
 {
@@ -432,9 +439,15 @@ struct lv2_obj
 
 			if (cpu != &g_to_notify)
 			{
-				// Note: by the time of notification the thread could have been deallocated which is why the direct function is used
-				// TODO: Pass a narrower mask
-				atomic_wait_engine::notify_one(cpu);
+				if (cpu >= vm::g_reservations && cpu <= vm::g_reservations + (std::size(vm::g_reservations) - 1))
+				{
+					atomic_wait_engine::notify_all(cpu);
+				}
+				else
+				{
+					// Note: by the time of notification the thread could have been deallocated which is why the direct function is used
+					atomic_wait_engine::notify_one(cpu);
+				}
 			}
 		}
 

rpcs3/Emu/Memory/vm.h

@@ -22,7 +22,7 @@ namespace vm
 	extern u8* const g_exec_addr;
 	extern u8* const g_stat_addr;
 	extern u8* const g_free_addr;
-	extern u8 g_reservations[];
+	extern u8 g_reservations[65536 / 128 * 64];
 
 	struct writer_lock;