svc.cpp 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798
  1. // Copyright 2018 Yuzu Emulator Team
  2. // Licensed under GPLv2 or any later version
  3. // Refer to the license.txt file included.
  4. #include "common/logging/log.h"
  5. #include "common/microprofile.h"
  6. #include "common/string_util.h"
  7. #include "core/core_timing.h"
  8. #include "core/hle/kernel/client_port.h"
  9. #include "core/hle/kernel/client_session.h"
  10. #include "core/hle/kernel/condition_variable.h"
  11. #include "core/hle/kernel/handle_table.h"
  12. #include "core/hle/kernel/mutex.h"
  13. #include "core/hle/kernel/object_address_table.h"
  14. #include "core/hle/kernel/process.h"
  15. #include "core/hle/kernel/resource_limit.h"
  16. #include "core/hle/kernel/svc.h"
  17. #include "core/hle/kernel/svc_wrap.h"
  18. #include "core/hle/kernel/sync_object.h"
  19. #include "core/hle/kernel/thread.h"
  20. #include "core/hle/lock.h"
  21. #include "core/hle/result.h"
  22. #include "core/hle/service/service.h"
  23. namespace Kernel {
  24. /// Set the process heap to a given Size. It can both extend and shrink the heap.
  25. static ResultCode SetHeapSize(VAddr* heap_addr, u64 heap_size) {
  26. LOG_TRACE(Kernel_SVC, "called, heap_size=0x%llx", heap_size);
  27. auto& process = *g_current_process;
  28. CASCADE_RESULT(*heap_addr,
  29. process.HeapAllocate(Memory::HEAP_VADDR, heap_size, VMAPermission::ReadWrite));
  30. return RESULT_SUCCESS;
  31. }
  32. /// Maps a memory range into a different range.
  33. static ResultCode MapMemory(VAddr dst_addr, VAddr src_addr, u64 size) {
  34. LOG_TRACE(Kernel_SVC, "called, dst_addr=0x%llx, src_addr=0x%llx, size=0x%llx", dst_addr,
  35. src_addr, size);
  36. return g_current_process->MirrorMemory(dst_addr, src_addr, size);
  37. }
  38. /// Unmaps a region that was previously mapped with svcMapMemory
  39. static ResultCode UnmapMemory(VAddr dst_addr, VAddr src_addr, u64 size) {
  40. LOG_TRACE(Kernel_SVC, "called, dst_addr=0x%llx, src_addr=0x%llx, size=0x%llx", dst_addr,
  41. src_addr, size);
  42. return g_current_process->UnmapMemory(dst_addr, src_addr, size);
  43. }
  44. /// Connect to an OS service given the port name, returns the handle to the port to out
  45. static ResultCode ConnectToPort(Handle* out_handle, VAddr port_name_address) {
  46. if (!Memory::IsValidVirtualAddress(port_name_address))
  47. return ERR_NOT_FOUND;
  48. static constexpr std::size_t PortNameMaxLength = 11;
  49. // Read 1 char beyond the max allowed port name to detect names that are too long.
  50. std::string port_name = Memory::ReadCString(port_name_address, PortNameMaxLength + 1);
  51. if (port_name.size() > PortNameMaxLength)
  52. return ERR_PORT_NAME_TOO_LONG;
  53. LOG_TRACE(Kernel_SVC, "called port_name=%s", port_name.c_str());
  54. auto it = Service::g_kernel_named_ports.find(port_name);
  55. if (it == Service::g_kernel_named_ports.end()) {
  56. LOG_WARNING(Kernel_SVC, "tried to connect to unknown port: %s", port_name.c_str());
  57. return ERR_NOT_FOUND;
  58. }
  59. auto client_port = it->second;
  60. SharedPtr<ClientSession> client_session;
  61. CASCADE_RESULT(client_session, client_port->Connect());
  62. // Return the client session
  63. CASCADE_RESULT(*out_handle, g_handle_table.Create(client_session));
  64. return RESULT_SUCCESS;
  65. }
  66. /// Makes a blocking IPC call to an OS service.
  67. static ResultCode SendSyncRequest(Handle handle) {
  68. SharedPtr<SyncObject> session = g_handle_table.Get<SyncObject>(handle);
  69. if (!session) {
  70. LOG_ERROR(Kernel_SVC, "called with invalid handle=0x%08X", handle);
  71. return ERR_INVALID_HANDLE;
  72. }
  73. LOG_TRACE(Kernel_SVC, "called handle=0x%08X(%s)", handle, session->GetName().c_str());
  74. Core::System::GetInstance().PrepareReschedule();
  75. // TODO(Subv): svcSendSyncRequest should put the caller thread to sleep while the server
  76. // responds and cause a reschedule.
  77. return session->SendSyncRequest(GetCurrentThread());
  78. }
  79. /// Get the ID for the specified thread.
  80. static ResultCode GetThreadId(u32* thread_id, Handle thread_handle) {
  81. LOG_TRACE(Kernel_SVC, "called thread=0x%08X", thread_handle);
  82. const SharedPtr<Thread> thread = g_handle_table.Get<Thread>(thread_handle);
  83. if (!thread) {
  84. return ERR_INVALID_HANDLE;
  85. }
  86. *thread_id = thread->GetThreadId();
  87. return RESULT_SUCCESS;
  88. }
  89. /// Get the ID of the specified process
  90. static ResultCode GetProcessId(u32* process_id, Handle process_handle) {
  91. LOG_TRACE(Kernel_SVC, "called process=0x%08X", process_handle);
  92. const SharedPtr<Process> process = g_handle_table.Get<Process>(process_handle);
  93. if (!process) {
  94. return ERR_INVALID_HANDLE;
  95. }
  96. *process_id = process->process_id;
  97. return RESULT_SUCCESS;
  98. }
  99. /// Default thread wakeup callback for WaitSynchronization
  100. static bool DefaultThreadWakeupCallback(ThreadWakeupReason reason, SharedPtr<Thread> thread,
  101. SharedPtr<WaitObject> object, size_t index) {
  102. ASSERT(thread->status == THREADSTATUS_WAIT_SYNCH_ANY);
  103. if (reason == ThreadWakeupReason::Timeout) {
  104. thread->SetWaitSynchronizationResult(RESULT_TIMEOUT);
  105. return true;
  106. }
  107. ASSERT(reason == ThreadWakeupReason::Signal);
  108. thread->SetWaitSynchronizationResult(RESULT_SUCCESS);
  109. return true;
  110. };
  111. /// Wait for a kernel object to synchronize, timeout after the specified nanoseconds
  112. static ResultCode WaitSynchronization1(
  113. SharedPtr<WaitObject> object, Thread* thread, s64 nano_seconds = -1,
  114. std::function<Thread::WakeupCallback> wakeup_callback = DefaultThreadWakeupCallback) {
  115. if (!object) {
  116. return ERR_INVALID_HANDLE;
  117. }
  118. if (object->ShouldWait(thread)) {
  119. if (nano_seconds == 0) {
  120. return RESULT_TIMEOUT;
  121. }
  122. thread->wait_objects = {object};
  123. object->AddWaitingThread(thread);
  124. thread->status = THREADSTATUS_WAIT_SYNCH_ANY;
  125. // Create an event to wake the thread up after the specified nanosecond delay has passed
  126. thread->WakeAfterDelay(nano_seconds);
  127. thread->wakeup_callback = wakeup_callback;
  128. Core::System::GetInstance().PrepareReschedule();
  129. } else {
  130. object->Acquire(thread);
  131. }
  132. return RESULT_SUCCESS;
  133. }
  134. /// Wait for the given handles to synchronize, timeout after the specified nanoseconds
  135. static ResultCode WaitSynchronization(Handle* index, VAddr handles_address, u64 handle_count,
  136. s64 nano_seconds) {
  137. LOG_TRACE(Kernel_SVC, "called handles_address=0x%llx, handle_count=%d, nano_seconds=%d",
  138. handles_address, handle_count, nano_seconds);
  139. if (!Memory::IsValidVirtualAddress(handles_address))
  140. return ERR_INVALID_POINTER;
  141. // Check if 'handle_count' is invalid
  142. if (handle_count < 0)
  143. return ERR_OUT_OF_RANGE;
  144. auto thread = GetCurrentThread();
  145. using ObjectPtr = SharedPtr<WaitObject>;
  146. std::vector<ObjectPtr> objects(handle_count);
  147. for (int i = 0; i < handle_count; ++i) {
  148. Handle handle = Memory::Read32(handles_address + i * sizeof(Handle));
  149. auto object = g_handle_table.Get<WaitObject>(handle);
  150. if (object == nullptr)
  151. return ERR_INVALID_HANDLE;
  152. objects[i] = object;
  153. }
  154. // Find the first object that is acquirable in the provided list of objects
  155. auto itr = std::find_if(objects.begin(), objects.end(), [thread](const ObjectPtr& object) {
  156. return !object->ShouldWait(thread);
  157. });
  158. if (itr != objects.end()) {
  159. // We found a ready object, acquire it and set the result value
  160. WaitObject* object = itr->get();
  161. object->Acquire(thread);
  162. *index = static_cast<s32>(std::distance(objects.begin(), itr));
  163. return RESULT_SUCCESS;
  164. }
  165. // No objects were ready to be acquired, prepare to suspend the thread.
  166. // If a timeout value of 0 was provided, just return the Timeout error code instead of
  167. // suspending the thread.
  168. if (nano_seconds == 0)
  169. return RESULT_TIMEOUT;
  170. // Just implement for a single handle for now
  171. ASSERT(handle_count == 1);
  172. return WaitSynchronization1(objects[0], GetCurrentThread(), nano_seconds);
  173. }
  174. /// Resumes a thread waiting on WaitSynchronization
  175. static ResultCode CancelSynchronization(Handle thread_handle) {
  176. LOG_TRACE(Kernel_SVC, "called thread=0x%08X", thread_handle);
  177. const SharedPtr<Thread> thread = g_handle_table.Get<Thread>(thread_handle);
  178. if (!thread) {
  179. return ERR_INVALID_HANDLE;
  180. }
  181. ASSERT(thread->status == THREADSTATUS_WAIT_SYNCH_ANY);
  182. thread->SetWaitSynchronizationResult(
  183. ResultCode(ErrorModule::Kernel, ErrCodes::SynchronizationCanceled));
  184. thread->ResumeFromWait();
  185. return RESULT_SUCCESS;
  186. }
  187. /// Attempts to locks a mutex, creating it if it does not already exist
  188. static ResultCode LockMutex(Handle holding_thread_handle, VAddr mutex_addr,
  189. Handle requesting_thread_handle) {
  190. LOG_TRACE(Kernel_SVC,
  191. "called holding_thread_handle=0x%08X, mutex_addr=0x%llx, "
  192. "requesting_current_thread_handle=0x%08X",
  193. holding_thread_handle, mutex_addr, requesting_thread_handle);
  194. SharedPtr<Thread> holding_thread = g_handle_table.Get<Thread>(holding_thread_handle);
  195. SharedPtr<Thread> requesting_thread = g_handle_table.Get<Thread>(requesting_thread_handle);
  196. ASSERT(requesting_thread);
  197. SharedPtr<Mutex> mutex = g_object_address_table.Get<Mutex>(mutex_addr);
  198. if (!mutex) {
  199. // Create a new mutex for the specified address if one does not already exist
  200. mutex = Mutex::Create(holding_thread, mutex_addr);
  201. mutex->name = Common::StringFromFormat("mutex-%llx", mutex_addr);
  202. }
  203. ASSERT(holding_thread == mutex->GetHoldingThread());
  204. return WaitSynchronization1(mutex, requesting_thread.get());
  205. }
  206. /// Unlock a mutex
  207. static ResultCode UnlockMutex(VAddr mutex_addr) {
  208. LOG_TRACE(Kernel_SVC, "called mutex_addr=0x%llx", mutex_addr);
  209. SharedPtr<Mutex> mutex = g_object_address_table.Get<Mutex>(mutex_addr);
  210. ASSERT(mutex);
  211. return mutex->Release(GetCurrentThread());
  212. }
  213. /// Break program execution
  214. static void Break(u64 unk_0, u64 unk_1, u64 unk_2) {
  215. LOG_CRITICAL(Debug_Emulated, "Emulated program broke execution!");
  216. ASSERT(false);
  217. }
  218. /// Used to output a message on a debug hardware unit - does nothing on a retail unit
  219. static void OutputDebugString(VAddr address, s32 len) {
  220. std::vector<char> string(len);
  221. Memory::ReadBlock(address, string.data(), len);
  222. LOG_DEBUG(Debug_Emulated, "%.*s", len, string.data());
  223. }
  224. /// Gets system/memory information for the current process
  225. static ResultCode GetInfo(u64* result, u64 info_id, u64 handle, u64 info_sub_id) {
  226. LOG_TRACE(Kernel_SVC, "called info_id=0x%X, info_sub_id=0x%X, handle=0x%08X", info_id,
  227. info_sub_id, handle);
  228. auto& vm_manager = g_current_process->vm_manager;
  229. switch (static_cast<GetInfoType>(info_id)) {
  230. case GetInfoType::TotalMemoryUsage:
  231. *result = vm_manager.GetTotalMemoryUsage();
  232. break;
  233. case GetInfoType::TotalHeapUsage:
  234. *result = vm_manager.GetTotalHeapUsage();
  235. break;
  236. case GetInfoType::RandomEntropy:
  237. *result = 0;
  238. break;
  239. case GetInfoType::AddressSpaceBaseAddr:
  240. *result = vm_manager.GetAddressSpaceBaseAddr();
  241. break;
  242. case GetInfoType::AddressSpaceSize:
  243. *result = vm_manager.GetAddressSpaceSize();
  244. break;
  245. case GetInfoType::NewMapRegionBaseAddr:
  246. *result = vm_manager.GetNewMapRegionBaseAddr();
  247. break;
  248. case GetInfoType::NewMapRegionSize:
  249. *result = vm_manager.GetNewMapRegionSize();
  250. break;
  251. default:
  252. UNIMPLEMENTED();
  253. }
  254. return RESULT_SUCCESS;
  255. }
  256. /// Gets the priority for the specified thread
  257. static ResultCode GetThreadPriority(u32* priority, Handle handle) {
  258. const SharedPtr<Thread> thread = g_handle_table.Get<Thread>(handle);
  259. if (!thread)
  260. return ERR_INVALID_HANDLE;
  261. *priority = thread->GetPriority();
  262. return RESULT_SUCCESS;
  263. }
  264. /// Sets the priority for the specified thread
  265. static ResultCode SetThreadPriority(Handle handle, u32 priority) {
  266. if (priority > THREADPRIO_LOWEST) {
  267. return ERR_OUT_OF_RANGE;
  268. }
  269. SharedPtr<Thread> thread = g_handle_table.Get<Thread>(handle);
  270. if (!thread)
  271. return ERR_INVALID_HANDLE;
  272. // Note: The kernel uses the current process's resource limit instead of
  273. // the one from the thread owner's resource limit.
  274. SharedPtr<ResourceLimit>& resource_limit = g_current_process->resource_limit;
  275. if (resource_limit->GetMaxResourceValue(ResourceTypes::PRIORITY) > priority) {
  276. return ERR_NOT_AUTHORIZED;
  277. }
  278. thread->SetPriority(priority);
  279. thread->UpdatePriority();
  280. // Update the mutexes that this thread is waiting for
  281. for (auto& mutex : thread->pending_mutexes)
  282. mutex->UpdatePriority();
  283. Core::System::GetInstance().PrepareReschedule();
  284. return RESULT_SUCCESS;
  285. }
  286. /// Get which CPU core is executing the current thread
  287. static u32 GetCurrentProcessorNumber() {
  288. LOG_WARNING(Kernel_SVC, "(STUBBED) called, defaulting to processor 0");
  289. return 0;
  290. }
  291. /// Query process memory
  292. static ResultCode QueryProcessMemory(MemoryInfo* memory_info, PageInfo* /*page_info*/,
  293. Handle process_handle, u64 addr) {
  294. SharedPtr<Process> process = g_handle_table.Get<Process>(process_handle);
  295. if (!process) {
  296. return ERR_INVALID_HANDLE;
  297. }
  298. auto vma = process->vm_manager.FindVMA(addr);
  299. memory_info->attributes = 0;
  300. if (vma == g_current_process->vm_manager.vma_map.end()) {
  301. memory_info->base_address = 0;
  302. memory_info->permission = static_cast<u32>(VMAPermission::None);
  303. memory_info->size = 0;
  304. memory_info->type = static_cast<u32>(MemoryState::Free);
  305. } else {
  306. memory_info->base_address = vma->second.base;
  307. memory_info->permission = static_cast<u32>(vma->second.permissions);
  308. memory_info->size = vma->second.size;
  309. memory_info->type = static_cast<u32>(vma->second.meminfo_state);
  310. }
  311. LOG_TRACE(Kernel_SVC, "called process=0x%08X addr=%llx", process_handle, addr);
  312. return RESULT_SUCCESS;
  313. }
  314. /// Query memory
  315. static ResultCode QueryMemory(MemoryInfo* memory_info, PageInfo* page_info, VAddr addr) {
  316. LOG_TRACE(Kernel_SVC, "called, addr=%llx", addr);
  317. return QueryProcessMemory(memory_info, page_info, CurrentProcess, addr);
  318. }
  319. /// Exits the current process
  320. static void ExitProcess() {
  321. LOG_INFO(Kernel_SVC, "Process %u exiting", g_current_process->process_id);
  322. ASSERT_MSG(g_current_process->status == ProcessStatus::Running, "Process has already exited");
  323. g_current_process->status = ProcessStatus::Exited;
  324. // Stop all the process threads that are currently waiting for objects.
  325. auto& thread_list = GetThreadList();
  326. for (auto& thread : thread_list) {
  327. if (thread->owner_process != g_current_process)
  328. continue;
  329. if (thread == GetCurrentThread())
  330. continue;
  331. // TODO(Subv): When are the other running/ready threads terminated?
  332. ASSERT_MSG(thread->status == THREADSTATUS_WAIT_SYNCH_ANY ||
  333. thread->status == THREADSTATUS_WAIT_SYNCH_ALL,
  334. "Exiting processes with non-waiting threads is currently unimplemented");
  335. thread->Stop();
  336. }
  337. // Kill the current thread
  338. GetCurrentThread()->Stop();
  339. Core::System::GetInstance().PrepareReschedule();
  340. }
  341. /// Creates a new thread
  342. static ResultCode CreateThread(Handle* out_handle, VAddr entry_point, u64 arg, VAddr stack_top,
  343. u32 priority, s32 processor_id) {
  344. std::string name = Common::StringFromFormat("unknown-%llx", entry_point);
  345. if (priority > THREADPRIO_LOWEST) {
  346. return ERR_OUT_OF_RANGE;
  347. }
  348. SharedPtr<ResourceLimit>& resource_limit = g_current_process->resource_limit;
  349. if (resource_limit->GetMaxResourceValue(ResourceTypes::PRIORITY) > priority) {
  350. return ERR_NOT_AUTHORIZED;
  351. }
  352. if (processor_id == THREADPROCESSORID_DEFAULT) {
  353. // Set the target CPU to the one specified in the process' exheader.
  354. processor_id = g_current_process->ideal_processor;
  355. ASSERT(processor_id != THREADPROCESSORID_DEFAULT);
  356. }
  357. switch (processor_id) {
  358. case THREADPROCESSORID_0:
  359. break;
  360. case THREADPROCESSORID_ALL:
  361. LOG_INFO(Kernel_SVC,
  362. "Newly created thread is allowed to be run in any Core, unimplemented.");
  363. break;
  364. case THREADPROCESSORID_1:
  365. LOG_ERROR(Kernel_SVC,
  366. "Newly created thread must run in the SysCore (Core1), unimplemented.");
  367. break;
  368. default:
  369. // TODO(bunnei): Implement support for other processor IDs
  370. ASSERT_MSG(false, "Unsupported thread processor ID: %d", processor_id);
  371. break;
  372. }
  373. CASCADE_RESULT(SharedPtr<Thread> thread,
  374. Thread::Create(name, entry_point, priority, arg, processor_id, stack_top,
  375. g_current_process));
  376. CASCADE_RESULT(thread->guest_handle, g_handle_table.Create(thread));
  377. *out_handle = thread->guest_handle;
  378. Core::System::GetInstance().PrepareReschedule();
  379. LOG_TRACE(Kernel_SVC,
  380. "called entrypoint=0x%08X (%s), arg=0x%08X, stacktop=0x%08X, "
  381. "threadpriority=0x%08X, processorid=0x%08X : created handle=0x%08X",
  382. entry_point, name.c_str(), arg, stack_top, priority, processor_id, *out_handle);
  383. return RESULT_SUCCESS;
  384. }
  385. /// Starts the thread for the provided handle
  386. static ResultCode StartThread(Handle thread_handle) {
  387. LOG_TRACE(Kernel_SVC, "called thread=0x%08X", thread_handle);
  388. const SharedPtr<Thread> thread = g_handle_table.Get<Thread>(thread_handle);
  389. if (!thread) {
  390. return ERR_INVALID_HANDLE;
  391. }
  392. thread->ResumeFromWait();
  393. return RESULT_SUCCESS;
  394. }
  395. /// Called when a thread exits
  396. static void ExitThread() {
  397. LOG_TRACE(Kernel_SVC, "called, pc=0x%08X", Core::CPU().GetPC());
  398. ExitCurrentThread();
  399. Core::System::GetInstance().PrepareReschedule();
  400. }
  401. /// Sleep the current thread
  402. static void SleepThread(s64 nanoseconds) {
  403. LOG_TRACE(Kernel_SVC, "called nanoseconds=%lld", nanoseconds);
  404. // Don't attempt to yield execution if there are no available threads to run,
  405. // this way we avoid a useless reschedule to the idle thread.
  406. if (nanoseconds == 0 && !HaveReadyThreads())
  407. return;
  408. // Sleep current thread and check for next thread to schedule
  409. WaitCurrentThread_Sleep();
  410. // Create an event to wake the thread up after the specified nanosecond delay has passed
  411. GetCurrentThread()->WakeAfterDelay(nanoseconds);
  412. Core::System::GetInstance().PrepareReschedule();
  413. }
  414. /// Signal process wide key atomic
  415. static ResultCode WaitProcessWideKeyAtomic(VAddr mutex_addr, VAddr condition_variable_addr,
  416. Handle thread_handle, s64 nano_seconds) {
  417. LOG_TRACE(
  418. Kernel_SVC,
  419. "called mutex_addr=%llx, condition_variable_addr=%llx, thread_handle=0x%08X, timeout=%d",
  420. mutex_addr, condition_variable_addr, thread_handle, nano_seconds);
  421. SharedPtr<Thread> thread = g_handle_table.Get<Thread>(thread_handle);
  422. ASSERT(thread);
  423. SharedPtr<Mutex> mutex = g_object_address_table.Get<Mutex>(mutex_addr);
  424. if (!mutex) {
  425. // Create a new mutex for the specified address if one does not already exist
  426. mutex = Mutex::Create(thread, mutex_addr);
  427. mutex->name = Common::StringFromFormat("mutex-%llx", mutex_addr);
  428. }
  429. ASSERT(mutex->GetOwnerHandle() == thread_handle);
  430. SharedPtr<ConditionVariable> condition_variable =
  431. g_object_address_table.Get<ConditionVariable>(condition_variable_addr);
  432. if (!condition_variable) {
  433. // Create a new condition_variable for the specified address if one does not already exist
  434. condition_variable =
  435. ConditionVariable::Create(condition_variable_addr, mutex_addr).Unwrap();
  436. condition_variable->name =
  437. Common::StringFromFormat("condition-variable-%llx", condition_variable_addr);
  438. }
  439. ASSERT(condition_variable->GetAvailableCount() == 0);
  440. ASSERT(condition_variable->mutex_addr == mutex_addr);
  441. auto wakeup_callback = [mutex, nano_seconds](ThreadWakeupReason reason,
  442. SharedPtr<Thread> thread,
  443. SharedPtr<WaitObject> object, size_t index) {
  444. ASSERT(thread->status == THREADSTATUS_WAIT_SYNCH_ANY);
  445. if (reason == ThreadWakeupReason::Timeout) {
  446. thread->SetWaitSynchronizationResult(RESULT_TIMEOUT);
  447. return true;
  448. }
  449. ASSERT(reason == ThreadWakeupReason::Signal);
  450. // Now try to acquire the mutex and don't resume if it's not available.
  451. if (!mutex->ShouldWait(thread.get())) {
  452. mutex->Acquire(thread.get());
  453. thread->SetWaitSynchronizationResult(RESULT_SUCCESS);
  454. return true;
  455. }
  456. if (nano_seconds == 0) {
  457. thread->SetWaitSynchronizationResult(RESULT_TIMEOUT);
  458. return true;
  459. }
  460. thread->wait_objects = {mutex};
  461. mutex->AddWaitingThread(thread);
  462. thread->status = THREADSTATUS_WAIT_SYNCH_ANY;
  463. // Create an event to wake the thread up after the
  464. // specified nanosecond delay has passed
  465. thread->WakeAfterDelay(nano_seconds);
  466. thread->wakeup_callback = DefaultThreadWakeupCallback;
  467. Core::System::GetInstance().PrepareReschedule();
  468. return false;
  469. };
  470. CASCADE_CODE(
  471. WaitSynchronization1(condition_variable, thread.get(), nano_seconds, wakeup_callback));
  472. mutex->Release(thread.get());
  473. return RESULT_SUCCESS;
  474. }
  475. /// Signal process wide key
  476. static ResultCode SignalProcessWideKey(VAddr condition_variable_addr, s32 target) {
  477. LOG_TRACE(Kernel_SVC, "called, condition_variable_addr=0x%llx, target=0x%08x",
  478. condition_variable_addr, target);
  479. // Wakeup all or one thread - Any other value is unimplemented
  480. ASSERT(target == -1 || target == 1);
  481. SharedPtr<ConditionVariable> condition_variable =
  482. g_object_address_table.Get<ConditionVariable>(condition_variable_addr);
  483. if (!condition_variable) {
  484. // Create a new condition_variable for the specified address if one does not already exist
  485. condition_variable = ConditionVariable::Create(condition_variable_addr).Unwrap();
  486. condition_variable->name =
  487. Common::StringFromFormat("condition-variable-%llx", condition_variable_addr);
  488. }
  489. CASCADE_CODE(condition_variable->Release(target));
  490. if (condition_variable->mutex_addr) {
  491. // If a mutex was created for this condition_variable, wait the current thread on it
  492. SharedPtr<Mutex> mutex = g_object_address_table.Get<Mutex>(condition_variable->mutex_addr);
  493. return WaitSynchronization1(mutex, GetCurrentThread());
  494. }
  495. return RESULT_SUCCESS;
  496. }
  497. /// Close a handle
  498. static ResultCode CloseHandle(Handle handle) {
  499. LOG_TRACE(Kernel_SVC, "Closing handle 0x%08X", handle);
  500. return g_handle_table.Close(handle);
  501. }
  502. namespace {
  503. struct FunctionDef {
  504. using Func = void();
  505. u32 id;
  506. Func* func;
  507. const char* name;
  508. };
  509. } // namespace
  510. static const FunctionDef SVC_Table[] = {
  511. {0x00, nullptr, "Unknown"},
  512. {0x01, SvcWrap<SetHeapSize>, "SetHeapSize"},
  513. {0x02, nullptr, "SetMemoryPermission"},
  514. {0x03, nullptr, "SetMemoryAttribute"},
  515. {0x04, SvcWrap<MapMemory>, "MapMemory"},
  516. {0x05, SvcWrap<UnmapMemory>, "UnmapMemory"},
  517. {0x06, SvcWrap<QueryMemory>, "QueryMemory"},
  518. {0x07, SvcWrap<ExitProcess>, "ExitProcess"},
  519. {0x08, SvcWrap<CreateThread>, "CreateThread"},
  520. {0x09, SvcWrap<StartThread>, "StartThread"},
  521. {0x0A, SvcWrap<ExitThread>, "ExitThread"},
  522. {0x0B, SvcWrap<SleepThread>, "SleepThread"},
  523. {0x0C, SvcWrap<GetThreadPriority>, "GetThreadPriority"},
  524. {0x0D, SvcWrap<SetThreadPriority>, "SetThreadPriority"},
  525. {0x0E, nullptr, "GetThreadCoreMask"},
  526. {0x0F, nullptr, "SetThreadCoreMask"},
  527. {0x10, SvcWrap<GetCurrentProcessorNumber>, "GetCurrentProcessorNumber"},
  528. {0x11, nullptr, "SignalEvent"},
  529. {0x12, nullptr, "ClearEvent"},
  530. {0x13, nullptr, "MapSharedMemory"},
  531. {0x14, nullptr, "UnmapSharedMemory"},
  532. {0x15, nullptr, "CreateTransferMemory"},
  533. {0x16, SvcWrap<CloseHandle>, "CloseHandle"},
  534. {0x17, nullptr, "ResetSignal"},
  535. {0x18, SvcWrap<WaitSynchronization>, "WaitSynchronization"},
  536. {0x19, SvcWrap<CancelSynchronization>, "CancelSynchronization"},
  537. {0x1A, SvcWrap<LockMutex>, "LockMutex"},
  538. {0x1B, SvcWrap<UnlockMutex>, "UnlockMutex"},
  539. {0x1C, SvcWrap<WaitProcessWideKeyAtomic>, "WaitProcessWideKeyAtomic"},
  540. {0x1D, SvcWrap<SignalProcessWideKey>, "SignalProcessWideKey"},
  541. {0x1E, nullptr, "GetSystemTick"},
  542. {0x1F, SvcWrap<ConnectToPort>, "ConnectToPort"},
  543. {0x20, nullptr, "SendSyncRequestLight"},
  544. {0x21, SvcWrap<SendSyncRequest>, "SendSyncRequest"},
  545. {0x22, nullptr, "SendSyncRequestWithUserBuffer"},
  546. {0x23, nullptr, "SendAsyncRequestWithUserBuffer"},
  547. {0x24, SvcWrap<GetProcessId>, "GetProcessId"},
  548. {0x25, SvcWrap<GetThreadId>, "GetThreadId"},
  549. {0x26, SvcWrap<Break>, "Break"},
  550. {0x27, SvcWrap<OutputDebugString>, "OutputDebugString"},
  551. {0x28, nullptr, "ReturnFromException"},
  552. {0x29, SvcWrap<GetInfo>, "GetInfo"},
  553. {0x2A, nullptr, "FlushEntireDataCache"},
  554. {0x2B, nullptr, "FlushDataCache"},
  555. {0x2C, nullptr, "MapPhysicalMemory"},
  556. {0x2D, nullptr, "UnmapPhysicalMemory"},
  557. {0x2E, nullptr, "Unknown"},
  558. {0x2F, nullptr, "GetLastThreadInfo"},
  559. {0x30, nullptr, "GetResourceLimitLimitValue"},
  560. {0x31, nullptr, "GetResourceLimitCurrentValue"},
  561. {0x32, nullptr, "SetThreadActivity"},
  562. {0x33, nullptr, "GetThreadContext"},
  563. {0x34, nullptr, "Unknown"},
  564. {0x35, nullptr, "Unknown"},
  565. {0x36, nullptr, "Unknown"},
  566. {0x37, nullptr, "Unknown"},
  567. {0x38, nullptr, "Unknown"},
  568. {0x39, nullptr, "Unknown"},
  569. {0x3A, nullptr, "Unknown"},
  570. {0x3B, nullptr, "Unknown"},
  571. {0x3C, nullptr, "DumpInfo"},
  572. {0x3D, nullptr, "Unknown"},
  573. {0x3E, nullptr, "Unknown"},
  574. {0x3F, nullptr, "Unknown"},
  575. {0x40, nullptr, "CreateSession"},
  576. {0x41, nullptr, "AcceptSession"},
  577. {0x42, nullptr, "ReplyAndReceiveLight"},
  578. {0x43, nullptr, "ReplyAndReceive"},
  579. {0x44, nullptr, "ReplyAndReceiveWithUserBuffer"},
  580. {0x45, nullptr, "CreateEvent"},
  581. {0x46, nullptr, "Unknown"},
  582. {0x47, nullptr, "Unknown"},
  583. {0x48, nullptr, "Unknown"},
  584. {0x49, nullptr, "Unknown"},
  585. {0x4A, nullptr, "Unknown"},
  586. {0x4B, nullptr, "Unknown"},
  587. {0x4C, nullptr, "Unknown"},
  588. {0x4D, nullptr, "SleepSystem"},
  589. {0x4E, nullptr, "ReadWriteRegister"},
  590. {0x4F, nullptr, "SetProcessActivity"},
  591. {0x50, nullptr, "CreateSharedMemory"},
  592. {0x51, nullptr, "MapTransferMemory"},
  593. {0x52, nullptr, "UnmapTransferMemory"},
  594. {0x53, nullptr, "CreateInterruptEvent"},
  595. {0x54, nullptr, "QueryPhysicalAddress"},
  596. {0x55, nullptr, "QueryIoMapping"},
  597. {0x56, nullptr, "CreateDeviceAddressSpace"},
  598. {0x57, nullptr, "AttachDeviceAddressSpace"},
  599. {0x58, nullptr, "DetachDeviceAddressSpace"},
  600. {0x59, nullptr, "MapDeviceAddressSpaceByForce"},
  601. {0x5A, nullptr, "MapDeviceAddressSpaceAligned"},
  602. {0x5B, nullptr, "MapDeviceAddressSpace"},
  603. {0x5C, nullptr, "UnmapDeviceAddressSpace"},
  604. {0x5D, nullptr, "InvalidateProcessDataCache"},
  605. {0x5E, nullptr, "StoreProcessDataCache"},
  606. {0x5F, nullptr, "FlushProcessDataCache"},
  607. {0x60, nullptr, "DebugActiveProcess"},
  608. {0x61, nullptr, "BreakDebugProcess"},
  609. {0x62, nullptr, "TerminateDebugProcess"},
  610. {0x63, nullptr, "GetDebugEvent"},
  611. {0x64, nullptr, "ContinueDebugEvent"},
  612. {0x65, nullptr, "GetProcessList"},
  613. {0x66, nullptr, "GetThreadList"},
  614. {0x67, nullptr, "GetDebugThreadContext"},
  615. {0x68, nullptr, "SetDebugThreadContext"},
  616. {0x69, nullptr, "QueryDebugProcessMemory"},
  617. {0x6A, nullptr, "ReadDebugProcessMemory"},
  618. {0x6B, nullptr, "WriteDebugProcessMemory"},
  619. {0x6C, nullptr, "SetHardwareBreakPoint"},
  620. {0x6D, nullptr, "GetDebugThreadParam"},
  621. {0x6E, nullptr, "Unknown"},
  622. {0x6F, nullptr, "Unknown"},
  623. {0x70, nullptr, "CreatePort"},
  624. {0x71, nullptr, "ManageNamedPort"},
  625. {0x72, nullptr, "ConnectToPort"},
  626. {0x73, nullptr, "SetProcessMemoryPermission"},
  627. {0x74, nullptr, "MapProcessMemory"},
  628. {0x75, nullptr, "UnmapProcessMemory"},
  629. {0x76, nullptr, "QueryProcessMemory"},
  630. {0x77, nullptr, "MapProcessCodeMemory"},
  631. {0x78, nullptr, "UnmapProcessCodeMemory"},
  632. {0x79, nullptr, "CreateProcess"},
  633. {0x7A, nullptr, "StartProcess"},
  634. {0x7B, nullptr, "TerminateProcess"},
  635. {0x7C, nullptr, "GetProcessInfo"},
  636. {0x7D, nullptr, "CreateResourceLimit"},
  637. {0x7E, nullptr, "SetResourceLimitLimitValue"},
  638. {0x7F, nullptr, "CallSecureMonitor"},
  639. };
  640. static const FunctionDef* GetSVCInfo(u32 func_num) {
  641. if (func_num >= ARRAY_SIZE(SVC_Table)) {
  642. LOG_ERROR(Kernel_SVC, "unknown svc=0x%02X", func_num);
  643. return nullptr;
  644. }
  645. return &SVC_Table[func_num];
  646. }
  647. MICROPROFILE_DEFINE(Kernel_SVC, "Kernel", "SVC", MP_RGB(70, 200, 70));
  648. void CallSVC(u32 immediate) {
  649. MICROPROFILE_SCOPE(Kernel_SVC);
  650. // Lock the global kernel mutex when we enter the kernel HLE.
  651. std::lock_guard<std::recursive_mutex> lock(HLE::g_hle_lock);
  652. const FunctionDef* info = GetSVCInfo(immediate);
  653. if (info) {
  654. if (info->func) {
  655. info->func();
  656. } else {
  657. LOG_CRITICAL(Kernel_SVC, "unimplemented SVC function %s(..)", info->name);
  658. }
  659. } else {
  660. LOG_CRITICAL(Kernel_SVC, "unknown SVC function 0x%x", immediate);
  661. }
  662. }
  663. } // namespace Kernel