VirtualFileSystem.cpp 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041
  1. /*
  2. * Copyright (c) 2018-2020, Andreas Kling <kling@serenityos.org>
  3. *
  4. * SPDX-License-Identifier: BSD-2-Clause
  5. */
  6. #include <AK/LexicalPath.h>
  7. #include <AK/Singleton.h>
  8. #include <AK/StringBuilder.h>
  9. #include <Kernel/Debug.h>
  10. #include <Kernel/Devices/BlockDevice.h>
  11. #include <Kernel/FileSystem/Custody.h>
  12. #include <Kernel/FileSystem/FileBackedFileSystem.h>
  13. #include <Kernel/FileSystem/FileDescription.h>
  14. #include <Kernel/FileSystem/FileSystem.h>
  15. #include <Kernel/FileSystem/VirtualFileSystem.h>
  16. #include <Kernel/KSyms.h>
  17. #include <Kernel/Process.h>
  18. #include <Kernel/Sections.h>
  19. #include <LibC/errno_numbers.h>
  20. namespace Kernel {
  21. static AK::Singleton<VFS> s_the;
  22. static constexpr int symlink_recursion_limit { 5 }; // FIXME: increase?
  23. static constexpr int root_mount_flags = MS_NODEV | MS_NOSUID | MS_RDONLY;
  24. UNMAP_AFTER_INIT void VFS::initialize()
  25. {
  26. s_the.ensure_instance();
  27. }
  28. VFS& VFS::the()
  29. {
  30. return *s_the;
  31. }
  32. UNMAP_AFTER_INIT VFS::VFS()
  33. {
  34. }
  35. UNMAP_AFTER_INIT VFS::~VFS()
  36. {
  37. }
  38. InodeIdentifier VFS::root_inode_id() const
  39. {
  40. VERIFY(m_root_inode);
  41. return m_root_inode->identifier();
  42. }
  43. KResult VFS::mount(FS& file_system, Custody& mount_point, int flags)
  44. {
  45. Locker locker(m_lock);
  46. auto& inode = mount_point.inode();
  47. dbgln("VFS: Mounting {} at {} (inode: {}) with flags {}",
  48. file_system.class_name(),
  49. mount_point.absolute_path(),
  50. inode.identifier(),
  51. flags);
  52. // FIXME: check that this is not already a mount point
  53. Mount mount { file_system, &mount_point, flags };
  54. m_mounts.append(move(mount));
  55. return KSuccess;
  56. }
  57. KResult VFS::bind_mount(Custody& source, Custody& mount_point, int flags)
  58. {
  59. Locker locker(m_lock);
  60. dbgln("VFS: Bind-mounting {} at {}", source.absolute_path(), mount_point.absolute_path());
  61. // FIXME: check that this is not already a mount point
  62. Mount mount { source.inode(), mount_point, flags };
  63. m_mounts.append(move(mount));
  64. return KSuccess;
  65. }
  66. KResult VFS::remount(Custody& mount_point, int new_flags)
  67. {
  68. Locker locker(m_lock);
  69. dbgln("VFS: Remounting {}", mount_point.absolute_path());
  70. Mount* mount = find_mount_for_guest(mount_point.inode());
  71. if (!mount)
  72. return ENODEV;
  73. mount->set_flags(new_flags);
  74. return KSuccess;
  75. }
  76. KResult VFS::unmount(Inode& guest_inode)
  77. {
  78. Locker locker(m_lock);
  79. dbgln("VFS: unmount called with inode {}", guest_inode.identifier());
  80. for (size_t i = 0; i < m_mounts.size(); ++i) {
  81. auto& mount = m_mounts.at(i);
  82. if (&mount.guest() == &guest_inode) {
  83. if (auto result = mount.guest_fs().prepare_to_unmount(); result.is_error()) {
  84. dbgln("VFS: Failed to unmount!");
  85. return result;
  86. }
  87. dbgln("VFS: found fs {} at mount index {}! Unmounting...", mount.guest_fs().fsid(), i);
  88. m_mounts.unstable_take(i);
  89. return KSuccess;
  90. }
  91. }
  92. dbgln("VFS: Nothing mounted on inode {}", guest_inode.identifier());
  93. return ENODEV;
  94. }
  95. bool VFS::mount_root(FS& file_system)
  96. {
  97. if (m_root_inode) {
  98. dmesgln("VFS: mount_root can't mount another root");
  99. return false;
  100. }
  101. Mount mount { file_system, nullptr, root_mount_flags };
  102. auto root_inode = file_system.root_inode();
  103. if (!root_inode->is_directory()) {
  104. dmesgln("VFS: root inode ({}) for / is not a directory :(", root_inode->identifier());
  105. return false;
  106. }
  107. m_root_inode = move(root_inode);
  108. dmesgln("VFS: mounted root from {} ({})", file_system.class_name(), static_cast<FileBackedFS&>(file_system).file_description().absolute_path());
  109. m_mounts.append(move(mount));
  110. auto custody_or_error = Custody::try_create(nullptr, "", *m_root_inode, root_mount_flags);
  111. if (custody_or_error.is_error())
  112. return false;
  113. m_root_custody = custody_or_error.release_value();
  114. return true;
  115. }
  116. auto VFS::find_mount_for_host(Inode& inode) -> Mount*
  117. {
  118. for (auto& mount : m_mounts) {
  119. if (mount.host() == &inode)
  120. return &mount;
  121. }
  122. return nullptr;
  123. }
  124. auto VFS::find_mount_for_host(InodeIdentifier id) -> Mount*
  125. {
  126. for (auto& mount : m_mounts) {
  127. if (mount.host() && mount.host()->identifier() == id)
  128. return &mount;
  129. }
  130. return nullptr;
  131. }
  132. auto VFS::find_mount_for_guest(Inode& inode) -> Mount*
  133. {
  134. for (auto& mount : m_mounts) {
  135. if (&mount.guest() == &inode)
  136. return &mount;
  137. }
  138. return nullptr;
  139. }
  140. auto VFS::find_mount_for_guest(InodeIdentifier id) -> Mount*
  141. {
  142. for (auto& mount : m_mounts) {
  143. if (mount.guest().identifier() == id)
  144. return &mount;
  145. }
  146. return nullptr;
  147. }
  148. bool VFS::is_vfs_root(InodeIdentifier inode) const
  149. {
  150. return inode == root_inode_id();
  151. }
  152. KResult VFS::traverse_directory_inode(Inode& dir_inode, Function<bool(const FS::DirectoryEntryView&)> callback)
  153. {
  154. return dir_inode.traverse_as_directory([&](auto& entry) {
  155. InodeIdentifier resolved_inode;
  156. if (auto mount = find_mount_for_host(entry.inode))
  157. resolved_inode = mount->guest().identifier();
  158. else
  159. resolved_inode = entry.inode;
  160. // FIXME: This is now broken considering chroot and bind mounts.
  161. bool is_root_inode = dir_inode.identifier() == dir_inode.fs().root_inode()->identifier();
  162. if (is_root_inode && !is_vfs_root(dir_inode.identifier()) && entry.name == "..") {
  163. auto mount = find_mount_for_guest(dir_inode);
  164. VERIFY(mount);
  165. VERIFY(mount->host());
  166. resolved_inode = mount->host()->identifier();
  167. }
  168. callback({ entry.name, resolved_inode, entry.file_type });
  169. return true;
  170. });
  171. }
  172. KResult VFS::utime(StringView path, Custody& base, time_t atime, time_t mtime)
  173. {
  174. auto custody_or_error = VFS::the().resolve_path(move(path), base);
  175. if (custody_or_error.is_error())
  176. return custody_or_error.error();
  177. auto& custody = *custody_or_error.value();
  178. auto& inode = custody.inode();
  179. auto current_process = Process::current();
  180. if (!current_process->is_superuser() && inode.metadata().uid != current_process->euid())
  181. return EACCES;
  182. if (custody.is_readonly())
  183. return EROFS;
  184. if (auto result = inode.set_atime(atime); result.is_error())
  185. return result;
  186. if (auto result = inode.set_mtime(mtime); result.is_error())
  187. return result;
  188. return KSuccess;
  189. }
  190. KResultOr<InodeMetadata> VFS::lookup_metadata(StringView path, Custody& base, int options)
  191. {
  192. auto custody_or_error = resolve_path(path, base, nullptr, options);
  193. if (custody_or_error.is_error())
  194. return custody_or_error.error();
  195. return custody_or_error.value()->inode().metadata();
  196. }
  197. KResultOr<NonnullRefPtr<FileDescription>> VFS::open(StringView path, int options, mode_t mode, Custody& base, Optional<UidAndGid> owner)
  198. {
  199. if ((options & O_CREAT) && (options & O_DIRECTORY))
  200. return EINVAL;
  201. RefPtr<Custody> parent_custody;
  202. auto custody_or_error = resolve_path(path, base, &parent_custody, options);
  203. if (custody_or_error.is_error()) {
  204. // NOTE: ENOENT with a non-null parent custody signals us that the immediate parent
  205. // of the file exists, but the file itself does not.
  206. if ((options & O_CREAT) && custody_or_error.error() == -ENOENT && parent_custody)
  207. return create(path, options, mode, *parent_custody, move(owner));
  208. return custody_or_error.error();
  209. }
  210. if ((options & O_CREAT) && (options & O_EXCL))
  211. return EEXIST;
  212. auto& custody = *custody_or_error.value();
  213. auto& inode = custody.inode();
  214. auto metadata = inode.metadata();
  215. if ((options & O_DIRECTORY) && !metadata.is_directory())
  216. return ENOTDIR;
  217. bool should_truncate_file = false;
  218. auto current_process = Process::current();
  219. if ((options & O_RDONLY) && !metadata.may_read(*current_process))
  220. return EACCES;
  221. if (options & O_WRONLY) {
  222. if (!metadata.may_write(*current_process))
  223. return EACCES;
  224. if (metadata.is_directory())
  225. return EISDIR;
  226. should_truncate_file = options & O_TRUNC;
  227. }
  228. if (options & O_EXEC) {
  229. if (!metadata.may_execute(*current_process) || (custody.mount_flags() & MS_NOEXEC))
  230. return EACCES;
  231. }
  232. if (auto preopen_fd = inode.preopen_fd())
  233. return *preopen_fd;
  234. if (metadata.is_fifo()) {
  235. auto fifo = inode.fifo();
  236. if (options & O_WRONLY) {
  237. auto open_result = fifo->open_direction_blocking(FIFO::Direction::Writer);
  238. if (open_result.is_error())
  239. return open_result.error();
  240. auto& description = open_result.value();
  241. description->set_rw_mode(options);
  242. description->set_file_flags(options);
  243. description->set_original_inode({}, inode);
  244. return description;
  245. } else if (options & O_RDONLY) {
  246. auto open_result = fifo->open_direction_blocking(FIFO::Direction::Reader);
  247. if (open_result.is_error())
  248. return open_result.error();
  249. auto& description = open_result.value();
  250. description->set_rw_mode(options);
  251. description->set_file_flags(options);
  252. description->set_original_inode({}, inode);
  253. return description;
  254. }
  255. return EINVAL;
  256. }
  257. if (metadata.is_device()) {
  258. if (custody.mount_flags() & MS_NODEV)
  259. return EACCES;
  260. auto device = Device::get_device(metadata.major_device, metadata.minor_device);
  261. if (device == nullptr) {
  262. return ENODEV;
  263. }
  264. auto descriptor_or_error = device->open(options);
  265. if (descriptor_or_error.is_error())
  266. return descriptor_or_error.error();
  267. descriptor_or_error.value()->set_original_inode({}, inode);
  268. return descriptor_or_error;
  269. }
  270. // Check for read-only FS. Do this after handling preopen FD and devices,
  271. // but before modifying the inode in any way.
  272. if ((options & O_WRONLY) && custody.is_readonly())
  273. return EROFS;
  274. if (should_truncate_file) {
  275. if (auto result = inode.truncate(0); result.is_error())
  276. return result;
  277. if (auto result = inode.set_mtime(kgettimeofday().to_truncated_seconds()); result.is_error())
  278. return result;
  279. }
  280. auto description = FileDescription::create(custody);
  281. if (!description.is_error()) {
  282. description.value()->set_rw_mode(options);
  283. description.value()->set_file_flags(options);
  284. }
  285. return description;
  286. }
  287. KResult VFS::mknod(StringView path, mode_t mode, dev_t dev, Custody& base)
  288. {
  289. if (!is_regular_file(mode) && !is_block_device(mode) && !is_character_device(mode) && !is_fifo(mode) && !is_socket(mode))
  290. return EINVAL;
  291. RefPtr<Custody> parent_custody;
  292. auto existing_file_or_error = resolve_path(path, base, &parent_custody);
  293. if (!existing_file_or_error.is_error())
  294. return EEXIST;
  295. if (!parent_custody)
  296. return ENOENT;
  297. if (existing_file_or_error.error() != -ENOENT)
  298. return existing_file_or_error.error();
  299. auto& parent_inode = parent_custody->inode();
  300. auto current_process = Process::current();
  301. if (!parent_inode.metadata().may_write(*current_process))
  302. return EACCES;
  303. if (parent_custody->is_readonly())
  304. return EROFS;
  305. auto basename = LexicalPath::basename(path);
  306. dbgln("VFS::mknod: '{}' mode={} dev={} in {}", basename, mode, dev, parent_inode.identifier());
  307. return parent_inode.create_child(basename, mode, dev, current_process->euid(), current_process->egid()).result();
  308. }
  309. KResultOr<NonnullRefPtr<FileDescription>> VFS::create(StringView path, int options, mode_t mode, Custody& parent_custody, Optional<UidAndGid> owner)
  310. {
  311. auto basename = LexicalPath::basename(path);
  312. if (auto result = validate_path_against_process_veil(String::formatted("{}/{}", parent_custody.absolute_path(), basename), options); result.is_error())
  313. return result;
  314. if (!is_socket(mode) && !is_fifo(mode) && !is_block_device(mode) && !is_character_device(mode)) {
  315. // Turn it into a regular file. (This feels rather hackish.)
  316. mode |= 0100000;
  317. }
  318. auto& parent_inode = parent_custody.inode();
  319. auto current_process = Process::current();
  320. if (!parent_inode.metadata().may_write(*current_process))
  321. return EACCES;
  322. if (parent_custody.is_readonly())
  323. return EROFS;
  324. dbgln_if(VFS_DEBUG, "VFS::create: '{}' in {}", basename, parent_inode.identifier());
  325. uid_t uid = owner.has_value() ? owner.value().uid : current_process->euid();
  326. gid_t gid = owner.has_value() ? owner.value().gid : current_process->egid();
  327. auto inode_or_error = parent_inode.create_child(basename, mode, 0, uid, gid);
  328. if (inode_or_error.is_error())
  329. return inode_or_error.error();
  330. auto new_custody_or_error = Custody::try_create(&parent_custody, basename, inode_or_error.value(), parent_custody.mount_flags());
  331. if (new_custody_or_error.is_error())
  332. return new_custody_or_error.error();
  333. auto description = FileDescription::create(*new_custody_or_error.release_value());
  334. if (!description.is_error()) {
  335. description.value()->set_rw_mode(options);
  336. description.value()->set_file_flags(options);
  337. }
  338. return description;
  339. }
  340. KResult VFS::mkdir(StringView path, mode_t mode, Custody& base)
  341. {
  342. // Unlike in basically every other case, where it's only the last
  343. // path component (the one being created) that is allowed not to
  344. // exist, POSIX allows mkdir'ed path to have trailing slashes.
  345. // Let's handle that case by trimming any trailing slashes.
  346. while (path.length() > 1 && path.ends_with("/"))
  347. path = path.substring_view(0, path.length() - 1);
  348. RefPtr<Custody> parent_custody;
  349. if (auto result = resolve_path(path, base, &parent_custody); !result.is_error())
  350. return EEXIST;
  351. else if (!parent_custody)
  352. return ENOENT;
  353. else if (result.error() != -ENOENT)
  354. return result.error();
  355. auto& parent_inode = parent_custody->inode();
  356. auto current_process = Process::current();
  357. if (!parent_inode.metadata().may_write(*current_process))
  358. return EACCES;
  359. if (parent_custody->is_readonly())
  360. return EROFS;
  361. auto basename = LexicalPath::basename(path);
  362. dbgln_if(VFS_DEBUG, "VFS::mkdir: '{}' in {}", basename, parent_inode.identifier());
  363. return parent_inode.create_child(basename, S_IFDIR | mode, 0, current_process->euid(), current_process->egid()).result();
  364. }
  365. KResult VFS::access(StringView path, int mode, Custody& base)
  366. {
  367. auto custody_or_error = resolve_path(path, base);
  368. if (custody_or_error.is_error())
  369. return custody_or_error.error();
  370. auto& custody = *custody_or_error.value();
  371. auto& inode = custody.inode();
  372. auto metadata = inode.metadata();
  373. auto current_process = Process::current();
  374. if (mode & R_OK) {
  375. if (!metadata.may_read(*current_process))
  376. return EACCES;
  377. }
  378. if (mode & W_OK) {
  379. if (!metadata.may_write(*current_process))
  380. return EACCES;
  381. if (custody.is_readonly())
  382. return EROFS;
  383. }
  384. if (mode & X_OK) {
  385. if (!metadata.may_execute(*current_process))
  386. return EACCES;
  387. }
  388. return KSuccess;
  389. }
  390. KResultOr<NonnullRefPtr<Custody>> VFS::open_directory(StringView path, Custody& base)
  391. {
  392. auto inode_or_error = resolve_path(path, base);
  393. if (inode_or_error.is_error())
  394. return inode_or_error.error();
  395. auto& custody = *inode_or_error.value();
  396. auto& inode = custody.inode();
  397. if (!inode.is_directory())
  398. return ENOTDIR;
  399. if (!inode.metadata().may_execute(*Process::current()))
  400. return EACCES;
  401. return custody;
  402. }
  403. KResult VFS::chmod(Custody& custody, mode_t mode)
  404. {
  405. auto& inode = custody.inode();
  406. auto current_process = Process::current();
  407. if (current_process->euid() != inode.metadata().uid && !current_process->is_superuser())
  408. return EPERM;
  409. if (custody.is_readonly())
  410. return EROFS;
  411. // Only change the permission bits.
  412. mode = (inode.mode() & ~07777u) | (mode & 07777u);
  413. return inode.chmod(mode);
  414. }
  415. KResult VFS::chmod(StringView path, mode_t mode, Custody& base)
  416. {
  417. auto custody_or_error = resolve_path(path, base);
  418. if (custody_or_error.is_error())
  419. return custody_or_error.error();
  420. auto& custody = *custody_or_error.value();
  421. return chmod(custody, mode);
  422. }
  423. KResult VFS::rename(StringView old_path, StringView new_path, Custody& base)
  424. {
  425. RefPtr<Custody> old_parent_custody;
  426. auto old_custody_or_error = resolve_path(old_path, base, &old_parent_custody, O_NOFOLLOW_NOERROR);
  427. if (old_custody_or_error.is_error())
  428. return old_custody_or_error.error();
  429. auto& old_custody = *old_custody_or_error.value();
  430. auto& old_inode = old_custody.inode();
  431. RefPtr<Custody> new_parent_custody;
  432. auto new_custody_or_error = resolve_path(new_path, base, &new_parent_custody);
  433. if (new_custody_or_error.is_error()) {
  434. if (new_custody_or_error.error() != -ENOENT || !new_parent_custody)
  435. return new_custody_or_error.error();
  436. }
  437. if (!old_parent_custody || !new_parent_custody) {
  438. return EPERM;
  439. }
  440. auto& old_parent_inode = old_parent_custody->inode();
  441. auto& new_parent_inode = new_parent_custody->inode();
  442. if (&old_parent_inode.fs() != &new_parent_inode.fs())
  443. return EXDEV;
  444. for (auto* new_ancestor = new_parent_custody.ptr(); new_ancestor; new_ancestor = new_ancestor->parent()) {
  445. if (&old_inode == &new_ancestor->inode())
  446. return EDIRINTOSELF;
  447. }
  448. auto current_process = Process::current();
  449. if (!new_parent_inode.metadata().may_write(*current_process))
  450. return EACCES;
  451. if (!old_parent_inode.metadata().may_write(*current_process))
  452. return EACCES;
  453. if (old_parent_inode.metadata().is_sticky()) {
  454. if (!current_process->is_superuser() && old_inode.metadata().uid != current_process->euid())
  455. return EACCES;
  456. }
  457. if (old_parent_custody->is_readonly() || new_parent_custody->is_readonly())
  458. return EROFS;
  459. auto new_basename = LexicalPath::basename(new_path);
  460. if (!new_custody_or_error.is_error()) {
  461. auto& new_custody = *new_custody_or_error.value();
  462. auto& new_inode = new_custody.inode();
  463. // FIXME: Is this really correct? Check what other systems do.
  464. if (&new_inode == &old_inode)
  465. return KSuccess;
  466. if (new_parent_inode.metadata().is_sticky()) {
  467. if (!current_process->is_superuser() && new_inode.metadata().uid != current_process->euid())
  468. return EACCES;
  469. }
  470. if (new_inode.is_directory() && !old_inode.is_directory())
  471. return EISDIR;
  472. if (auto result = new_parent_inode.remove_child(new_basename); result.is_error())
  473. return result;
  474. }
  475. if (auto result = new_parent_inode.add_child(old_inode, new_basename, old_inode.mode()); result.is_error())
  476. return result;
  477. if (auto result = old_parent_inode.remove_child(LexicalPath::basename(old_path)); result.is_error())
  478. return result;
  479. return KSuccess;
  480. }
  481. KResult VFS::chown(Custody& custody, uid_t a_uid, gid_t a_gid)
  482. {
  483. auto& inode = custody.inode();
  484. auto metadata = inode.metadata();
  485. auto current_process = Process::current();
  486. if (current_process->euid() != metadata.uid && !current_process->is_superuser())
  487. return EPERM;
  488. uid_t new_uid = metadata.uid;
  489. gid_t new_gid = metadata.gid;
  490. if (a_uid != (uid_t)-1) {
  491. if (current_process->euid() != a_uid && !current_process->is_superuser())
  492. return EPERM;
  493. new_uid = a_uid;
  494. }
  495. if (a_gid != (gid_t)-1) {
  496. if (!current_process->in_group(a_gid) && !current_process->is_superuser())
  497. return EPERM;
  498. new_gid = a_gid;
  499. }
  500. if (custody.is_readonly())
  501. return EROFS;
  502. dbgln_if(VFS_DEBUG, "VFS::chown(): inode {} <- uid={} gid={}", inode.identifier(), new_uid, new_gid);
  503. if (metadata.is_setuid() || metadata.is_setgid()) {
  504. dbgln_if(VFS_DEBUG, "VFS::chown(): Stripping SUID/SGID bits from {}", inode.identifier());
  505. if (auto result = inode.chmod(metadata.mode & ~(04000 | 02000)); result.is_error())
  506. return result;
  507. }
  508. return inode.chown(new_uid, new_gid);
  509. }
  510. KResult VFS::chown(StringView path, uid_t a_uid, gid_t a_gid, Custody& base)
  511. {
  512. auto custody_or_error = resolve_path(path, base);
  513. if (custody_or_error.is_error())
  514. return custody_or_error.error();
  515. auto& custody = *custody_or_error.value();
  516. return chown(custody, a_uid, a_gid);
  517. }
  518. static bool hard_link_allowed(const Inode& inode)
  519. {
  520. auto metadata = inode.metadata();
  521. if (Process::current()->euid() == metadata.uid)
  522. return true;
  523. if (metadata.is_regular_file()
  524. && !metadata.is_setuid()
  525. && !(metadata.is_setgid() && metadata.mode & S_IXGRP)
  526. && metadata.may_write(*Process::current())) {
  527. return true;
  528. }
  529. return false;
  530. }
  531. KResult VFS::link(StringView old_path, StringView new_path, Custody& base)
  532. {
  533. auto old_custody_or_error = resolve_path(old_path, base);
  534. if (old_custody_or_error.is_error())
  535. return old_custody_or_error.error();
  536. auto& old_custody = *old_custody_or_error.value();
  537. auto& old_inode = old_custody.inode();
  538. RefPtr<Custody> parent_custody;
  539. auto new_custody_or_error = resolve_path(new_path, base, &parent_custody);
  540. if (!new_custody_or_error.is_error())
  541. return EEXIST;
  542. if (!parent_custody)
  543. return ENOENT;
  544. auto& parent_inode = parent_custody->inode();
  545. if (parent_inode.fsid() != old_inode.fsid())
  546. return EXDEV;
  547. if (!parent_inode.metadata().may_write(*Process::current()))
  548. return EACCES;
  549. if (old_inode.is_directory())
  550. return EPERM;
  551. if (parent_custody->is_readonly())
  552. return EROFS;
  553. if (!hard_link_allowed(old_inode))
  554. return EPERM;
  555. return parent_inode.add_child(old_inode, LexicalPath::basename(new_path), old_inode.mode());
  556. }
  557. KResult VFS::unlink(StringView path, Custody& base)
  558. {
  559. RefPtr<Custody> parent_custody;
  560. auto custody_or_error = resolve_path(path, base, &parent_custody, O_NOFOLLOW_NOERROR | O_UNLINK_INTERNAL);
  561. if (custody_or_error.is_error())
  562. return custody_or_error.error();
  563. auto& custody = *custody_or_error.value();
  564. auto& inode = custody.inode();
  565. if (inode.is_directory())
  566. return EISDIR;
  567. // We have just checked that the inode is not a directory, and thus it's not
  568. // the root. So it should have a parent. Note that this would be invalidated
  569. // if we were to support bind-mounting regular files on top of the root.
  570. VERIFY(parent_custody);
  571. auto& parent_inode = parent_custody->inode();
  572. auto current_process = Process::current();
  573. if (!parent_inode.metadata().may_write(*current_process))
  574. return EACCES;
  575. if (parent_inode.metadata().is_sticky()) {
  576. if (!current_process->is_superuser() && inode.metadata().uid != current_process->euid())
  577. return EACCES;
  578. }
  579. if (parent_custody->is_readonly())
  580. return EROFS;
  581. if (auto result = parent_inode.remove_child(LexicalPath::basename(path)); result.is_error())
  582. return result;
  583. return KSuccess;
  584. }
  585. KResult VFS::symlink(StringView target, StringView linkpath, Custody& base)
  586. {
  587. RefPtr<Custody> parent_custody;
  588. auto existing_custody_or_error = resolve_path(linkpath, base, &parent_custody);
  589. if (!existing_custody_or_error.is_error())
  590. return EEXIST;
  591. if (!parent_custody)
  592. return ENOENT;
  593. if (existing_custody_or_error.error() != -ENOENT)
  594. return existing_custody_or_error.error();
  595. auto& parent_inode = parent_custody->inode();
  596. auto current_process = Process::current();
  597. if (!parent_inode.metadata().may_write(*current_process))
  598. return EACCES;
  599. if (parent_custody->is_readonly())
  600. return EROFS;
  601. auto basename = LexicalPath::basename(linkpath);
  602. dbgln_if(VFS_DEBUG, "VFS::symlink: '{}' (-> '{}') in {}", linkpath, target, parent_inode.identifier());
  603. auto inode_or_error = parent_inode.create_child(linkpath, S_IFLNK | 0644, 0, current_process->euid(), current_process->egid());
  604. if (inode_or_error.is_error())
  605. return inode_or_error.error();
  606. auto& inode = inode_or_error.value();
  607. auto target_buffer = UserOrKernelBuffer::for_kernel_buffer(const_cast<u8*>((const u8*)target.characters_without_null_termination()));
  608. auto result = inode->write_bytes(0, target.length(), target_buffer, nullptr);
  609. if (result.is_error())
  610. return result.error();
  611. return KSuccess;
  612. }
  613. KResult VFS::rmdir(StringView path, Custody& base)
  614. {
  615. RefPtr<Custody> parent_custody;
  616. auto custody_or_error = resolve_path(path, base, &parent_custody);
  617. if (custody_or_error.is_error())
  618. return KResult(custody_or_error.error());
  619. auto& custody = *custody_or_error.value();
  620. auto& inode = custody.inode();
  621. // FIXME: We should return EINVAL if the last component of the path is "."
  622. // FIXME: We should return ENOTEMPTY if the last component of the path is ".."
  623. if (!inode.is_directory())
  624. return ENOTDIR;
  625. if (!parent_custody)
  626. return EBUSY;
  627. auto& parent_inode = parent_custody->inode();
  628. auto parent_metadata = parent_inode.metadata();
  629. if (!parent_metadata.may_write(*Process::current()))
  630. return EACCES;
  631. if (parent_metadata.is_sticky()) {
  632. if (!Process::current()->is_superuser() && inode.metadata().uid != Process::current()->euid())
  633. return EACCES;
  634. }
  635. KResultOr<size_t> dir_count_result = inode.directory_entry_count();
  636. if (dir_count_result.is_error())
  637. return dir_count_result.result();
  638. if (dir_count_result.value() != 2)
  639. return ENOTEMPTY;
  640. if (custody.is_readonly())
  641. return EROFS;
  642. if (auto result = inode.remove_child("."); result.is_error())
  643. return result;
  644. if (auto result = inode.remove_child(".."); result.is_error())
  645. return result;
  646. return parent_inode.remove_child(LexicalPath::basename(path));
  647. }
  648. VFS::Mount::Mount(FS& guest_fs, Custody* host_custody, int flags)
  649. : m_guest(guest_fs.root_inode())
  650. , m_guest_fs(guest_fs)
  651. , m_host_custody(host_custody)
  652. , m_flags(flags)
  653. {
  654. }
  655. VFS::Mount::Mount(Inode& source, Custody& host_custody, int flags)
  656. : m_guest(source)
  657. , m_guest_fs(source.fs())
  658. , m_host_custody(host_custody)
  659. , m_flags(flags)
  660. {
  661. }
  662. String VFS::Mount::absolute_path() const
  663. {
  664. if (!m_host_custody)
  665. return "/";
  666. return m_host_custody->absolute_path();
  667. }
  668. Inode* VFS::Mount::host()
  669. {
  670. if (!m_host_custody)
  671. return nullptr;
  672. return &m_host_custody->inode();
  673. }
  674. const Inode* VFS::Mount::host() const
  675. {
  676. if (!m_host_custody)
  677. return nullptr;
  678. return &m_host_custody->inode();
  679. }
  680. void VFS::for_each_mount(Function<void(const Mount&)> callback) const
  681. {
  682. for (auto& mount : m_mounts) {
  683. callback(mount);
  684. }
  685. }
  686. void VFS::sync()
  687. {
  688. FS::sync();
  689. }
  690. Custody& VFS::root_custody()
  691. {
  692. return *m_root_custody;
  693. }
  694. UnveilNode const& VFS::find_matching_unveiled_path(StringView path)
  695. {
  696. VERIFY(Process::current()->veil_state() != VeilState::None);
  697. auto& unveil_root = Process::current()->unveiled_paths();
  698. LexicalPath lexical_path { path };
  699. auto& path_parts = lexical_path.parts_view();
  700. return unveil_root.traverse_until_last_accessible_node(path_parts.begin(), path_parts.end());
  701. }
  702. KResult VFS::validate_path_against_process_veil(Custody const& custody, int options)
  703. {
  704. if (Process::current()->veil_state() == VeilState::None)
  705. return KSuccess;
  706. return validate_path_against_process_veil(custody.absolute_path(), options);
  707. }
  708. KResult VFS::validate_path_against_process_veil(StringView path, int options)
  709. {
  710. if (Process::current()->veil_state() == VeilState::None)
  711. return KSuccess;
  712. if (path == "/usr/lib/Loader.so")
  713. return KSuccess;
  714. VERIFY(path.starts_with('/'));
  715. VERIFY(!path.contains("/../"sv) && !path.ends_with("/.."sv));
  716. VERIFY(!path.contains("/./"sv) && !path.ends_with("/."sv));
  717. auto& unveiled_path = find_matching_unveiled_path(path);
  718. if (unveiled_path.permissions() == UnveilAccess::None) {
  719. dbgln("Rejecting path '{}' since it hasn't been unveiled.", path);
  720. dump_backtrace();
  721. return ENOENT;
  722. }
  723. if (options & O_CREAT) {
  724. if (!(unveiled_path.permissions() & UnveilAccess::CreateOrRemove)) {
  725. dbgln("Rejecting path '{}' since it hasn't been unveiled with 'c' permission.", path);
  726. dump_backtrace();
  727. return EACCES;
  728. }
  729. }
  730. if (options & O_UNLINK_INTERNAL) {
  731. if (!(unveiled_path.permissions() & UnveilAccess::CreateOrRemove)) {
  732. dbgln("Rejecting path '{}' for unlink since it hasn't been unveiled with 'c' permission.", path);
  733. dump_backtrace();
  734. return EACCES;
  735. }
  736. return KSuccess;
  737. }
  738. if (options & O_RDONLY) {
  739. if (options & O_DIRECTORY) {
  740. if (!(unveiled_path.permissions() & (UnveilAccess::Read | UnveilAccess::Browse))) {
  741. dbgln("Rejecting path '{}' since it hasn't been unveiled with 'r' or 'b' permissions.", path);
  742. dump_backtrace();
  743. return EACCES;
  744. }
  745. } else {
  746. if (!(unveiled_path.permissions() & UnveilAccess::Read)) {
  747. dbgln("Rejecting path '{}' since it hasn't been unveiled with 'r' permission.", path);
  748. dump_backtrace();
  749. return EACCES;
  750. }
  751. }
  752. }
  753. if (options & O_WRONLY) {
  754. if (!(unveiled_path.permissions() & UnveilAccess::Write)) {
  755. dbgln("Rejecting path '{}' since it hasn't been unveiled with 'w' permission.", path);
  756. dump_backtrace();
  757. return EACCES;
  758. }
  759. }
  760. if (options & O_EXEC) {
  761. if (!(unveiled_path.permissions() & UnveilAccess::Execute)) {
  762. dbgln("Rejecting path '{}' since it hasn't been unveiled with 'x' permission.", path);
  763. dump_backtrace();
  764. return EACCES;
  765. }
  766. }
  767. return KSuccess;
  768. }
  769. KResultOr<NonnullRefPtr<Custody>> VFS::resolve_path(StringView path, Custody& base, RefPtr<Custody>* out_parent, int options, int symlink_recursion_level)
  770. {
  771. auto custody_or_error = resolve_path_without_veil(path, base, out_parent, options, symlink_recursion_level);
  772. if (custody_or_error.is_error())
  773. return custody_or_error.error();
  774. auto& custody = custody_or_error.value();
  775. if (auto result = validate_path_against_process_veil(*custody, options); result.is_error())
  776. return result;
  777. return custody;
  778. }
  779. static bool safe_to_follow_symlink(const Inode& inode, const InodeMetadata& parent_metadata)
  780. {
  781. auto metadata = inode.metadata();
  782. if (Process::current()->euid() == metadata.uid)
  783. return true;
  784. if (!(parent_metadata.is_sticky() && parent_metadata.mode & S_IWOTH))
  785. return true;
  786. if (metadata.uid == parent_metadata.uid)
  787. return true;
  788. return false;
  789. }
  790. KResultOr<NonnullRefPtr<Custody>> VFS::resolve_path_without_veil(StringView path, Custody& base, RefPtr<Custody>* out_parent, int options, int symlink_recursion_level)
  791. {
  792. if (symlink_recursion_level >= symlink_recursion_limit)
  793. return ELOOP;
  794. if (path.is_empty())
  795. return EINVAL;
  796. GenericLexer path_lexer(path);
  797. auto current_process = Process::current();
  798. auto& current_root = current_process->root_directory();
  799. NonnullRefPtr<Custody> custody = path[0] == '/' ? current_root : base;
  800. bool extra_iteration = path[path.length() - 1] == '/';
  801. while (!path_lexer.is_eof() || extra_iteration) {
  802. if (path_lexer.is_eof())
  803. extra_iteration = false;
  804. auto part = path_lexer.consume_until('/');
  805. path_lexer.consume_specific('/');
  806. Custody& parent = custody;
  807. auto parent_metadata = parent.inode().metadata();
  808. if (!parent_metadata.is_directory())
  809. return ENOTDIR;
  810. // Ensure the current user is allowed to resolve paths inside this directory.
  811. if (!parent_metadata.may_execute(*current_process))
  812. return EACCES;
  813. bool have_more_parts = !path_lexer.is_eof() || extra_iteration;
  814. if (part == "..") {
  815. // If we encounter a "..", take a step back, but don't go beyond the root.
  816. if (custody->parent())
  817. custody = *custody->parent();
  818. continue;
  819. } else if (part == "." || part.is_empty()) {
  820. continue;
  821. }
  822. // Okay, let's look up this part.
  823. auto child_inode = parent.inode().lookup(part);
  824. if (!child_inode) {
  825. if (out_parent) {
  826. // ENOENT with a non-null parent custody signals to caller that
  827. // we found the immediate parent of the file, but the file itself
  828. // does not exist yet.
  829. *out_parent = have_more_parts ? nullptr : &parent;
  830. }
  831. return ENOENT;
  832. }
  833. int mount_flags_for_child = parent.mount_flags();
  834. // See if there's something mounted on the child; in that case
  835. // we would need to return the guest inode, not the host inode.
  836. if (auto mount = find_mount_for_host(*child_inode)) {
  837. child_inode = mount->guest();
  838. mount_flags_for_child = mount->flags();
  839. }
  840. auto new_custody_or_error = Custody::try_create(&parent, part, *child_inode, mount_flags_for_child);
  841. if (new_custody_or_error.is_error())
  842. return new_custody_or_error.error();
  843. custody = new_custody_or_error.release_value();
  844. if (child_inode->metadata().is_symlink()) {
  845. if (!have_more_parts) {
  846. if (options & O_NOFOLLOW)
  847. return ELOOP;
  848. if (options & O_NOFOLLOW_NOERROR)
  849. break;
  850. }
  851. if (!safe_to_follow_symlink(*child_inode, parent_metadata))
  852. return EACCES;
  853. if (auto result = validate_path_against_process_veil(*custody, options); result.is_error())
  854. return result;
  855. auto symlink_target = child_inode->resolve_as_link(parent, out_parent, options, symlink_recursion_level + 1);
  856. if (symlink_target.is_error() || !have_more_parts)
  857. return symlink_target;
  858. // Now, resolve the remaining path relative to the symlink target.
  859. // We prepend a "." to it to ensure that it's not empty and that
  860. // any initial slashes it might have get interpreted properly.
  861. StringBuilder remaining_path;
  862. remaining_path.append('.');
  863. remaining_path.append(path.substring_view_starting_after_substring(part));
  864. return resolve_path_without_veil(remaining_path.to_string(), *symlink_target.value(), out_parent, options, symlink_recursion_level + 1);
  865. }
  866. }
  867. if (out_parent)
  868. *out_parent = custody->parent();
  869. return custody;
  870. }
  871. }