svc.cpp 49 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350
  1. // Copyright 2014 Citra Emulator Project
  2. // Licensed under GPLv2 or any later version
  3. // Refer to the license.txt file included.
  4. #include <algorithm>
  5. #include <cinttypes>
  6. #include <map>
  7. #include "common/logging/log.h"
  8. #include "common/microprofile.h"
  9. #include "common/scope_exit.h"
  10. #include "common/string_util.h"
  11. #include "core/arm/arm_interface.h"
  12. #include "core/core_timing.h"
  13. #include "core/hle/function_wrappers.h"
  14. #include "core/hle/kernel/address_arbiter.h"
  15. #include "core/hle/kernel/client_port.h"
  16. #include "core/hle/kernel/client_session.h"
  17. #include "core/hle/kernel/errors.h"
  18. #include "core/hle/kernel/event.h"
  19. #include "core/hle/kernel/handle_table.h"
  20. #include "core/hle/kernel/memory.h"
  21. #include "core/hle/kernel/mutex.h"
  22. #include "core/hle/kernel/process.h"
  23. #include "core/hle/kernel/resource_limit.h"
  24. #include "core/hle/kernel/semaphore.h"
  25. #include "core/hle/kernel/server_port.h"
  26. #include "core/hle/kernel/server_session.h"
  27. #include "core/hle/kernel/session.h"
  28. #include "core/hle/kernel/shared_memory.h"
  29. #include "core/hle/kernel/thread.h"
  30. #include "core/hle/kernel/timer.h"
  31. #include "core/hle/kernel/vm_manager.h"
  32. #include "core/hle/kernel/wait_object.h"
  33. #include "core/hle/lock.h"
  34. #include "core/hle/result.h"
  35. #include "core/hle/service/service.h"
  36. ////////////////////////////////////////////////////////////////////////////////////////////////////
  37. // Namespace SVC
  38. using Kernel::ERR_INVALID_HANDLE;
  39. using Kernel::Handle;
  40. using Kernel::SharedPtr;
  41. namespace SVC {
  42. enum ControlMemoryOperation {
  43. MEMOP_FREE = 1,
  44. MEMOP_RESERVE = 2, // This operation seems to be unsupported in the kernel
  45. MEMOP_COMMIT = 3,
  46. MEMOP_MAP = 4,
  47. MEMOP_UNMAP = 5,
  48. MEMOP_PROTECT = 6,
  49. MEMOP_OPERATION_MASK = 0xFF,
  50. MEMOP_REGION_APP = 0x100,
  51. MEMOP_REGION_SYSTEM = 0x200,
  52. MEMOP_REGION_BASE = 0x300,
  53. MEMOP_REGION_MASK = 0xF00,
  54. MEMOP_LINEAR = 0x10000,
  55. };
  56. /// Map application or GSP heap memory
  57. static ResultCode ControlMemory(u32* out_addr, u32 operation, u32 addr0, u32 addr1, u32 size,
  58. u32 permissions) {
  59. using namespace Kernel;
  60. LOG_DEBUG(Kernel_SVC,
  61. "called operation=0x%08X, addr0=0x%08X, addr1=0x%08X, size=0x%X, permissions=0x%08X",
  62. operation, addr0, addr1, size, permissions);
  63. if ((addr0 & Memory::PAGE_MASK) != 0 || (addr1 & Memory::PAGE_MASK) != 0) {
  64. return ERR_MISALIGNED_ADDRESS;
  65. }
  66. if ((size & Memory::PAGE_MASK) != 0) {
  67. return ERR_MISALIGNED_SIZE;
  68. }
  69. u32 region = operation & MEMOP_REGION_MASK;
  70. operation &= ~MEMOP_REGION_MASK;
  71. if (region != 0) {
  72. LOG_WARNING(Kernel_SVC, "ControlMemory with specified region not supported, region=%X",
  73. region);
  74. }
  75. if ((permissions & (u32)MemoryPermission::ReadWrite) != permissions) {
  76. return ERR_INVALID_COMBINATION;
  77. }
  78. VMAPermission vma_permissions = (VMAPermission)permissions;
  79. auto& process = *g_current_process;
  80. switch (operation & MEMOP_OPERATION_MASK) {
  81. case MEMOP_FREE: {
  82. // TODO(Subv): What happens if an application tries to FREE a block of memory that has a
  83. // SharedMemory pointing to it?
  84. if (addr0 >= Memory::HEAP_VADDR && addr0 < Memory::HEAP_VADDR_END) {
  85. ResultCode result = process.HeapFree(addr0, size);
  86. if (result.IsError())
  87. return result;
  88. } else if (addr0 >= process.GetLinearHeapBase() && addr0 < process.GetLinearHeapLimit()) {
  89. ResultCode result = process.LinearFree(addr0, size);
  90. if (result.IsError())
  91. return result;
  92. } else {
  93. return ERR_INVALID_ADDRESS;
  94. }
  95. *out_addr = addr0;
  96. break;
  97. }
  98. case MEMOP_COMMIT: {
  99. if (operation & MEMOP_LINEAR) {
  100. CASCADE_RESULT(*out_addr, process.LinearAllocate(addr0, size, vma_permissions));
  101. } else {
  102. CASCADE_RESULT(*out_addr, process.HeapAllocate(addr0, size, vma_permissions));
  103. }
  104. break;
  105. }
  106. case MEMOP_MAP: // TODO: This is just a hack to avoid regressions until memory aliasing is
  107. // implemented
  108. {
  109. CASCADE_RESULT(*out_addr, process.HeapAllocate(addr0, size, vma_permissions));
  110. break;
  111. }
  112. case MEMOP_UNMAP: // TODO: This is just a hack to avoid regressions until memory aliasing is
  113. // implemented
  114. {
  115. ResultCode result = process.HeapFree(addr0, size);
  116. if (result.IsError())
  117. return result;
  118. break;
  119. }
  120. case MEMOP_PROTECT: {
  121. ResultCode result = process.vm_manager.ReprotectRange(addr0, size, vma_permissions);
  122. if (result.IsError())
  123. return result;
  124. break;
  125. }
  126. default:
  127. LOG_ERROR(Kernel_SVC, "unknown operation=0x%08X", operation);
  128. return ERR_INVALID_COMBINATION;
  129. }
  130. process.vm_manager.LogLayout(Log::Level::Trace);
  131. return RESULT_SUCCESS;
  132. }
  133. /// Maps a memory block to specified address
  134. static ResultCode MapMemoryBlock(Kernel::Handle handle, u32 addr, u32 permissions,
  135. u32 other_permissions) {
  136. using Kernel::SharedMemory;
  137. using Kernel::MemoryPermission;
  138. LOG_TRACE(Kernel_SVC,
  139. "called memblock=0x%08X, addr=0x%08X, mypermissions=0x%08X, otherpermission=%d",
  140. handle, addr, permissions, other_permissions);
  141. SharedPtr<SharedMemory> shared_memory = Kernel::g_handle_table.Get<SharedMemory>(handle);
  142. if (shared_memory == nullptr)
  143. return ERR_INVALID_HANDLE;
  144. MemoryPermission permissions_type = static_cast<MemoryPermission>(permissions);
  145. switch (permissions_type) {
  146. case MemoryPermission::Read:
  147. case MemoryPermission::Write:
  148. case MemoryPermission::ReadWrite:
  149. case MemoryPermission::Execute:
  150. case MemoryPermission::ReadExecute:
  151. case MemoryPermission::WriteExecute:
  152. case MemoryPermission::ReadWriteExecute:
  153. case MemoryPermission::DontCare:
  154. return shared_memory->Map(Kernel::g_current_process.get(), addr, permissions_type,
  155. static_cast<MemoryPermission>(other_permissions));
  156. default:
  157. LOG_ERROR(Kernel_SVC, "unknown permissions=0x%08X", permissions);
  158. }
  159. return Kernel::ERR_INVALID_COMBINATION;
  160. }
  161. static ResultCode UnmapMemoryBlock(Kernel::Handle handle, u32 addr) {
  162. using Kernel::SharedMemory;
  163. LOG_TRACE(Kernel_SVC, "called memblock=0x%08X, addr=0x%08X", handle, addr);
  164. // TODO(Subv): Return E0A01BF5 if the address is not in the application's heap
  165. SharedPtr<SharedMemory> shared_memory = Kernel::g_handle_table.Get<SharedMemory>(handle);
  166. if (shared_memory == nullptr)
  167. return ERR_INVALID_HANDLE;
  168. return shared_memory->Unmap(Kernel::g_current_process.get(), addr);
  169. }
  170. /// Connect to an OS service given the port name, returns the handle to the port to out
  171. static ResultCode ConnectToPort(Kernel::Handle* out_handle, const char* port_name) {
  172. if (port_name == nullptr)
  173. return Kernel::ERR_NOT_FOUND;
  174. if (std::strlen(port_name) > 11)
  175. return Kernel::ERR_PORT_NAME_TOO_LONG;
  176. LOG_TRACE(Kernel_SVC, "called port_name=%s", port_name);
  177. auto it = Service::g_kernel_named_ports.find(port_name);
  178. if (it == Service::g_kernel_named_ports.end()) {
  179. LOG_WARNING(Kernel_SVC, "tried to connect to unknown port: %s", port_name);
  180. return Kernel::ERR_NOT_FOUND;
  181. }
  182. auto client_port = it->second;
  183. SharedPtr<Kernel::ClientSession> client_session;
  184. CASCADE_RESULT(client_session, client_port->Connect());
  185. // Return the client session
  186. CASCADE_RESULT(*out_handle, Kernel::g_handle_table.Create(client_session));
  187. return RESULT_SUCCESS;
  188. }
  189. /// Makes a blocking IPC call to an OS service.
  190. static ResultCode SendSyncRequest(Kernel::Handle handle) {
  191. SharedPtr<Kernel::ClientSession> session =
  192. Kernel::g_handle_table.Get<Kernel::ClientSession>(handle);
  193. if (session == nullptr) {
  194. return ERR_INVALID_HANDLE;
  195. }
  196. LOG_TRACE(Kernel_SVC, "called handle=0x%08X(%s)", handle, session->GetName().c_str());
  197. Core::System::GetInstance().PrepareReschedule();
  198. // TODO(Subv): svcSendSyncRequest should put the caller thread to sleep while the server
  199. // responds and cause a reschedule.
  200. return session->SendSyncRequest(Kernel::GetCurrentThread());
  201. }
  202. /// Close a handle
  203. static ResultCode CloseHandle(Kernel::Handle handle) {
  204. LOG_TRACE(Kernel_SVC, "Closing handle 0x%08X", handle);
  205. return Kernel::g_handle_table.Close(handle);
  206. }
  207. /// Wait for a handle to synchronize, timeout after the specified nanoseconds
  208. static ResultCode WaitSynchronization1(Kernel::Handle handle, s64 nano_seconds) {
  209. auto object = Kernel::g_handle_table.Get<Kernel::WaitObject>(handle);
  210. Kernel::Thread* thread = Kernel::GetCurrentThread();
  211. if (object == nullptr)
  212. return ERR_INVALID_HANDLE;
  213. LOG_TRACE(Kernel_SVC, "called handle=0x%08X(%s:%s), nanoseconds=%lld", handle,
  214. object->GetTypeName().c_str(), object->GetName().c_str(), nano_seconds);
  215. if (object->ShouldWait(thread)) {
  216. if (nano_seconds == 0)
  217. return Kernel::RESULT_TIMEOUT;
  218. thread->wait_objects = {object};
  219. object->AddWaitingThread(thread);
  220. thread->status = THREADSTATUS_WAIT_SYNCH_ANY;
  221. // Create an event to wake the thread up after the specified nanosecond delay has passed
  222. thread->WakeAfterDelay(nano_seconds);
  223. Core::System::GetInstance().PrepareReschedule();
  224. // Note: The output of this SVC will be set to RESULT_SUCCESS if the thread
  225. // resumes due to a signal in its wait objects.
  226. // Otherwise we retain the default value of timeout.
  227. return Kernel::RESULT_TIMEOUT;
  228. }
  229. object->Acquire(thread);
  230. return RESULT_SUCCESS;
  231. }
  232. /// Wait for the given handles to synchronize, timeout after the specified nanoseconds
  233. static ResultCode WaitSynchronizationN(s32* out, Kernel::Handle* handles, s32 handle_count,
  234. bool wait_all, s64 nano_seconds) {
  235. Kernel::Thread* thread = Kernel::GetCurrentThread();
  236. // Check if 'handles' is invalid
  237. if (handles == nullptr)
  238. return Kernel::ERR_INVALID_POINTER;
  239. // NOTE: on real hardware, there is no nullptr check for 'out' (tested with firmware 4.4). If
  240. // this happens, the running application will crash.
  241. ASSERT_MSG(out != nullptr, "invalid output pointer specified!");
  242. // Check if 'handle_count' is invalid
  243. if (handle_count < 0)
  244. return Kernel::ERR_OUT_OF_RANGE;
  245. using ObjectPtr = Kernel::SharedPtr<Kernel::WaitObject>;
  246. std::vector<ObjectPtr> objects(handle_count);
  247. for (int i = 0; i < handle_count; ++i) {
  248. auto object = Kernel::g_handle_table.Get<Kernel::WaitObject>(handles[i]);
  249. if (object == nullptr)
  250. return ERR_INVALID_HANDLE;
  251. objects[i] = object;
  252. }
  253. if (wait_all) {
  254. bool all_available =
  255. std::all_of(objects.begin(), objects.end(),
  256. [thread](const ObjectPtr& object) { return !object->ShouldWait(thread); });
  257. if (all_available) {
  258. // We can acquire all objects right now, do so.
  259. for (auto& object : objects)
  260. object->Acquire(thread);
  261. // Note: In this case, the `out` parameter is not set,
  262. // and retains whatever value it had before.
  263. return RESULT_SUCCESS;
  264. }
  265. // Not all objects were available right now, prepare to suspend the thread.
  266. // If a timeout value of 0 was provided, just return the Timeout error code instead of
  267. // suspending the thread.
  268. if (nano_seconds == 0)
  269. return Kernel::RESULT_TIMEOUT;
  270. // Put the thread to sleep
  271. thread->status = THREADSTATUS_WAIT_SYNCH_ALL;
  272. // Add the thread to each of the objects' waiting threads.
  273. for (auto& object : objects) {
  274. object->AddWaitingThread(thread);
  275. }
  276. thread->wait_objects = std::move(objects);
  277. // Create an event to wake the thread up after the specified nanosecond delay has passed
  278. thread->WakeAfterDelay(nano_seconds);
  279. Core::System::GetInstance().PrepareReschedule();
  280. // This value gets set to -1 by default in this case, it is not modified after this.
  281. *out = -1;
  282. // Note: The output of this SVC will be set to RESULT_SUCCESS if the thread resumes due to
  283. // a signal in one of its wait objects.
  284. return Kernel::RESULT_TIMEOUT;
  285. } else {
  286. // Find the first object that is acquirable in the provided list of objects
  287. auto itr = std::find_if(objects.begin(), objects.end(), [thread](const ObjectPtr& object) {
  288. return !object->ShouldWait(thread);
  289. });
  290. if (itr != objects.end()) {
  291. // We found a ready object, acquire it and set the result value
  292. Kernel::WaitObject* object = itr->get();
  293. object->Acquire(thread);
  294. *out = std::distance(objects.begin(), itr);
  295. return RESULT_SUCCESS;
  296. }
  297. // No objects were ready to be acquired, prepare to suspend the thread.
  298. // If a timeout value of 0 was provided, just return the Timeout error code instead of
  299. // suspending the thread.
  300. if (nano_seconds == 0)
  301. return Kernel::RESULT_TIMEOUT;
  302. // Put the thread to sleep
  303. thread->status = THREADSTATUS_WAIT_SYNCH_ANY;
  304. // Add the thread to each of the objects' waiting threads.
  305. for (size_t i = 0; i < objects.size(); ++i) {
  306. Kernel::WaitObject* object = objects[i].get();
  307. object->AddWaitingThread(thread);
  308. }
  309. thread->wait_objects = std::move(objects);
  310. // Note: If no handles and no timeout were given, then the thread will deadlock, this is
  311. // consistent with hardware behavior.
  312. // Create an event to wake the thread up after the specified nanosecond delay has passed
  313. thread->WakeAfterDelay(nano_seconds);
  314. Core::System::GetInstance().PrepareReschedule();
  315. // Note: The output of this SVC will be set to RESULT_SUCCESS if the thread resumes due to a
  316. // signal in one of its wait objects.
  317. // Otherwise we retain the default value of timeout, and -1 in the out parameter
  318. thread->wait_set_output = true;
  319. *out = -1;
  320. return Kernel::RESULT_TIMEOUT;
  321. }
  322. }
  323. /// In a single operation, sends a IPC reply and waits for a new request.
  324. static ResultCode ReplyAndReceive(s32* index, Kernel::Handle* handles, s32 handle_count,
  325. Kernel::Handle reply_target) {
  326. // 'handles' has to be a valid pointer even if 'handle_count' is 0.
  327. if (handles == nullptr)
  328. return Kernel::ERR_INVALID_POINTER;
  329. // Check if 'handle_count' is invalid
  330. if (handle_count < 0)
  331. return Kernel::ERR_OUT_OF_RANGE;
  332. using ObjectPtr = SharedPtr<Kernel::WaitObject>;
  333. std::vector<ObjectPtr> objects(handle_count);
  334. for (int i = 0; i < handle_count; ++i) {
  335. auto object = Kernel::g_handle_table.Get<Kernel::WaitObject>(handles[i]);
  336. if (object == nullptr)
  337. return ERR_INVALID_HANDLE;
  338. objects[i] = object;
  339. }
  340. // We are also sending a command reply.
  341. // Do not send a reply if the command id in the command buffer is 0xFFFF.
  342. u32* cmd_buff = Kernel::GetCommandBuffer();
  343. IPC::Header header{cmd_buff[0]};
  344. if (reply_target != 0 && header.command_id != 0xFFFF) {
  345. auto session = Kernel::g_handle_table.Get<Kernel::ServerSession>(reply_target);
  346. if (session == nullptr)
  347. return ERR_INVALID_HANDLE;
  348. auto request_thread = std::move(session->currently_handling);
  349. // Mark the request as "handled".
  350. session->currently_handling = nullptr;
  351. // Error out if there's no request thread or the session was closed.
  352. // TODO(Subv): Is the same error code (ClosedByRemote) returned for both of these cases?
  353. if (request_thread == nullptr || session->parent->client == nullptr) {
  354. *index = -1;
  355. return Kernel::ERR_SESSION_CLOSED_BY_REMOTE;
  356. }
  357. // TODO(Subv): Perform IPC translation from the current thread to request_thread.
  358. // Note: The scheduler is not invoked here.
  359. request_thread->ResumeFromWait();
  360. }
  361. if (handle_count == 0) {
  362. *index = 0;
  363. // The kernel uses this value as a placeholder for the real error, and returns it when we
  364. // pass no handles and do not perform any reply.
  365. if (reply_target == 0 || header.command_id == 0xFFFF)
  366. return ResultCode(0xE7E3FFFF);
  367. return RESULT_SUCCESS;
  368. }
  369. auto thread = Kernel::GetCurrentThread();
  370. // Find the first object that is acquirable in the provided list of objects
  371. auto itr = std::find_if(objects.begin(), objects.end(), [thread](const ObjectPtr& object) {
  372. return !object->ShouldWait(thread);
  373. });
  374. if (itr != objects.end()) {
  375. // We found a ready object, acquire it and set the result value
  376. Kernel::WaitObject* object = itr->get();
  377. object->Acquire(thread);
  378. *index = std::distance(objects.begin(), itr);
  379. if (object->GetHandleType() == Kernel::HandleType::ServerSession) {
  380. auto server_session = static_cast<Kernel::ServerSession*>(object);
  381. if (server_session->parent->client == nullptr)
  382. return Kernel::ERR_SESSION_CLOSED_BY_REMOTE;
  383. // TODO(Subv): Perform IPC translation from the ServerSession to the current thread.
  384. }
  385. return RESULT_SUCCESS;
  386. }
  387. // No objects were ready to be acquired, prepare to suspend the thread.
  388. // TODO(Subv): Perform IPC translation upon wakeup.
  389. // Put the thread to sleep
  390. thread->status = THREADSTATUS_WAIT_SYNCH_ANY;
  391. // Add the thread to each of the objects' waiting threads.
  392. for (size_t i = 0; i < objects.size(); ++i) {
  393. Kernel::WaitObject* object = objects[i].get();
  394. object->AddWaitingThread(thread);
  395. }
  396. thread->wait_objects = std::move(objects);
  397. Core::System::GetInstance().PrepareReschedule();
  398. // Note: The output of this SVC will be set to RESULT_SUCCESS if the thread resumes due to a
  399. // signal in one of its wait objects, or to 0xC8A01836 if there was a translation error.
  400. // By default the index is set to -1.
  401. thread->wait_set_output = true;
  402. *index = -1;
  403. return RESULT_SUCCESS;
  404. }
  405. /// Create an address arbiter (to allocate access to shared resources)
  406. static ResultCode CreateAddressArbiter(Kernel::Handle* out_handle) {
  407. using Kernel::AddressArbiter;
  408. SharedPtr<AddressArbiter> arbiter = AddressArbiter::Create();
  409. CASCADE_RESULT(*out_handle, Kernel::g_handle_table.Create(std::move(arbiter)));
  410. LOG_TRACE(Kernel_SVC, "returned handle=0x%08X", *out_handle);
  411. return RESULT_SUCCESS;
  412. }
  413. /// Arbitrate address
  414. static ResultCode ArbitrateAddress(Kernel::Handle handle, u32 address, u32 type, u32 value,
  415. s64 nanoseconds) {
  416. using Kernel::AddressArbiter;
  417. LOG_TRACE(Kernel_SVC, "called handle=0x%08X, address=0x%08X, type=0x%08X, value=0x%08X", handle,
  418. address, type, value);
  419. SharedPtr<AddressArbiter> arbiter = Kernel::g_handle_table.Get<AddressArbiter>(handle);
  420. if (arbiter == nullptr)
  421. return ERR_INVALID_HANDLE;
  422. auto res = arbiter->ArbitrateAddress(static_cast<Kernel::ArbitrationType>(type), address, value,
  423. nanoseconds);
  424. // TODO(Subv): Identify in which specific cases this call should cause a reschedule.
  425. Core::System::GetInstance().PrepareReschedule();
  426. return res;
  427. }
  428. static void Break(u8 break_reason) {
  429. LOG_CRITICAL(Debug_Emulated, "Emulated program broke execution!");
  430. std::string reason_str;
  431. switch (break_reason) {
  432. case 0:
  433. reason_str = "PANIC";
  434. break;
  435. case 1:
  436. reason_str = "ASSERT";
  437. break;
  438. case 2:
  439. reason_str = "USER";
  440. break;
  441. default:
  442. reason_str = "UNKNOWN";
  443. break;
  444. }
  445. LOG_CRITICAL(Debug_Emulated, "Break reason: %s", reason_str.c_str());
  446. }
  447. /// Used to output a message on a debug hardware unit - does nothing on a retail unit
  448. static void OutputDebugString(const char* string, int len) {
  449. LOG_DEBUG(Debug_Emulated, "%.*s", len, string);
  450. }
  451. /// Get resource limit
  452. static ResultCode GetResourceLimit(Kernel::Handle* resource_limit, Kernel::Handle process_handle) {
  453. LOG_TRACE(Kernel_SVC, "called process=0x%08X", process_handle);
  454. SharedPtr<Kernel::Process> process =
  455. Kernel::g_handle_table.Get<Kernel::Process>(process_handle);
  456. if (process == nullptr)
  457. return ERR_INVALID_HANDLE;
  458. CASCADE_RESULT(*resource_limit, Kernel::g_handle_table.Create(process->resource_limit));
  459. return RESULT_SUCCESS;
  460. }
  461. /// Get resource limit current values
  462. static ResultCode GetResourceLimitCurrentValues(s64* values, Kernel::Handle resource_limit_handle,
  463. u32* names, u32 name_count) {
  464. LOG_TRACE(Kernel_SVC, "called resource_limit=%08X, names=%p, name_count=%d",
  465. resource_limit_handle, names, name_count);
  466. SharedPtr<Kernel::ResourceLimit> resource_limit =
  467. Kernel::g_handle_table.Get<Kernel::ResourceLimit>(resource_limit_handle);
  468. if (resource_limit == nullptr)
  469. return ERR_INVALID_HANDLE;
  470. for (unsigned int i = 0; i < name_count; ++i)
  471. values[i] = resource_limit->GetCurrentResourceValue(names[i]);
  472. return RESULT_SUCCESS;
  473. }
  474. /// Get resource limit max values
  475. static ResultCode GetResourceLimitLimitValues(s64* values, Kernel::Handle resource_limit_handle,
  476. u32* names, u32 name_count) {
  477. LOG_TRACE(Kernel_SVC, "called resource_limit=%08X, names=%p, name_count=%d",
  478. resource_limit_handle, names, name_count);
  479. SharedPtr<Kernel::ResourceLimit> resource_limit =
  480. Kernel::g_handle_table.Get<Kernel::ResourceLimit>(resource_limit_handle);
  481. if (resource_limit == nullptr)
  482. return ERR_INVALID_HANDLE;
  483. for (unsigned int i = 0; i < name_count; ++i)
  484. values[i] = resource_limit->GetMaxResourceValue(names[i]);
  485. return RESULT_SUCCESS;
  486. }
  487. /// Creates a new thread
  488. static ResultCode CreateThread(Kernel::Handle* out_handle, u32 priority, u32 entry_point, u32 arg,
  489. u32 stack_top, s32 processor_id) {
  490. using Kernel::Thread;
  491. std::string name = Common::StringFromFormat("unknown-%08" PRIX32, entry_point);
  492. if (priority > THREADPRIO_LOWEST) {
  493. return Kernel::ERR_OUT_OF_RANGE;
  494. }
  495. using Kernel::ResourceLimit;
  496. Kernel::SharedPtr<ResourceLimit>& resource_limit = Kernel::g_current_process->resource_limit;
  497. if (resource_limit->GetMaxResourceValue(Kernel::ResourceTypes::PRIORITY) > priority) {
  498. return Kernel::ERR_NOT_AUTHORIZED;
  499. }
  500. switch (processor_id) {
  501. case THREADPROCESSORID_ALL:
  502. case THREADPROCESSORID_DEFAULT:
  503. case THREADPROCESSORID_0:
  504. case THREADPROCESSORID_1:
  505. break;
  506. default:
  507. // TODO(bunnei): Implement support for other processor IDs
  508. ASSERT_MSG(false, "Unsupported thread processor ID: %d", processor_id);
  509. break;
  510. }
  511. if (processor_id == THREADPROCESSORID_ALL) {
  512. LOG_INFO(Kernel_SVC,
  513. "Newly created thread is allowed to be run in any Core, unimplemented.");
  514. }
  515. if (processor_id == THREADPROCESSORID_DEFAULT &&
  516. Kernel::g_current_process->ideal_processor == THREADPROCESSORID_1) {
  517. LOG_WARNING(
  518. Kernel_SVC,
  519. "Newly created thread is allowed to be run in the SysCore (Core1), unimplemented.");
  520. }
  521. if (processor_id == THREADPROCESSORID_1) {
  522. LOG_ERROR(Kernel_SVC,
  523. "Newly created thread must run in the SysCore (Core1), unimplemented.");
  524. }
  525. CASCADE_RESULT(SharedPtr<Thread> thread,
  526. Kernel::Thread::Create(name, entry_point, priority, arg, processor_id, stack_top,
  527. Kernel::g_current_process));
  528. thread->context.fpscr =
  529. FPSCR_DEFAULT_NAN | FPSCR_FLUSH_TO_ZERO | FPSCR_ROUND_TOZERO; // 0x03C00000
  530. CASCADE_RESULT(*out_handle, Kernel::g_handle_table.Create(std::move(thread)));
  531. Core::System::GetInstance().PrepareReschedule();
  532. LOG_TRACE(Kernel_SVC, "called entrypoint=0x%08X (%s), arg=0x%08X, stacktop=0x%08X, "
  533. "threadpriority=0x%08X, processorid=0x%08X : created handle=0x%08X",
  534. entry_point, name.c_str(), arg, stack_top, priority, processor_id, *out_handle);
  535. return RESULT_SUCCESS;
  536. }
  537. /// Called when a thread exits
  538. static void ExitThread() {
  539. LOG_TRACE(Kernel_SVC, "called, pc=0x%08X", Core::CPU().GetPC());
  540. Kernel::ExitCurrentThread();
  541. Core::System::GetInstance().PrepareReschedule();
  542. }
  543. /// Gets the priority for the specified thread
  544. static ResultCode GetThreadPriority(s32* priority, Kernel::Handle handle) {
  545. const SharedPtr<Kernel::Thread> thread = Kernel::g_handle_table.Get<Kernel::Thread>(handle);
  546. if (thread == nullptr)
  547. return ERR_INVALID_HANDLE;
  548. *priority = thread->GetPriority();
  549. return RESULT_SUCCESS;
  550. }
  551. /// Sets the priority for the specified thread
  552. static ResultCode SetThreadPriority(Kernel::Handle handle, s32 priority) {
  553. if (priority > THREADPRIO_LOWEST) {
  554. return Kernel::ERR_OUT_OF_RANGE;
  555. }
  556. SharedPtr<Kernel::Thread> thread = Kernel::g_handle_table.Get<Kernel::Thread>(handle);
  557. if (thread == nullptr)
  558. return ERR_INVALID_HANDLE;
  559. using Kernel::ResourceLimit;
  560. // Note: The kernel uses the current process's resource limit instead of
  561. // the one from the thread owner's resource limit.
  562. Kernel::SharedPtr<ResourceLimit>& resource_limit = Kernel::g_current_process->resource_limit;
  563. if (resource_limit->GetMaxResourceValue(Kernel::ResourceTypes::PRIORITY) > priority) {
  564. return Kernel::ERR_NOT_AUTHORIZED;
  565. }
  566. thread->SetPriority(priority);
  567. thread->UpdatePriority();
  568. // Update the mutexes that this thread is waiting for
  569. for (auto& mutex : thread->pending_mutexes)
  570. mutex->UpdatePriority();
  571. Core::System::GetInstance().PrepareReschedule();
  572. return RESULT_SUCCESS;
  573. }
  574. /// Create a mutex
  575. static ResultCode CreateMutex(Kernel::Handle* out_handle, u32 initial_locked) {
  576. using Kernel::Mutex;
  577. SharedPtr<Mutex> mutex = Mutex::Create(initial_locked != 0);
  578. mutex->name = Common::StringFromFormat("mutex-%08x", Core::CPU().GetReg(14));
  579. CASCADE_RESULT(*out_handle, Kernel::g_handle_table.Create(std::move(mutex)));
  580. LOG_TRACE(Kernel_SVC, "called initial_locked=%s : created handle=0x%08X",
  581. initial_locked ? "true" : "false", *out_handle);
  582. return RESULT_SUCCESS;
  583. }
  584. /// Release a mutex
  585. static ResultCode ReleaseMutex(Kernel::Handle handle) {
  586. using Kernel::Mutex;
  587. LOG_TRACE(Kernel_SVC, "called handle=0x%08X", handle);
  588. SharedPtr<Mutex> mutex = Kernel::g_handle_table.Get<Mutex>(handle);
  589. if (mutex == nullptr)
  590. return ERR_INVALID_HANDLE;
  591. mutex->Release();
  592. return RESULT_SUCCESS;
  593. }
  594. /// Get the ID of the specified process
  595. static ResultCode GetProcessId(u32* process_id, Kernel::Handle process_handle) {
  596. LOG_TRACE(Kernel_SVC, "called process=0x%08X", process_handle);
  597. const SharedPtr<Kernel::Process> process =
  598. Kernel::g_handle_table.Get<Kernel::Process>(process_handle);
  599. if (process == nullptr)
  600. return ERR_INVALID_HANDLE;
  601. *process_id = process->process_id;
  602. return RESULT_SUCCESS;
  603. }
  604. /// Get the ID of the process that owns the specified thread
  605. static ResultCode GetProcessIdOfThread(u32* process_id, Kernel::Handle thread_handle) {
  606. LOG_TRACE(Kernel_SVC, "called thread=0x%08X", thread_handle);
  607. const SharedPtr<Kernel::Thread> thread =
  608. Kernel::g_handle_table.Get<Kernel::Thread>(thread_handle);
  609. if (thread == nullptr)
  610. return ERR_INVALID_HANDLE;
  611. const SharedPtr<Kernel::Process> process = thread->owner_process;
  612. ASSERT_MSG(process != nullptr, "Invalid parent process for thread=0x%08X", thread_handle);
  613. *process_id = process->process_id;
  614. return RESULT_SUCCESS;
  615. }
  616. /// Get the ID for the specified thread.
  617. static ResultCode GetThreadId(u32* thread_id, Kernel::Handle handle) {
  618. LOG_TRACE(Kernel_SVC, "called thread=0x%08X", handle);
  619. const SharedPtr<Kernel::Thread> thread = Kernel::g_handle_table.Get<Kernel::Thread>(handle);
  620. if (thread == nullptr)
  621. return ERR_INVALID_HANDLE;
  622. *thread_id = thread->GetThreadId();
  623. return RESULT_SUCCESS;
  624. }
  625. /// Creates a semaphore
  626. static ResultCode CreateSemaphore(Kernel::Handle* out_handle, s32 initial_count, s32 max_count) {
  627. using Kernel::Semaphore;
  628. CASCADE_RESULT(SharedPtr<Semaphore> semaphore, Semaphore::Create(initial_count, max_count));
  629. semaphore->name = Common::StringFromFormat("semaphore-%08x", Core::CPU().GetReg(14));
  630. CASCADE_RESULT(*out_handle, Kernel::g_handle_table.Create(std::move(semaphore)));
  631. LOG_TRACE(Kernel_SVC, "called initial_count=%d, max_count=%d, created handle=0x%08X",
  632. initial_count, max_count, *out_handle);
  633. return RESULT_SUCCESS;
  634. }
  635. /// Releases a certain number of slots in a semaphore
  636. static ResultCode ReleaseSemaphore(s32* count, Kernel::Handle handle, s32 release_count) {
  637. using Kernel::Semaphore;
  638. LOG_TRACE(Kernel_SVC, "called release_count=%d, handle=0x%08X", release_count, handle);
  639. SharedPtr<Semaphore> semaphore = Kernel::g_handle_table.Get<Semaphore>(handle);
  640. if (semaphore == nullptr)
  641. return ERR_INVALID_HANDLE;
  642. CASCADE_RESULT(*count, semaphore->Release(release_count));
  643. return RESULT_SUCCESS;
  644. }
  645. /// Query process memory
  646. static ResultCode QueryProcessMemory(MemoryInfo* memory_info, PageInfo* page_info,
  647. Kernel::Handle process_handle, u32 addr) {
  648. using Kernel::Process;
  649. Kernel::SharedPtr<Process> process = Kernel::g_handle_table.Get<Process>(process_handle);
  650. if (process == nullptr)
  651. return ERR_INVALID_HANDLE;
  652. auto vma = process->vm_manager.FindVMA(addr);
  653. if (vma == Kernel::g_current_process->vm_manager.vma_map.end())
  654. return Kernel::ERR_INVALID_ADDRESS;
  655. memory_info->base_address = vma->second.base;
  656. memory_info->permission = static_cast<u32>(vma->second.permissions);
  657. memory_info->size = vma->second.size;
  658. memory_info->state = static_cast<u32>(vma->second.meminfo_state);
  659. page_info->flags = 0;
  660. LOG_TRACE(Kernel_SVC, "called process=0x%08X addr=0x%08X", process_handle, addr);
  661. return RESULT_SUCCESS;
  662. }
  663. /// Query memory
  664. static ResultCode QueryMemory(MemoryInfo* memory_info, PageInfo* page_info, u32 addr) {
  665. return QueryProcessMemory(memory_info, page_info, Kernel::CurrentProcess, addr);
  666. }
  667. /// Create an event
  668. static ResultCode CreateEvent(Kernel::Handle* out_handle, u32 reset_type) {
  669. using Kernel::Event;
  670. SharedPtr<Event> evt = Event::Create(static_cast<Kernel::ResetType>(reset_type));
  671. evt->name = Common::StringFromFormat("event-%08x", Core::CPU().GetReg(14));
  672. CASCADE_RESULT(*out_handle, Kernel::g_handle_table.Create(std::move(evt)));
  673. LOG_TRACE(Kernel_SVC, "called reset_type=0x%08X : created handle=0x%08X", reset_type,
  674. *out_handle);
  675. return RESULT_SUCCESS;
  676. }
  677. /// Duplicates a kernel handle
  678. static ResultCode DuplicateHandle(Kernel::Handle* out, Kernel::Handle handle) {
  679. CASCADE_RESULT(*out, Kernel::g_handle_table.Duplicate(handle));
  680. LOG_TRACE(Kernel_SVC, "duplicated 0x%08X to 0x%08X", handle, *out);
  681. return RESULT_SUCCESS;
  682. }
  683. /// Signals an event
  684. static ResultCode SignalEvent(Kernel::Handle handle) {
  685. using Kernel::Event;
  686. LOG_TRACE(Kernel_SVC, "called event=0x%08X", handle);
  687. SharedPtr<Event> evt = Kernel::g_handle_table.Get<Kernel::Event>(handle);
  688. if (evt == nullptr)
  689. return ERR_INVALID_HANDLE;
  690. evt->Signal();
  691. return RESULT_SUCCESS;
  692. }
  693. /// Clears an event
  694. static ResultCode ClearEvent(Kernel::Handle handle) {
  695. using Kernel::Event;
  696. LOG_TRACE(Kernel_SVC, "called event=0x%08X", handle);
  697. SharedPtr<Event> evt = Kernel::g_handle_table.Get<Kernel::Event>(handle);
  698. if (evt == nullptr)
  699. return ERR_INVALID_HANDLE;
  700. evt->Clear();
  701. return RESULT_SUCCESS;
  702. }
  703. /// Creates a timer
  704. static ResultCode CreateTimer(Kernel::Handle* out_handle, u32 reset_type) {
  705. using Kernel::Timer;
  706. SharedPtr<Timer> timer = Timer::Create(static_cast<Kernel::ResetType>(reset_type));
  707. timer->name = Common::StringFromFormat("timer-%08x", Core::CPU().GetReg(14));
  708. CASCADE_RESULT(*out_handle, Kernel::g_handle_table.Create(std::move(timer)));
  709. LOG_TRACE(Kernel_SVC, "called reset_type=0x%08X : created handle=0x%08X", reset_type,
  710. *out_handle);
  711. return RESULT_SUCCESS;
  712. }
  713. /// Clears a timer
  714. static ResultCode ClearTimer(Kernel::Handle handle) {
  715. using Kernel::Timer;
  716. LOG_TRACE(Kernel_SVC, "called timer=0x%08X", handle);
  717. SharedPtr<Timer> timer = Kernel::g_handle_table.Get<Timer>(handle);
  718. if (timer == nullptr)
  719. return ERR_INVALID_HANDLE;
  720. timer->Clear();
  721. return RESULT_SUCCESS;
  722. }
  723. /// Starts a timer
  724. static ResultCode SetTimer(Kernel::Handle handle, s64 initial, s64 interval) {
  725. using Kernel::Timer;
  726. LOG_TRACE(Kernel_SVC, "called timer=0x%08X", handle);
  727. if (initial < 0 || interval < 0) {
  728. return Kernel::ERR_OUT_OF_RANGE_KERNEL;
  729. }
  730. SharedPtr<Timer> timer = Kernel::g_handle_table.Get<Timer>(handle);
  731. if (timer == nullptr)
  732. return ERR_INVALID_HANDLE;
  733. timer->Set(initial, interval);
  734. return RESULT_SUCCESS;
  735. }
  736. /// Cancels a timer
  737. static ResultCode CancelTimer(Kernel::Handle handle) {
  738. using Kernel::Timer;
  739. LOG_TRACE(Kernel_SVC, "called timer=0x%08X", handle);
  740. SharedPtr<Timer> timer = Kernel::g_handle_table.Get<Timer>(handle);
  741. if (timer == nullptr)
  742. return ERR_INVALID_HANDLE;
  743. timer->Cancel();
  744. return RESULT_SUCCESS;
  745. }
  746. /// Sleep the current thread
  747. static void SleepThread(s64 nanoseconds) {
  748. LOG_TRACE(Kernel_SVC, "called nanoseconds=%lld", nanoseconds);
  749. // Don't attempt to yield execution if there are no available threads to run,
  750. // this way we avoid a useless reschedule to the idle thread.
  751. if (nanoseconds == 0 && !Kernel::HaveReadyThreads())
  752. return;
  753. // Sleep current thread and check for next thread to schedule
  754. Kernel::WaitCurrentThread_Sleep();
  755. // Create an event to wake the thread up after the specified nanosecond delay has passed
  756. Kernel::GetCurrentThread()->WakeAfterDelay(nanoseconds);
  757. Core::System::GetInstance().PrepareReschedule();
  758. }
  759. /// This returns the total CPU ticks elapsed since the CPU was powered-on
  760. static s64 GetSystemTick() {
  761. s64 result = CoreTiming::GetTicks();
  762. // Advance time to defeat dumb games (like Cubic Ninja) that busy-wait for the frame to end.
  763. Core::CPU().AddTicks(150); // Measured time between two calls on a 9.2 o3DS with Ninjhax 1.1b
  764. return result;
  765. }
  766. /// Creates a memory block at the specified address with the specified permissions and size
  767. static ResultCode CreateMemoryBlock(Kernel::Handle* out_handle, u32 addr, u32 size,
  768. u32 my_permission, u32 other_permission) {
  769. using Kernel::SharedMemory;
  770. if (size % Memory::PAGE_SIZE != 0)
  771. return Kernel::ERR_MISALIGNED_SIZE;
  772. SharedPtr<SharedMemory> shared_memory = nullptr;
  773. using Kernel::MemoryPermission;
  774. auto VerifyPermissions = [](MemoryPermission permission) {
  775. // SharedMemory blocks can not be created with Execute permissions
  776. switch (permission) {
  777. case MemoryPermission::None:
  778. case MemoryPermission::Read:
  779. case MemoryPermission::Write:
  780. case MemoryPermission::ReadWrite:
  781. case MemoryPermission::DontCare:
  782. return true;
  783. default:
  784. return false;
  785. }
  786. };
  787. if (!VerifyPermissions(static_cast<MemoryPermission>(my_permission)) ||
  788. !VerifyPermissions(static_cast<MemoryPermission>(other_permission)))
  789. return Kernel::ERR_INVALID_COMBINATION;
  790. // TODO(Subv): Processes with memory type APPLICATION are not allowed
  791. // to create memory blocks with addr = 0, any attempts to do so
  792. // should return error 0xD92007EA.
  793. if ((addr < Memory::PROCESS_IMAGE_VADDR || addr + size > Memory::SHARED_MEMORY_VADDR_END) &&
  794. addr != 0) {
  795. return Kernel::ERR_INVALID_ADDRESS;
  796. }
  797. // When trying to create a memory block with address = 0,
  798. // if the process has the Shared Device Memory flag in the exheader,
  799. // then we have to allocate from the same region as the caller process instead of the BASE
  800. // region.
  801. Kernel::MemoryRegion region = Kernel::MemoryRegion::BASE;
  802. if (addr == 0 && Kernel::g_current_process->flags.shared_device_mem)
  803. region = Kernel::g_current_process->flags.memory_region;
  804. shared_memory = SharedMemory::Create(
  805. Kernel::g_current_process, size, static_cast<MemoryPermission>(my_permission),
  806. static_cast<MemoryPermission>(other_permission), addr, region);
  807. CASCADE_RESULT(*out_handle, Kernel::g_handle_table.Create(std::move(shared_memory)));
  808. LOG_WARNING(Kernel_SVC, "called addr=0x%08X", addr);
  809. return RESULT_SUCCESS;
  810. }
  811. static ResultCode CreatePort(Kernel::Handle* server_port, Kernel::Handle* client_port,
  812. const char* name, u32 max_sessions) {
  813. // TODO(Subv): Implement named ports.
  814. ASSERT_MSG(name == nullptr, "Named ports are currently unimplemented");
  815. using Kernel::ServerPort;
  816. using Kernel::ClientPort;
  817. auto ports = ServerPort::CreatePortPair(max_sessions);
  818. CASCADE_RESULT(*client_port, Kernel::g_handle_table.Create(
  819. std::move(std::get<SharedPtr<ClientPort>>(ports))));
  820. // Note: The 3DS kernel also leaks the client port handle if the server port handle fails to be
  821. // created.
  822. CASCADE_RESULT(*server_port, Kernel::g_handle_table.Create(
  823. std::move(std::get<SharedPtr<ServerPort>>(ports))));
  824. LOG_TRACE(Kernel_SVC, "called max_sessions=%u", max_sessions);
  825. return RESULT_SUCCESS;
  826. }
  827. static ResultCode CreateSessionToPort(Handle* out_client_session, Handle client_port_handle) {
  828. using Kernel::ClientPort;
  829. SharedPtr<ClientPort> client_port = Kernel::g_handle_table.Get<ClientPort>(client_port_handle);
  830. if (client_port == nullptr)
  831. return ERR_INVALID_HANDLE;
  832. CASCADE_RESULT(auto session, client_port->Connect());
  833. CASCADE_RESULT(*out_client_session, Kernel::g_handle_table.Create(std::move(session)));
  834. return RESULT_SUCCESS;
  835. }
  836. static ResultCode CreateSession(Handle* server_session, Handle* client_session) {
  837. auto sessions = Kernel::ServerSession::CreateSessionPair();
  838. auto& server = std::get<SharedPtr<Kernel::ServerSession>>(sessions);
  839. CASCADE_RESULT(*server_session, Kernel::g_handle_table.Create(std::move(server)));
  840. auto& client = std::get<SharedPtr<Kernel::ClientSession>>(sessions);
  841. CASCADE_RESULT(*client_session, Kernel::g_handle_table.Create(std::move(client)));
  842. LOG_TRACE(Kernel_SVC, "called");
  843. return RESULT_SUCCESS;
  844. }
  845. static ResultCode AcceptSession(Handle* out_server_session, Handle server_port_handle) {
  846. using Kernel::ServerPort;
  847. SharedPtr<ServerPort> server_port = Kernel::g_handle_table.Get<ServerPort>(server_port_handle);
  848. if (server_port == nullptr)
  849. return ERR_INVALID_HANDLE;
  850. CASCADE_RESULT(auto session, server_port->Accept());
  851. CASCADE_RESULT(*out_server_session, Kernel::g_handle_table.Create(std::move(session)));
  852. return RESULT_SUCCESS;
  853. }
  854. static ResultCode GetSystemInfo(s64* out, u32 type, s32 param) {
  855. using Kernel::MemoryRegion;
  856. LOG_TRACE(Kernel_SVC, "called type=%u param=%d", type, param);
  857. switch ((SystemInfoType)type) {
  858. case SystemInfoType::REGION_MEMORY_USAGE:
  859. switch ((SystemInfoMemUsageRegion)param) {
  860. case SystemInfoMemUsageRegion::ALL:
  861. *out = Kernel::GetMemoryRegion(Kernel::MemoryRegion::APPLICATION)->used +
  862. Kernel::GetMemoryRegion(Kernel::MemoryRegion::SYSTEM)->used +
  863. Kernel::GetMemoryRegion(Kernel::MemoryRegion::BASE)->used;
  864. break;
  865. case SystemInfoMemUsageRegion::APPLICATION:
  866. *out = Kernel::GetMemoryRegion(Kernel::MemoryRegion::APPLICATION)->used;
  867. break;
  868. case SystemInfoMemUsageRegion::SYSTEM:
  869. *out = Kernel::GetMemoryRegion(Kernel::MemoryRegion::SYSTEM)->used;
  870. break;
  871. case SystemInfoMemUsageRegion::BASE:
  872. *out = Kernel::GetMemoryRegion(Kernel::MemoryRegion::BASE)->used;
  873. break;
  874. default:
  875. LOG_ERROR(Kernel_SVC, "unknown GetSystemInfo type=0 region: param=%d", param);
  876. *out = 0;
  877. break;
  878. }
  879. break;
  880. case SystemInfoType::KERNEL_ALLOCATED_PAGES:
  881. LOG_ERROR(Kernel_SVC, "unimplemented GetSystemInfo type=2 param=%d", param);
  882. *out = 0;
  883. break;
  884. case SystemInfoType::KERNEL_SPAWNED_PIDS:
  885. *out = 5;
  886. break;
  887. default:
  888. LOG_ERROR(Kernel_SVC, "unknown GetSystemInfo type=%u param=%d", type, param);
  889. *out = 0;
  890. break;
  891. }
  892. // This function never returns an error, even if invalid parameters were passed.
  893. return RESULT_SUCCESS;
  894. }
  895. static ResultCode GetProcessInfo(s64* out, Kernel::Handle process_handle, u32 type) {
  896. LOG_TRACE(Kernel_SVC, "called process=0x%08X type=%u", process_handle, type);
  897. using Kernel::Process;
  898. Kernel::SharedPtr<Process> process = Kernel::g_handle_table.Get<Process>(process_handle);
  899. if (process == nullptr)
  900. return ERR_INVALID_HANDLE;
  901. switch (type) {
  902. case 0:
  903. case 2:
  904. // TODO(yuriks): Type 0 returns a slightly higher number than type 2, but I'm not sure
  905. // what's the difference between them.
  906. *out = process->heap_used + process->linear_heap_used + process->misc_memory_used;
  907. if (*out % Memory::PAGE_SIZE != 0) {
  908. LOG_ERROR(Kernel_SVC, "called, memory size not page-aligned");
  909. return Kernel::ERR_MISALIGNED_SIZE;
  910. }
  911. break;
  912. case 1:
  913. case 3:
  914. case 4:
  915. case 5:
  916. case 6:
  917. case 7:
  918. case 8:
  919. // These are valid, but not implemented yet
  920. LOG_ERROR(Kernel_SVC, "unimplemented GetProcessInfo type=%u", type);
  921. break;
  922. case 20:
  923. *out = Memory::FCRAM_PADDR - process->GetLinearHeapBase();
  924. break;
  925. case 21:
  926. case 22:
  927. case 23:
  928. // These return a different error value than higher invalid values
  929. LOG_ERROR(Kernel_SVC, "unknown GetProcessInfo type=%u", type);
  930. return Kernel::ERR_NOT_IMPLEMENTED;
  931. default:
  932. LOG_ERROR(Kernel_SVC, "unknown GetProcessInfo type=%u", type);
  933. return Kernel::ERR_INVALID_ENUM_VALUE;
  934. }
  935. return RESULT_SUCCESS;
  936. }
  937. namespace {
  938. struct FunctionDef {
  939. using Func = void();
  940. u32 id;
  941. Func* func;
  942. const char* name;
  943. };
  944. } // namespace
  945. static const FunctionDef SVC_Table[] = {
  946. {0x00, nullptr, "Unknown"},
  947. {0x01, HLE::Wrap<ControlMemory>, "ControlMemory"},
  948. {0x02, HLE::Wrap<QueryMemory>, "QueryMemory"},
  949. {0x03, nullptr, "ExitProcess"},
  950. {0x04, nullptr, "GetProcessAffinityMask"},
  951. {0x05, nullptr, "SetProcessAffinityMask"},
  952. {0x06, nullptr, "GetProcessIdealProcessor"},
  953. {0x07, nullptr, "SetProcessIdealProcessor"},
  954. {0x08, HLE::Wrap<CreateThread>, "CreateThread"},
  955. {0x09, ExitThread, "ExitThread"},
  956. {0x0A, HLE::Wrap<SleepThread>, "SleepThread"},
  957. {0x0B, HLE::Wrap<GetThreadPriority>, "GetThreadPriority"},
  958. {0x0C, HLE::Wrap<SetThreadPriority>, "SetThreadPriority"},
  959. {0x0D, nullptr, "GetThreadAffinityMask"},
  960. {0x0E, nullptr, "SetThreadAffinityMask"},
  961. {0x0F, nullptr, "GetThreadIdealProcessor"},
  962. {0x10, nullptr, "SetThreadIdealProcessor"},
  963. {0x11, nullptr, "GetCurrentProcessorNumber"},
  964. {0x12, nullptr, "Run"},
  965. {0x13, HLE::Wrap<CreateMutex>, "CreateMutex"},
  966. {0x14, HLE::Wrap<ReleaseMutex>, "ReleaseMutex"},
  967. {0x15, HLE::Wrap<CreateSemaphore>, "CreateSemaphore"},
  968. {0x16, HLE::Wrap<ReleaseSemaphore>, "ReleaseSemaphore"},
  969. {0x17, HLE::Wrap<CreateEvent>, "CreateEvent"},
  970. {0x18, HLE::Wrap<SignalEvent>, "SignalEvent"},
  971. {0x19, HLE::Wrap<ClearEvent>, "ClearEvent"},
  972. {0x1A, HLE::Wrap<CreateTimer>, "CreateTimer"},
  973. {0x1B, HLE::Wrap<SetTimer>, "SetTimer"},
  974. {0x1C, HLE::Wrap<CancelTimer>, "CancelTimer"},
  975. {0x1D, HLE::Wrap<ClearTimer>, "ClearTimer"},
  976. {0x1E, HLE::Wrap<CreateMemoryBlock>, "CreateMemoryBlock"},
  977. {0x1F, HLE::Wrap<MapMemoryBlock>, "MapMemoryBlock"},
  978. {0x20, HLE::Wrap<UnmapMemoryBlock>, "UnmapMemoryBlock"},
  979. {0x21, HLE::Wrap<CreateAddressArbiter>, "CreateAddressArbiter"},
  980. {0x22, HLE::Wrap<ArbitrateAddress>, "ArbitrateAddress"},
  981. {0x23, HLE::Wrap<CloseHandle>, "CloseHandle"},
  982. {0x24, HLE::Wrap<WaitSynchronization1>, "WaitSynchronization1"},
  983. {0x25, HLE::Wrap<WaitSynchronizationN>, "WaitSynchronizationN"},
  984. {0x26, nullptr, "SignalAndWait"},
  985. {0x27, HLE::Wrap<DuplicateHandle>, "DuplicateHandle"},
  986. {0x28, HLE::Wrap<GetSystemTick>, "GetSystemTick"},
  987. {0x29, nullptr, "GetHandleInfo"},
  988. {0x2A, HLE::Wrap<GetSystemInfo>, "GetSystemInfo"},
  989. {0x2B, HLE::Wrap<GetProcessInfo>, "GetProcessInfo"},
  990. {0x2C, nullptr, "GetThreadInfo"},
  991. {0x2D, HLE::Wrap<ConnectToPort>, "ConnectToPort"},
  992. {0x2E, nullptr, "SendSyncRequest1"},
  993. {0x2F, nullptr, "SendSyncRequest2"},
  994. {0x30, nullptr, "SendSyncRequest3"},
  995. {0x31, nullptr, "SendSyncRequest4"},
  996. {0x32, HLE::Wrap<SendSyncRequest>, "SendSyncRequest"},
  997. {0x33, nullptr, "OpenProcess"},
  998. {0x34, nullptr, "OpenThread"},
  999. {0x35, HLE::Wrap<GetProcessId>, "GetProcessId"},
  1000. {0x36, HLE::Wrap<GetProcessIdOfThread>, "GetProcessIdOfThread"},
  1001. {0x37, HLE::Wrap<GetThreadId>, "GetThreadId"},
  1002. {0x38, HLE::Wrap<GetResourceLimit>, "GetResourceLimit"},
  1003. {0x39, HLE::Wrap<GetResourceLimitLimitValues>, "GetResourceLimitLimitValues"},
  1004. {0x3A, HLE::Wrap<GetResourceLimitCurrentValues>, "GetResourceLimitCurrentValues"},
  1005. {0x3B, nullptr, "GetThreadContext"},
  1006. {0x3C, HLE::Wrap<Break>, "Break"},
  1007. {0x3D, HLE::Wrap<OutputDebugString>, "OutputDebugString"},
  1008. {0x3E, nullptr, "ControlPerformanceCounter"},
  1009. {0x3F, nullptr, "Unknown"},
  1010. {0x40, nullptr, "Unknown"},
  1011. {0x41, nullptr, "Unknown"},
  1012. {0x42, nullptr, "Unknown"},
  1013. {0x43, nullptr, "Unknown"},
  1014. {0x44, nullptr, "Unknown"},
  1015. {0x45, nullptr, "Unknown"},
  1016. {0x46, nullptr, "Unknown"},
  1017. {0x47, HLE::Wrap<CreatePort>, "CreatePort"},
  1018. {0x48, HLE::Wrap<CreateSessionToPort>, "CreateSessionToPort"},
  1019. {0x49, HLE::Wrap<CreateSession>, "CreateSession"},
  1020. {0x4A, HLE::Wrap<AcceptSession>, "AcceptSession"},
  1021. {0x4B, nullptr, "ReplyAndReceive1"},
  1022. {0x4C, nullptr, "ReplyAndReceive2"},
  1023. {0x4D, nullptr, "ReplyAndReceive3"},
  1024. {0x4E, nullptr, "ReplyAndReceive4"},
  1025. {0x4F, HLE::Wrap<ReplyAndReceive>, "ReplyAndReceive"},
  1026. {0x50, nullptr, "BindInterrupt"},
  1027. {0x51, nullptr, "UnbindInterrupt"},
  1028. {0x52, nullptr, "InvalidateProcessDataCache"},
  1029. {0x53, nullptr, "StoreProcessDataCache"},
  1030. {0x54, nullptr, "FlushProcessDataCache"},
  1031. {0x55, nullptr, "StartInterProcessDma"},
  1032. {0x56, nullptr, "StopDma"},
  1033. {0x57, nullptr, "GetDmaState"},
  1034. {0x58, nullptr, "RestartDma"},
  1035. {0x59, nullptr, "Unknown"},
  1036. {0x5A, nullptr, "Unknown"},
  1037. {0x5B, nullptr, "Unknown"},
  1038. {0x5C, nullptr, "Unknown"},
  1039. {0x5D, nullptr, "Unknown"},
  1040. {0x5E, nullptr, "Unknown"},
  1041. {0x5F, nullptr, "Unknown"},
  1042. {0x60, nullptr, "DebugActiveProcess"},
  1043. {0x61, nullptr, "BreakDebugProcess"},
  1044. {0x62, nullptr, "TerminateDebugProcess"},
  1045. {0x63, nullptr, "GetProcessDebugEvent"},
  1046. {0x64, nullptr, "ContinueDebugEvent"},
  1047. {0x65, nullptr, "GetProcessList"},
  1048. {0x66, nullptr, "GetThreadList"},
  1049. {0x67, nullptr, "GetDebugThreadContext"},
  1050. {0x68, nullptr, "SetDebugThreadContext"},
  1051. {0x69, nullptr, "QueryDebugProcessMemory"},
  1052. {0x6A, nullptr, "ReadProcessMemory"},
  1053. {0x6B, nullptr, "WriteProcessMemory"},
  1054. {0x6C, nullptr, "SetHardwareBreakPoint"},
  1055. {0x6D, nullptr, "GetDebugThreadParam"},
  1056. {0x6E, nullptr, "Unknown"},
  1057. {0x6F, nullptr, "Unknown"},
  1058. {0x70, nullptr, "ControlProcessMemory"},
  1059. {0x71, nullptr, "MapProcessMemory"},
  1060. {0x72, nullptr, "UnmapProcessMemory"},
  1061. {0x73, nullptr, "CreateCodeSet"},
  1062. {0x74, nullptr, "RandomStub"},
  1063. {0x75, nullptr, "CreateProcess"},
  1064. {0x76, nullptr, "TerminateProcess"},
  1065. {0x77, nullptr, "SetProcessResourceLimits"},
  1066. {0x78, nullptr, "CreateResourceLimit"},
  1067. {0x79, nullptr, "SetResourceLimitValues"},
  1068. {0x7A, nullptr, "AddCodeSegment"},
  1069. {0x7B, nullptr, "Backdoor"},
  1070. {0x7C, nullptr, "KernelSetState"},
  1071. {0x7D, HLE::Wrap<QueryProcessMemory>, "QueryProcessMemory"},
  1072. };
  1073. static const FunctionDef* GetSVCInfo(u32 func_num) {
  1074. if (func_num >= ARRAY_SIZE(SVC_Table)) {
  1075. LOG_ERROR(Kernel_SVC, "unknown svc=0x%02X", func_num);
  1076. return nullptr;
  1077. }
  1078. return &SVC_Table[func_num];
  1079. }
  1080. MICROPROFILE_DEFINE(Kernel_SVC, "Kernel", "SVC", MP_RGB(70, 200, 70));
  1081. void CallSVC(u32 immediate) {
  1082. MICROPROFILE_SCOPE(Kernel_SVC);
  1083. // Lock the global kernel mutex when we enter the kernel HLE.
  1084. std::lock_guard<std::recursive_mutex> lock(HLE::g_hle_lock);
  1085. const FunctionDef* info = GetSVCInfo(immediate);
  1086. if (info) {
  1087. if (info->func) {
  1088. info->func();
  1089. } else {
  1090. LOG_ERROR(Kernel_SVC, "unimplemented SVC function %s(..)", info->name);
  1091. }
  1092. }
  1093. }
  1094. } // namespace SVC