Emulator.cpp 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992
  1. /*
  2. * Copyright (c) 2020, Andreas Kling <kling@serenityos.org>
  3. * All rights reserved.
  4. *
  5. * Redistribution and use in source and binary forms, with or without
  6. * modification, are permitted provided that the following conditions are met:
  7. *
  8. * 1. Redistributions of source code must retain the above copyright notice, this
  9. * list of conditions and the following disclaimer.
  10. *
  11. * 2. Redistributions in binary form must reproduce the above copyright notice,
  12. * this list of conditions and the following disclaimer in the documentation
  13. * and/or other materials provided with the distribution.
  14. *
  15. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  16. * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  17. * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
  18. * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
  19. * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  20. * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
  21. * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
  22. * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
  23. * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  24. * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  25. */
  26. #include "Emulator.h"
  27. #include "MmapRegion.h"
  28. #include "SharedBufferRegion.h"
  29. #include "SimpleRegion.h"
  30. #include "SoftCPU.h"
  31. #include <AK/LexicalPath.h>
  32. #include <AK/LogStream.h>
  33. #include <Kernel/API/Syscall.h>
  34. #include <fcntl.h>
  35. #include <serenity.h>
  36. #include <stdio.h>
  37. #include <string.h>
  38. #include <sys/ioctl.h>
  39. #include <sys/mman.h>
  40. #include <sys/select.h>
  41. #include <sys/socket.h>
  42. #include <sys/stat.h>
  43. #include <sys/time.h>
  44. #include <unistd.h>
  45. #if defined(__GNUC__) && !defined(__clang__)
  46. # pragma GCC optimize("O3")
  47. #endif
  48. //#define DEBUG_SPAM
  49. namespace UserspaceEmulator {
  50. static constexpr u32 stack_location = 0x10000000;
  51. static constexpr size_t stack_size = 64 * KB;
  52. static Emulator* s_the;
  53. Emulator& Emulator::the()
  54. {
  55. ASSERT(s_the);
  56. return *s_the;
  57. }
  58. Emulator::Emulator(const Vector<String>& arguments, const Vector<String>& environment, NonnullRefPtr<ELF::Loader> elf)
  59. : m_elf(move(elf))
  60. , m_cpu(*this)
  61. {
  62. m_malloc_tracer = make<MallocTracer>();
  63. ASSERT(!s_the);
  64. s_the = this;
  65. setup_stack(arguments, environment);
  66. }
  67. void Emulator::setup_stack(const Vector<String>& arguments, const Vector<String>& environment)
  68. {
  69. auto stack_region = make<SimpleRegion>(stack_location, stack_size);
  70. stack_region->set_stack(true);
  71. m_mmu.add_region(move(stack_region));
  72. m_cpu.set_esp(shadow_wrap_as_initialized<u32>(stack_location + stack_size));
  73. Vector<u32> argv_entries;
  74. for (auto& argument : arguments) {
  75. m_cpu.push_string(argument.characters());
  76. argv_entries.append(m_cpu.esp().value());
  77. }
  78. Vector<u32> env_entries;
  79. for (auto& variable : environment) {
  80. m_cpu.push_string(variable.characters());
  81. env_entries.append(m_cpu.esp().value());
  82. }
  83. m_cpu.push32(shadow_wrap_as_initialized<u32>(0)); // char** envp = { envv_entries..., nullptr }
  84. for (ssize_t i = env_entries.size() - 1; i >= 0; --i)
  85. m_cpu.push32(shadow_wrap_as_initialized(env_entries[i]));
  86. u32 envp = m_cpu.esp().value();
  87. m_cpu.push32(shadow_wrap_as_initialized<u32>(0)); // char** argv = { argv_entries..., nullptr }
  88. for (ssize_t i = argv_entries.size() - 1; i >= 0; --i)
  89. m_cpu.push32(shadow_wrap_as_initialized(argv_entries[i]));
  90. u32 argv = m_cpu.esp().value();
  91. m_cpu.push32(shadow_wrap_as_initialized<u32>(0)); // (alignment)
  92. u32 argc = argv_entries.size();
  93. m_cpu.push32(shadow_wrap_as_initialized(envp));
  94. m_cpu.push32(shadow_wrap_as_initialized(argv));
  95. m_cpu.push32(shadow_wrap_as_initialized(argc));
  96. m_cpu.push32(shadow_wrap_as_initialized<u32>(0)); // (alignment)
  97. }
  98. bool Emulator::load_elf()
  99. {
  100. m_elf->image().for_each_program_header([&](const ELF::Image::ProgramHeader& program_header) {
  101. if (program_header.type() == PT_LOAD) {
  102. auto region = make<SimpleRegion>(program_header.vaddr().get(), program_header.size_in_memory());
  103. if (program_header.is_executable() && !program_header.is_writable())
  104. region->set_text(true);
  105. memcpy(region->data(), program_header.raw_data(), program_header.size_in_image());
  106. memset(region->shadow_data(), 0x01, program_header.size_in_memory());
  107. mmu().add_region(move(region));
  108. return;
  109. }
  110. if (program_header.type() == PT_TLS) {
  111. auto tcb_region = make<SimpleRegion>(0x20000000, program_header.size_in_memory());
  112. memcpy(tcb_region->data(), program_header.raw_data(), program_header.size_in_image());
  113. memset(tcb_region->shadow_data(), 0x01, program_header.size_in_memory());
  114. auto tls_region = make<SimpleRegion>(0, 4);
  115. tls_region->write32(0, shadow_wrap_as_initialized(tcb_region->base() + program_header.size_in_memory()));
  116. memset(tls_region->shadow_data(), 0x01, 4);
  117. mmu().add_region(move(tcb_region));
  118. mmu().set_tls_region(move(tls_region));
  119. return;
  120. }
  121. });
  122. m_cpu.set_eip(m_elf->image().entry().get());
  123. auto malloc_symbol = m_elf->find_demangled_function("malloc");
  124. auto free_symbol = m_elf->find_demangled_function("free");
  125. m_malloc_symbol_start = malloc_symbol.value().value();
  126. m_malloc_symbol_end = m_malloc_symbol_start + malloc_symbol.value().size();
  127. m_free_symbol_start = free_symbol.value().value();
  128. m_free_symbol_end = m_free_symbol_start + free_symbol.value().size();
  129. m_debug_info = make<DebugInfo>(m_elf);
  130. return true;
  131. }
  132. class ELFSymbolProvider final : public X86::SymbolProvider {
  133. public:
  134. ELFSymbolProvider(ELF::Loader& loader)
  135. : m_loader(loader)
  136. {
  137. }
  138. virtual String symbolicate(FlatPtr address, u32* offset = nullptr) const
  139. {
  140. return m_loader.symbolicate(address, offset);
  141. }
  142. private:
  143. ELF::Loader& m_loader;
  144. };
  145. int Emulator::exec()
  146. {
  147. ELFSymbolProvider symbol_provider(*m_elf);
  148. bool trace = false;
  149. while (!m_shutdown) {
  150. m_cpu.save_base_eip();
  151. auto insn = X86::Instruction::from_stream(m_cpu, true, true);
  152. if (trace)
  153. out() << (const void*)m_cpu.base_eip() << " \033[33;1m" << insn.to_string(m_cpu.base_eip(), &symbol_provider) << "\033[0m";
  154. (m_cpu.*insn.handler())(insn);
  155. if (trace)
  156. m_cpu.dump();
  157. }
  158. if (auto* tracer = malloc_tracer())
  159. tracer->dump_leak_report();
  160. return m_exit_status;
  161. }
  162. bool Emulator::is_in_malloc_or_free() const
  163. {
  164. return (m_cpu.base_eip() >= m_malloc_symbol_start && m_cpu.base_eip() < m_malloc_symbol_end) || (m_cpu.base_eip() >= m_free_symbol_start && m_cpu.base_eip() < m_free_symbol_end);
  165. }
  166. Vector<FlatPtr> Emulator::raw_backtrace()
  167. {
  168. Vector<FlatPtr> backtrace;
  169. backtrace.append(m_cpu.base_eip());
  170. // FIXME: Maybe do something if the backtrace has uninitialized data in the frame chain.
  171. u32 frame_ptr = m_cpu.ebp().value();
  172. while (frame_ptr) {
  173. u32 ret_ptr = m_mmu.read32({ 0x20, frame_ptr + 4 }).value();
  174. if (!ret_ptr)
  175. break;
  176. backtrace.append(ret_ptr);
  177. frame_ptr = m_mmu.read32({ 0x20, frame_ptr }).value();
  178. }
  179. return backtrace;
  180. }
  181. void Emulator::dump_backtrace(const Vector<FlatPtr>& backtrace)
  182. {
  183. for (auto& address : backtrace) {
  184. u32 offset = 0;
  185. String symbol = m_elf->symbolicate(address, &offset);
  186. auto source_position = m_debug_info->get_source_position(address);
  187. report("==%d== %#08x %s +%#x", getpid(), address, symbol.characters(), offset);
  188. if (source_position.has_value())
  189. report(" (\033[34;1m%s\033[0m:%zu)", LexicalPath(source_position.value().file_path).basename().characters(), source_position.value().line_number);
  190. report("\n");
  191. }
  192. }
  193. void Emulator::dump_backtrace()
  194. {
  195. dump_backtrace(raw_backtrace());
  196. }
  197. u32 Emulator::virt_syscall(u32 function, u32 arg1, u32 arg2, u32 arg3)
  198. {
  199. #ifdef DEBUG_SPAM
  200. dbgprintf("Syscall: %s (%x)\n", Syscall::to_string((Syscall::Function)function), function);
  201. #endif
  202. switch (function) {
  203. case SC_execve:
  204. return virt$execve(arg1);
  205. case SC_stat:
  206. return virt$stat(arg1);
  207. case SC_realpath:
  208. return virt$realpath(arg1);
  209. case SC_gethostname:
  210. return virt$gethostname(arg1, arg2);
  211. case SC_ioctl:
  212. return virt$ioctl(arg1, arg2, arg3);
  213. case SC_get_dir_entries:
  214. return virt$get_dir_entries(arg1, arg2, arg3);
  215. case SC_usleep:
  216. return virt$usleep(arg1);
  217. case SC_shbuf_create:
  218. return virt$shbuf_create(arg1, arg2);
  219. case SC_shbuf_allow_pid:
  220. return virt$shbuf_allow_pid(arg1, arg2);
  221. case SC_shbuf_allow_all:
  222. return virt$shbuf_allow_all(arg1);
  223. case SC_shbuf_get:
  224. return virt$shbuf_get(arg1, arg2);
  225. case SC_shbuf_release:
  226. return virt$shbuf_release(arg1);
  227. case SC_shbuf_seal:
  228. return virt$shbuf_seal(arg1);
  229. case SC_shbuf_set_volatile:
  230. return virt$shbuf_set_volatile(arg1, arg2);
  231. case SC_mmap:
  232. return virt$mmap(arg1);
  233. case SC_munmap:
  234. return virt$munmap(arg1, arg2);
  235. case SC_gettid:
  236. return virt$gettid();
  237. case SC_getpid:
  238. return virt$getpid();
  239. case SC_pledge:
  240. return virt$pledge(arg1);
  241. case SC_unveil:
  242. return virt$unveil(arg1);
  243. case SC_getuid:
  244. return virt$getuid();
  245. case SC_getgid:
  246. return virt$getgid();
  247. case SC_setuid:
  248. return virt$setuid(arg1);
  249. case SC_setgid:
  250. return virt$setgid(arg2);
  251. case SC_close:
  252. return virt$close(arg1);
  253. case SC_fstat:
  254. return virt$fstat(arg1, arg2);
  255. case SC_mkdir:
  256. return virt$mkdir(arg1, arg2, arg3);
  257. case SC_unlink:
  258. return virt$unlink(arg1, arg2);
  259. case SC_write:
  260. return virt$write(arg1, arg2, arg3);
  261. case SC_read:
  262. return virt$read(arg1, arg2, arg3);
  263. case SC_mprotect:
  264. return virt$mprotect(arg1, arg2, arg3);
  265. case SC_madvise:
  266. return virt$madvise(arg1, arg2, arg3);
  267. case SC_open:
  268. return virt$open(arg1);
  269. case SC_pipe:
  270. return virt$pipe(arg1, arg2);
  271. case SC_fcntl:
  272. return virt$fcntl(arg1, arg2, arg3);
  273. case SC_getgroups:
  274. return virt$getgroups(arg1, arg2);
  275. case SC_lseek:
  276. return virt$lseek(arg1, arg2, arg3);
  277. case SC_socket:
  278. return virt$socket(arg1, arg2, arg3);
  279. case SC_getsockopt:
  280. return virt$getsockopt(arg1);
  281. case SC_get_process_name:
  282. return virt$get_process_name(arg1, arg2);
  283. case SC_dbgputstr:
  284. return virt$dbgputstr(arg1, arg2);
  285. case SC_dbgputch:
  286. return virt$dbgputch(arg1);
  287. case SC_fchmod:
  288. return virt$fchmod(arg1, arg2);
  289. case SC_accept:
  290. return virt$accept(arg1, arg2, arg3);
  291. case SC_setsockopt:
  292. return virt$setsockopt(arg1);
  293. case SC_bind:
  294. return virt$bind(arg1, arg2, arg3);
  295. case SC_connect:
  296. return virt$connect(arg1, arg2, arg3);
  297. case SC_listen:
  298. return virt$listen(arg1, arg2);
  299. case SC_select:
  300. return virt$select(arg1);
  301. case SC_recvfrom:
  302. return virt$recvfrom(arg1);
  303. case SC_kill:
  304. return virt$kill(arg1, arg2);
  305. case SC_set_mmap_name:
  306. return virt$set_mmap_name(arg1);
  307. case SC_set_process_icon:
  308. return virt$set_process_icon(arg1);
  309. case SC_exit:
  310. virt$exit((int)arg1);
  311. return 0;
  312. case SC_gettimeofday:
  313. return virt$gettimeofday(arg1);
  314. case SC_clock_gettime:
  315. return virt$clock_gettime(arg1, arg2);
  316. case SC_getrandom:
  317. return virt$getrandom(arg1, arg2, arg3);
  318. case SC_fork:
  319. return virt$fork();
  320. default:
  321. dbg() << "Unimplemented syscall: " << Syscall::to_string((Syscall::Function)function);
  322. dump_backtrace();
  323. TODO();
  324. }
  325. }
  326. int Emulator::virt$usleep(useconds_t us)
  327. {
  328. return syscall(SC_usleep, us);
  329. }
  330. int Emulator::virt$shbuf_create(int size, FlatPtr buffer)
  331. {
  332. u8* host_data = nullptr;
  333. int shbuf_id = syscall(SC_shbuf_create, size, &host_data);
  334. if (shbuf_id < 0)
  335. return shbuf_id;
  336. FlatPtr address = allocate_vm(size, PAGE_SIZE);
  337. auto region = SharedBufferRegion::create_with_shbuf_id(address, size, shbuf_id, host_data);
  338. m_mmu.add_region(move(region));
  339. m_mmu.copy_to_vm(buffer, &address, sizeof(address));
  340. return shbuf_id;
  341. }
  342. FlatPtr Emulator::virt$shbuf_get(int shbuf_id, FlatPtr size_ptr)
  343. {
  344. size_t host_size = 0;
  345. void* host_data = (void*)syscall(SC_shbuf_get, shbuf_id, &host_size);
  346. if (host_data == (void*)-1)
  347. return (FlatPtr)host_data;
  348. FlatPtr address = allocate_vm(host_size, PAGE_SIZE);
  349. auto region = SharedBufferRegion::create_with_shbuf_id(address, host_size, shbuf_id, (u8*)host_data);
  350. m_mmu.add_region(move(region));
  351. m_mmu.copy_to_vm(size_ptr, &host_size, sizeof(host_size));
  352. return address;
  353. }
  354. int Emulator::virt$shbuf_allow_pid(int shbuf_id, pid_t peer_pid)
  355. {
  356. auto* region = m_mmu.shbuf_region(shbuf_id);
  357. ASSERT(region);
  358. return region->allow_pid(peer_pid);
  359. }
  360. int Emulator::virt$shbuf_allow_all(int shbuf_id)
  361. {
  362. auto* region = m_mmu.shbuf_region(shbuf_id);
  363. ASSERT(region);
  364. return region->allow_all();
  365. }
  366. int Emulator::virt$shbuf_release(int shbuf_id)
  367. {
  368. auto* region = m_mmu.shbuf_region(shbuf_id);
  369. ASSERT(region);
  370. auto rc = region->release();
  371. m_mmu.remove_region(*region);
  372. return rc;
  373. }
  374. int Emulator::virt$shbuf_seal(int shbuf_id)
  375. {
  376. auto* region = m_mmu.shbuf_region(shbuf_id);
  377. ASSERT(region);
  378. return region->seal();
  379. }
  380. int Emulator::virt$shbuf_set_volatile(int shbuf_id, bool is_volatile)
  381. {
  382. auto* region = m_mmu.shbuf_region(shbuf_id);
  383. ASSERT(region);
  384. return region->set_volatile(is_volatile);
  385. }
  386. int Emulator::virt$fstat(int fd, FlatPtr statbuf)
  387. {
  388. struct stat local_statbuf;
  389. int rc = syscall(SC_fstat, fd, &local_statbuf);
  390. if (rc < 0)
  391. return rc;
  392. mmu().copy_to_vm(statbuf, &local_statbuf, sizeof(local_statbuf));
  393. return rc;
  394. }
  395. int Emulator::virt$close(int fd)
  396. {
  397. return syscall(SC_close, fd);
  398. }
  399. int Emulator::virt$mkdir(FlatPtr path, size_t path_length, mode_t mode)
  400. {
  401. auto buffer = mmu().copy_buffer_from_vm(path, path_length);
  402. return syscall(SC_mkdir, buffer.data(), buffer.size(), mode);
  403. }
  404. int Emulator::virt$unlink(FlatPtr path, size_t path_length)
  405. {
  406. auto buffer = mmu().copy_buffer_from_vm(path, path_length);
  407. return syscall(SC_unlink, buffer.data(), buffer.size());
  408. }
  409. int Emulator::virt$dbgputstr(FlatPtr characters, int length)
  410. {
  411. auto buffer = mmu().copy_buffer_from_vm(characters, length);
  412. dbgputstr((const char*)buffer.data(), buffer.size());
  413. return 0;
  414. }
  415. int Emulator::virt$fchmod(int fd, mode_t mode)
  416. {
  417. return syscall(SC_fchmod, fd, mode);
  418. }
  419. int Emulator::virt$setsockopt(FlatPtr params_addr)
  420. {
  421. Syscall::SC_setsockopt_params params;
  422. mmu().copy_from_vm(&params, params_addr, sizeof(params));
  423. if (params.option == SO_RCVTIMEO) {
  424. auto host_value_buffer = ByteBuffer::create_zeroed(params.value_size);
  425. mmu().copy_from_vm(host_value_buffer.data(), (FlatPtr)params.value, params.value_size);
  426. int rc = setsockopt(params.sockfd, params.level, SO_RCVTIMEO, host_value_buffer.data(), host_value_buffer.size());
  427. if (rc < 0)
  428. return -errno;
  429. return rc;
  430. }
  431. TODO();
  432. }
  433. int Emulator::virt$accept(int sockfd, FlatPtr address, FlatPtr address_length)
  434. {
  435. socklen_t host_address_length = 0;
  436. mmu().copy_from_vm(&host_address_length, address_length, sizeof(host_address_length));
  437. auto host_buffer = ByteBuffer::create_zeroed(host_address_length);
  438. int rc = syscall(SC_accept, sockfd, host_buffer.data(), &host_address_length);
  439. if (rc < 0)
  440. return rc;
  441. mmu().copy_to_vm(address, host_buffer.data(), min((socklen_t)host_buffer.size(), host_address_length));
  442. mmu().copy_to_vm(address_length, &host_address_length, sizeof(host_address_length));
  443. return rc;
  444. }
  445. int Emulator::virt$bind(int sockfd, FlatPtr address, socklen_t address_length)
  446. {
  447. auto buffer = mmu().copy_buffer_from_vm(address, address_length);
  448. return syscall(SC_bind, sockfd, buffer.data(), buffer.size());
  449. }
  450. int Emulator::virt$connect(int sockfd, FlatPtr address, socklen_t address_size)
  451. {
  452. auto buffer = mmu().copy_buffer_from_vm(address, address_size);
  453. return syscall(SC_connect, sockfd, buffer.data(), buffer.size());
  454. }
  455. int Emulator::virt$dbgputch(char ch)
  456. {
  457. dbgputch(ch);
  458. return 0;
  459. }
  460. int Emulator::virt$listen(int fd, int backlog)
  461. {
  462. return syscall(SC_listen, fd, backlog);
  463. }
  464. int Emulator::virt$kill(pid_t pid, int signal)
  465. {
  466. return syscall(SC_kill, pid, signal);
  467. }
  468. int Emulator::virt$set_process_icon(int shbuf_id)
  469. {
  470. return syscall(SC_set_process_icon, shbuf_id);
  471. }
  472. int Emulator::virt$gettimeofday(FlatPtr timeval)
  473. {
  474. struct timeval host_timeval;
  475. int rc = syscall(SC_gettimeofday, &host_timeval);
  476. if (rc < 0)
  477. return rc;
  478. mmu().copy_to_vm(timeval, &host_timeval, sizeof(host_timeval));
  479. return rc;
  480. }
  481. int Emulator::virt$clock_gettime(int clockid, FlatPtr timespec)
  482. {
  483. struct timespec host_timespec;
  484. int rc = syscall(SC_clock_gettime, clockid, &host_timespec);
  485. if (rc < 0)
  486. return rc;
  487. mmu().copy_to_vm(timespec, &host_timespec, sizeof(host_timespec));
  488. return rc;
  489. }
  490. int Emulator::virt$set_mmap_name(FlatPtr)
  491. {
  492. // FIXME: Implement.
  493. return 0;
  494. }
  495. int Emulator::virt$get_process_name(FlatPtr buffer, int size)
  496. {
  497. if (size < 0)
  498. return -EINVAL;
  499. auto host_buffer = ByteBuffer::create_zeroed((size_t)size);
  500. int rc = syscall(SC_get_process_name, host_buffer.data(), host_buffer.size());
  501. mmu().copy_to_vm(buffer, host_buffer.data(), host_buffer.size());
  502. return rc;
  503. }
  504. int Emulator::virt$lseek(int fd, off_t offset, int whence)
  505. {
  506. return syscall(SC_lseek, fd, offset, whence);
  507. }
  508. int Emulator::virt$socket(int domain, int type, int protocol)
  509. {
  510. return syscall(SC_socket, domain, type, protocol);
  511. }
  512. int Emulator::virt$recvfrom(FlatPtr params_addr)
  513. {
  514. Syscall::SC_recvfrom_params params;
  515. mmu().copy_from_vm(&params, params_addr, sizeof(params));
  516. auto buffer = ByteBuffer::create_uninitialized(params.buffer.size);
  517. sockaddr_un address;
  518. if (params.addr)
  519. mmu().copy_from_vm(&address, (FlatPtr)params.addr, sizeof(address));
  520. socklen_t address_length = 0;
  521. if (params.addr_length)
  522. mmu().copy_from_vm(&address_length, (FlatPtr)address_length, sizeof(address_length));
  523. int rc = recvfrom(params.sockfd, buffer.data(), buffer.size(), params.flags, params.addr ? (struct sockaddr*)&address : nullptr, params.addr_length ? &address_length : nullptr);
  524. if (rc < 0)
  525. return -errno;
  526. mmu().copy_to_vm((FlatPtr)params.buffer.data, buffer.data(), buffer.size());
  527. if (params.addr)
  528. mmu().copy_to_vm((FlatPtr)params.addr, &address, address_length);
  529. if (params.addr_length)
  530. mmu().copy_to_vm((FlatPtr)params.addr_length, &address_length, sizeof(address_length));
  531. return rc;
  532. }
  533. int Emulator::virt$select(FlatPtr params_addr)
  534. {
  535. Syscall::SC_select_params params;
  536. mmu().copy_from_vm(&params, params_addr, sizeof(params));
  537. fd_set readfds;
  538. fd_set writefds;
  539. fd_set exceptfds;
  540. struct timespec timeout;
  541. u32 sigmask;
  542. if (params.readfds)
  543. mmu().copy_from_vm(&readfds, (FlatPtr)params.readfds, sizeof(readfds));
  544. if (params.writefds)
  545. mmu().copy_from_vm(&writefds, (FlatPtr)params.writefds, sizeof(writefds));
  546. if (params.exceptfds)
  547. mmu().copy_from_vm(&exceptfds, (FlatPtr)params.exceptfds, sizeof(exceptfds));
  548. if (params.timeout)
  549. mmu().copy_from_vm(&timeout, (FlatPtr)params.timeout, sizeof(timeout));
  550. if (params.sigmask)
  551. mmu().copy_from_vm(&sigmask, (FlatPtr)params.sigmask, sizeof(sigmask));
  552. int rc = pselect(params.nfds, &readfds, &writefds, &exceptfds, params.timeout ? &timeout : nullptr, params.sigmask ? &sigmask : nullptr);
  553. if (rc < 0)
  554. return -errno;
  555. if (params.readfds)
  556. mmu().copy_to_vm((FlatPtr)params.readfds, &readfds, sizeof(readfds));
  557. if (params.writefds)
  558. mmu().copy_to_vm((FlatPtr)params.writefds, &writefds, sizeof(writefds));
  559. if (params.exceptfds)
  560. mmu().copy_to_vm((FlatPtr)params.exceptfds, &exceptfds, sizeof(exceptfds));
  561. if (params.timeout)
  562. mmu().copy_to_vm((FlatPtr)params.timeout, &timeout, sizeof(timeout));
  563. return rc;
  564. }
  565. int Emulator::virt$getsockopt(FlatPtr params_addr)
  566. {
  567. Syscall::SC_getsockopt_params params;
  568. mmu().copy_from_vm(&params, params_addr, sizeof(params));
  569. if (params.option == SO_PEERCRED) {
  570. struct ucred creds = {};
  571. socklen_t creds_size = sizeof(creds);
  572. int rc = getsockopt(params.sockfd, params.level, SO_PEERCRED, &creds, &creds_size);
  573. if (rc < 0)
  574. return -errno;
  575. // FIXME: Check params.value_size
  576. mmu().copy_to_vm((FlatPtr)params.value, &creds, sizeof(creds));
  577. return rc;
  578. }
  579. TODO();
  580. }
  581. int Emulator::virt$getgroups(ssize_t count, FlatPtr groups)
  582. {
  583. if (!count)
  584. return syscall(SC_getgroups, 0, nullptr);
  585. auto buffer = ByteBuffer::create_uninitialized(count * sizeof(gid_t));
  586. int rc = syscall(SC_getgroups, count, buffer.data());
  587. if (rc < 0)
  588. return rc;
  589. mmu().copy_to_vm(groups, buffer.data(), buffer.size());
  590. return 0;
  591. }
  592. u32 Emulator::virt$fcntl(int fd, int cmd, u32 arg)
  593. {
  594. switch (cmd) {
  595. case F_DUPFD:
  596. case F_GETFD:
  597. case F_SETFD:
  598. case F_GETFL:
  599. case F_SETFL:
  600. case F_ISTTY:
  601. break;
  602. default:
  603. TODO();
  604. }
  605. return syscall(SC_fcntl, fd, cmd, arg);
  606. }
  607. u32 Emulator::virt$open(u32 params_addr)
  608. {
  609. Syscall::SC_open_params params;
  610. mmu().copy_from_vm(&params, params_addr, sizeof(params));
  611. auto path = mmu().copy_buffer_from_vm((FlatPtr)params.path.characters, params.path.length);
  612. int fd = openat_with_path_length(params.dirfd, (const char*)path.data(), path.size(), params.options, params.mode);
  613. if (fd < 0)
  614. return -errno;
  615. return fd;
  616. }
  617. int Emulator::virt$pipe(FlatPtr vm_pipefd, int flags)
  618. {
  619. int pipefd[2];
  620. int rc = syscall(SC_pipe, pipefd, flags);
  621. if (rc < 0)
  622. return rc;
  623. mmu().copy_to_vm(vm_pipefd, pipefd, sizeof(pipefd));
  624. return rc;
  625. }
  626. u32 Emulator::virt$munmap(FlatPtr address, u32 size)
  627. {
  628. auto* region = mmu().find_region({ 0x20, address });
  629. ASSERT(region);
  630. if (region->size() != round_up_to_power_of_two(size, PAGE_SIZE))
  631. TODO();
  632. mmu().remove_region(*region);
  633. return 0;
  634. }
  635. FlatPtr Emulator::allocate_vm(size_t size, size_t alignment)
  636. {
  637. // FIXME: Write a proper VM allocator
  638. static FlatPtr next_address = 0x30000000;
  639. FlatPtr final_address;
  640. if (alignment) {
  641. // FIXME: What if alignment is not a power of 2?
  642. final_address = round_up_to_power_of_two(next_address, alignment);
  643. } else {
  644. final_address = next_address;
  645. }
  646. next_address = final_address + size;
  647. return final_address;
  648. }
  649. u32 Emulator::virt$mmap(u32 params_addr)
  650. {
  651. Syscall::SC_mmap_params params;
  652. mmu().copy_from_vm(&params, params_addr, sizeof(params));
  653. ASSERT(params.addr == 0);
  654. u32 final_size = round_up_to_power_of_two(params.size, PAGE_SIZE);
  655. u32 final_address = allocate_vm(final_size, params.alignment);
  656. if (params.flags & MAP_ANONYMOUS)
  657. mmu().add_region(MmapRegion::create_anonymous(final_address, final_size, params.prot));
  658. else
  659. mmu().add_region(MmapRegion::create_file_backed(final_address, final_size, params.prot, params.flags, params.fd, params.offset));
  660. return final_address;
  661. }
  662. u32 Emulator::virt$gettid()
  663. {
  664. return gettid();
  665. }
  666. u32 Emulator::virt$getpid()
  667. {
  668. return getpid();
  669. }
  670. u32 Emulator::virt$pledge(u32)
  671. {
  672. return 0;
  673. }
  674. u32 Emulator::virt$unveil(u32)
  675. {
  676. return 0;
  677. }
  678. u32 Emulator::virt$mprotect(FlatPtr, size_t, int)
  679. {
  680. return 0;
  681. }
  682. u32 Emulator::virt$madvise(FlatPtr, size_t, int)
  683. {
  684. return 0;
  685. }
  686. uid_t Emulator::virt$getuid()
  687. {
  688. return getuid();
  689. }
  690. gid_t Emulator::virt$getgid()
  691. {
  692. return getgid();
  693. }
  694. int Emulator::virt$setuid(uid_t uid)
  695. {
  696. return syscall(SC_setuid, uid);
  697. }
  698. int Emulator::virt$setgid(gid_t gid)
  699. {
  700. return syscall(SC_setgid, gid);
  701. }
  702. u32 Emulator::virt$write(int fd, FlatPtr data, ssize_t size)
  703. {
  704. if (size < 0)
  705. return -EINVAL;
  706. auto buffer = mmu().copy_buffer_from_vm(data, size);
  707. return syscall(SC_write, fd, buffer.data(), buffer.size());
  708. }
  709. u32 Emulator::virt$read(int fd, FlatPtr buffer, ssize_t size)
  710. {
  711. if (size < 0)
  712. return -EINVAL;
  713. auto local_buffer = ByteBuffer::create_uninitialized(size);
  714. int nread = syscall(SC_read, fd, local_buffer.data(), local_buffer.size());
  715. if (nread < 0) {
  716. if (nread == -EPERM) {
  717. dump_backtrace();
  718. TODO();
  719. }
  720. return nread;
  721. }
  722. mmu().copy_to_vm(buffer, local_buffer.data(), local_buffer.size());
  723. return nread;
  724. }
  725. void Emulator::virt$exit(int status)
  726. {
  727. report("\n==%d== \033[33;1mSyscall: exit(%d)\033[0m, shutting down!\n", getpid(), status);
  728. m_exit_status = status;
  729. m_shutdown = true;
  730. }
  731. ssize_t Emulator::virt$getrandom(FlatPtr buffer, size_t buffer_size, unsigned int flags)
  732. {
  733. auto host_buffer = ByteBuffer::create_uninitialized(buffer_size);
  734. int rc = syscall(SC_getrandom, host_buffer.data(), host_buffer.size(), flags);
  735. if (rc < 0)
  736. return rc;
  737. mmu().copy_to_vm(buffer, host_buffer.data(), host_buffer.size());
  738. return rc;
  739. }
  740. int Emulator::virt$get_dir_entries(int fd, FlatPtr buffer, ssize_t size)
  741. {
  742. auto host_buffer = ByteBuffer::create_uninitialized(size);
  743. int rc = syscall(SC_get_dir_entries, fd, host_buffer.data(), host_buffer.size());
  744. if (rc < 0)
  745. return rc;
  746. mmu().copy_to_vm(buffer, host_buffer.data(), host_buffer.size());
  747. return rc;
  748. }
  749. int Emulator::virt$ioctl(int fd, unsigned request, FlatPtr arg)
  750. {
  751. (void)fd;
  752. (void)arg;
  753. if (request == TIOCGWINSZ) {
  754. struct winsize ws;
  755. int rc = syscall(SC_ioctl, fd, TIOCGWINSZ, &ws);
  756. if (rc < 0)
  757. return rc;
  758. mmu().copy_to_vm(arg, &ws, sizeof(winsize));
  759. return 0;
  760. }
  761. dbg() << "Unsupported ioctl: " << request;
  762. dump_backtrace();
  763. TODO();
  764. }
  765. int Emulator::virt$fork()
  766. {
  767. return fork();
  768. }
  769. int Emulator::virt$execve(FlatPtr params_addr)
  770. {
  771. Syscall::SC_execve_params params;
  772. mmu().copy_from_vm(&params, params_addr, sizeof(params));
  773. auto path = String::copy(mmu().copy_buffer_from_vm((FlatPtr)params.path.characters, params.path.length));
  774. Vector<String> arguments;
  775. Vector<String> environment;
  776. auto copy_string_list = [this](auto& output_vector, auto& string_list) {
  777. for (size_t i = 0; i < string_list.length; ++i) {
  778. Syscall::StringArgument string;
  779. mmu().copy_from_vm(&string, (FlatPtr)&string_list.strings[i], sizeof(string));
  780. output_vector.append(String::copy(mmu().copy_buffer_from_vm((FlatPtr)string.characters, string.length)));
  781. }
  782. };
  783. copy_string_list(arguments, params.arguments);
  784. copy_string_list(environment, params.environment);
  785. report("\n");
  786. report("==%d== \033[33;1mSyscall:\033[0m execve\n", getpid());
  787. for (auto& argument : arguments)
  788. report("==%d== - %s\n", getpid(), argument.characters());
  789. Vector<char*> argv;
  790. Vector<char*> envp;
  791. argv.append(const_cast<char*>("/bin/UserspaceEmulator"));
  792. auto create_string_vector = [](auto& output_vector, auto& input_vector) {
  793. for (auto& string : input_vector)
  794. output_vector.append(const_cast<char*>(string.characters()));
  795. output_vector.append(nullptr);
  796. };
  797. create_string_vector(argv, arguments);
  798. create_string_vector(envp, environment);
  799. return execve(argv[0], (char* const*)argv.data(), (char* const*)envp.data());
  800. }
  801. int Emulator::virt$stat(FlatPtr params_addr)
  802. {
  803. Syscall::SC_stat_params params;
  804. mmu().copy_from_vm(&params, params_addr, sizeof(params));
  805. auto path = String::copy(mmu().copy_buffer_from_vm((FlatPtr)params.path.characters, params.path.length));
  806. struct stat host_statbuf;
  807. int rc;
  808. if (params.follow_symlinks)
  809. rc = stat(path.characters(), &host_statbuf);
  810. else
  811. rc = lstat(path.characters(), &host_statbuf);
  812. if (rc < 0)
  813. return -errno;
  814. mmu().copy_to_vm((FlatPtr)params.statbuf, &host_statbuf, sizeof(host_statbuf));
  815. return rc;
  816. }
  817. int Emulator::virt$realpath(FlatPtr params_addr)
  818. {
  819. Syscall::SC_realpath_params params;
  820. mmu().copy_from_vm(&params, params_addr, sizeof(params));
  821. auto path = String::copy(mmu().copy_buffer_from_vm((FlatPtr)params.path.characters, params.path.length));
  822. char host_buffer[PATH_MAX] = {};
  823. Syscall::SC_realpath_params host_params;
  824. host_params.path = { path.characters(), path.length() };
  825. host_params.buffer = { host_buffer, sizeof(host_buffer) };
  826. int rc = syscall(SC_realpath, &host_params);
  827. if (rc < 0)
  828. return rc;
  829. mmu().copy_to_vm((FlatPtr)params.buffer.data, host_buffer, min(params.buffer.size, sizeof(host_buffer)));
  830. return rc;
  831. }
  832. int Emulator::virt$gethostname(FlatPtr buffer, ssize_t buffer_size)
  833. {
  834. if (buffer_size < 0)
  835. return -EINVAL;
  836. auto host_buffer = ByteBuffer::create_zeroed(buffer_size);
  837. int rc = syscall(SC_gethostname, host_buffer.data(), host_buffer.size());
  838. if (rc < 0)
  839. return rc;
  840. mmu().copy_to_vm(buffer, host_buffer.data(), host_buffer.size());
  841. return rc;
  842. }
  843. void report(const char* format, ...)
  844. {
  845. va_list ap;
  846. va_start(ap, format);
  847. vfprintf(stderr, format, ap);
  848. va_end(ap);
  849. }
  850. }