1 //===--------------------- filesystem/ops.cpp -----------------------------===// 2 // 3 // Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions. 4 // See https://llvm.org/LICENSE.txt for license information. 5 // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception 6 // 7 //===----------------------------------------------------------------------===// 8 9 #include "filesystem" 10 #include "array" 11 #include "iterator" 12 #include "string_view" 13 #include "type_traits" 14 #include "vector" 15 #include "cstdlib" 16 #include "climits" 17 18 #include "filesystem_common.h" 19 20 #include "posix_compat.h" 21 22 #if defined(_LIBCPP_WIN32API) 23 # define WIN32_LEAN_AND_MEAN 24 # define NOMINMAX 25 # include <windows.h> 26 #else 27 # include <unistd.h> 28 # include <sys/stat.h> 29 # include <sys/statvfs.h> 30 #endif 31 #include <time.h> 32 #include <fcntl.h> /* values for fchmodat */ 33 34 #if __has_include(<sys/sendfile.h>) 35 # include <sys/sendfile.h> 36 # define _LIBCPP_FILESYSTEM_USE_SENDFILE 37 #elif defined(__APPLE__) || __has_include(<copyfile.h>) 38 # include <copyfile.h> 39 # define _LIBCPP_FILESYSTEM_USE_COPYFILE 40 #else 41 # include "fstream" 42 # define _LIBCPP_FILESYSTEM_USE_FSTREAM 43 #endif 44 45 #if !defined(CLOCK_REALTIME) && !defined(_LIBCPP_WIN32API) 46 # include <sys/time.h> // for gettimeofday and timeval 47 #endif 48 49 #if defined(__ELF__) && defined(_LIBCPP_LINK_RT_LIB) 50 # pragma comment(lib, "rt") 51 #endif 52 53 _LIBCPP_BEGIN_NAMESPACE_FILESYSTEM 54 55 namespace { 56 57 bool isSeparator(path::value_type C) { 58 if (C == '/') 59 return true; 60 #if defined(_LIBCPP_WIN32API) 61 if (C == '\\') 62 return true; 63 #endif 64 return false; 65 } 66 67 namespace parser { 68 69 using string_view_t = path::__string_view; 70 using string_view_pair = pair<string_view_t, string_view_t>; 71 using PosPtr = path::value_type const*; 72 73 struct PathParser { 74 enum ParserState : unsigned char { 75 // Zero is a special sentinel value used by default constructed iterators. 76 PS_BeforeBegin = path::iterator::_BeforeBegin, 77 PS_InRootName = path::iterator::_InRootName, 78 PS_InRootDir = path::iterator::_InRootDir, 79 PS_InFilenames = path::iterator::_InFilenames, 80 PS_InTrailingSep = path::iterator::_InTrailingSep, 81 PS_AtEnd = path::iterator::_AtEnd 82 }; 83 84 const string_view_t Path; 85 string_view_t RawEntry; 86 ParserState State; 87 88 private: 89 PathParser(string_view_t P, ParserState State) noexcept : Path(P), 90 State(State) {} 91 92 public: 93 PathParser(string_view_t P, string_view_t E, unsigned char S) 94 : Path(P), RawEntry(E), State(static_cast<ParserState>(S)) { 95 // S cannot be '0' or PS_BeforeBegin. 96 } 97 98 static PathParser CreateBegin(string_view_t P) noexcept { 99 PathParser PP(P, PS_BeforeBegin); 100 PP.increment(); 101 return PP; 102 } 103 104 static PathParser CreateEnd(string_view_t P) noexcept { 105 PathParser PP(P, PS_AtEnd); 106 return PP; 107 } 108 109 PosPtr peek() const noexcept { 110 auto TkEnd = getNextTokenStartPos(); 111 auto End = getAfterBack(); 112 return TkEnd == End ? nullptr : TkEnd; 113 } 114 115 void increment() noexcept { 116 const PosPtr End = getAfterBack(); 117 const PosPtr Start = getNextTokenStartPos(); 118 if (Start == End) 119 return makeState(PS_AtEnd); 120 121 switch (State) { 122 case PS_BeforeBegin: { 123 PosPtr TkEnd = consumeSeparator(Start, End); 124 if (TkEnd) 125 return makeState(PS_InRootDir, Start, TkEnd); 126 else 127 return makeState(PS_InFilenames, Start, consumeName(Start, End)); 128 } 129 case PS_InRootDir: 130 return makeState(PS_InFilenames, Start, consumeName(Start, End)); 131 132 case PS_InFilenames: { 133 PosPtr SepEnd = consumeSeparator(Start, End); 134 if (SepEnd != End) { 135 PosPtr TkEnd = consumeName(SepEnd, End); 136 if (TkEnd) 137 return makeState(PS_InFilenames, SepEnd, TkEnd); 138 } 139 return makeState(PS_InTrailingSep, Start, SepEnd); 140 } 141 142 case PS_InTrailingSep: 143 return makeState(PS_AtEnd); 144 145 case PS_InRootName: 146 case PS_AtEnd: 147 _LIBCPP_UNREACHABLE(); 148 } 149 } 150 151 void decrement() noexcept { 152 const PosPtr REnd = getBeforeFront(); 153 const PosPtr RStart = getCurrentTokenStartPos() - 1; 154 if (RStart == REnd) // we're decrementing the begin 155 return makeState(PS_BeforeBegin); 156 157 switch (State) { 158 case PS_AtEnd: { 159 // Try to consume a trailing separator or root directory first. 160 if (PosPtr SepEnd = consumeSeparator(RStart, REnd)) { 161 if (SepEnd == REnd) 162 return makeState(PS_InRootDir, Path.data(), RStart + 1); 163 return makeState(PS_InTrailingSep, SepEnd + 1, RStart + 1); 164 } else { 165 PosPtr TkStart = consumeName(RStart, REnd); 166 return makeState(PS_InFilenames, TkStart + 1, RStart + 1); 167 } 168 } 169 case PS_InTrailingSep: 170 return makeState(PS_InFilenames, consumeName(RStart, REnd) + 1, 171 RStart + 1); 172 case PS_InFilenames: { 173 PosPtr SepEnd = consumeSeparator(RStart, REnd); 174 if (SepEnd == REnd) 175 return makeState(PS_InRootDir, Path.data(), RStart + 1); 176 PosPtr TkEnd = consumeName(SepEnd, REnd); 177 return makeState(PS_InFilenames, TkEnd + 1, SepEnd + 1); 178 } 179 case PS_InRootDir: 180 // return makeState(PS_InRootName, Path.data(), RStart + 1); 181 case PS_InRootName: 182 case PS_BeforeBegin: 183 _LIBCPP_UNREACHABLE(); 184 } 185 } 186 187 /// \brief Return a view with the "preferred representation" of the current 188 /// element. For example trailing separators are represented as a '.' 189 string_view_t operator*() const noexcept { 190 switch (State) { 191 case PS_BeforeBegin: 192 case PS_AtEnd: 193 return PS(""); 194 case PS_InRootDir: 195 if (RawEntry[0] == '\\') 196 return PS("\\"); 197 else 198 return PS("/"); 199 case PS_InTrailingSep: 200 return PS(""); 201 case PS_InRootName: 202 case PS_InFilenames: 203 return RawEntry; 204 } 205 _LIBCPP_UNREACHABLE(); 206 } 207 208 explicit operator bool() const noexcept { 209 return State != PS_BeforeBegin && State != PS_AtEnd; 210 } 211 212 PathParser& operator++() noexcept { 213 increment(); 214 return *this; 215 } 216 217 PathParser& operator--() noexcept { 218 decrement(); 219 return *this; 220 } 221 222 bool atEnd() const noexcept { 223 return State == PS_AtEnd; 224 } 225 226 bool inRootDir() const noexcept { 227 return State == PS_InRootDir; 228 } 229 230 bool inRootName() const noexcept { 231 return State == PS_InRootName; 232 } 233 234 bool inRootPath() const noexcept { 235 return inRootName() || inRootDir(); 236 } 237 238 private: 239 void makeState(ParserState NewState, PosPtr Start, PosPtr End) noexcept { 240 State = NewState; 241 RawEntry = string_view_t(Start, End - Start); 242 } 243 void makeState(ParserState NewState) noexcept { 244 State = NewState; 245 RawEntry = {}; 246 } 247 248 PosPtr getAfterBack() const noexcept { return Path.data() + Path.size(); } 249 250 PosPtr getBeforeFront() const noexcept { return Path.data() - 1; } 251 252 /// \brief Return a pointer to the first character after the currently 253 /// lexed element. 254 PosPtr getNextTokenStartPos() const noexcept { 255 switch (State) { 256 case PS_BeforeBegin: 257 return Path.data(); 258 case PS_InRootName: 259 case PS_InRootDir: 260 case PS_InFilenames: 261 return &RawEntry.back() + 1; 262 case PS_InTrailingSep: 263 case PS_AtEnd: 264 return getAfterBack(); 265 } 266 _LIBCPP_UNREACHABLE(); 267 } 268 269 /// \brief Return a pointer to the first character in the currently lexed 270 /// element. 271 PosPtr getCurrentTokenStartPos() const noexcept { 272 switch (State) { 273 case PS_BeforeBegin: 274 case PS_InRootName: 275 return &Path.front(); 276 case PS_InRootDir: 277 case PS_InFilenames: 278 case PS_InTrailingSep: 279 return &RawEntry.front(); 280 case PS_AtEnd: 281 return &Path.back() + 1; 282 } 283 _LIBCPP_UNREACHABLE(); 284 } 285 286 PosPtr consumeSeparator(PosPtr P, PosPtr End) const noexcept { 287 if (P == End || !isSeparator(*P)) 288 return nullptr; 289 const int Inc = P < End ? 1 : -1; 290 P += Inc; 291 while (P != End && isSeparator(*P)) 292 P += Inc; 293 return P; 294 } 295 296 PosPtr consumeName(PosPtr P, PosPtr End) const noexcept { 297 if (P == End || isSeparator(*P)) 298 return nullptr; 299 const int Inc = P < End ? 1 : -1; 300 P += Inc; 301 while (P != End && !isSeparator(*P)) 302 P += Inc; 303 return P; 304 } 305 }; 306 307 string_view_pair separate_filename(string_view_t const& s) { 308 if (s == PS(".") || s == PS("..") || s.empty()) 309 return string_view_pair{s, PS("")}; 310 auto pos = s.find_last_of('.'); 311 if (pos == string_view_t::npos || pos == 0) 312 return string_view_pair{s, string_view_t{}}; 313 return string_view_pair{s.substr(0, pos), s.substr(pos)}; 314 } 315 316 string_view_t createView(PosPtr S, PosPtr E) noexcept { 317 return {S, static_cast<size_t>(E - S) + 1}; 318 } 319 320 } // namespace parser 321 } // namespace 322 323 // POSIX HELPERS 324 325 #if defined(_LIBCPP_WIN32API) 326 namespace detail { 327 328 errc __win_err_to_errc(int err) { 329 constexpr struct { 330 DWORD win; 331 errc errc; 332 } win_error_mapping[] = { 333 {ERROR_ACCESS_DENIED, errc::permission_denied}, 334 {ERROR_ALREADY_EXISTS, errc::file_exists}, 335 {ERROR_BAD_NETPATH, errc::no_such_file_or_directory}, 336 {ERROR_BAD_UNIT, errc::no_such_device}, 337 {ERROR_BROKEN_PIPE, errc::broken_pipe}, 338 {ERROR_BUFFER_OVERFLOW, errc::filename_too_long}, 339 {ERROR_BUSY, errc::device_or_resource_busy}, 340 {ERROR_BUSY_DRIVE, errc::device_or_resource_busy}, 341 {ERROR_CANNOT_MAKE, errc::permission_denied}, 342 {ERROR_CANTOPEN, errc::io_error}, 343 {ERROR_CANTREAD, errc::io_error}, 344 {ERROR_CANTWRITE, errc::io_error}, 345 {ERROR_CURRENT_DIRECTORY, errc::permission_denied}, 346 {ERROR_DEV_NOT_EXIST, errc::no_such_device}, 347 {ERROR_DEVICE_IN_USE, errc::device_or_resource_busy}, 348 {ERROR_DIR_NOT_EMPTY, errc::directory_not_empty}, 349 {ERROR_DIRECTORY, errc::invalid_argument}, 350 {ERROR_DISK_FULL, errc::no_space_on_device}, 351 {ERROR_FILE_EXISTS, errc::file_exists}, 352 {ERROR_FILE_NOT_FOUND, errc::no_such_file_or_directory}, 353 {ERROR_HANDLE_DISK_FULL, errc::no_space_on_device}, 354 {ERROR_INVALID_ACCESS, errc::permission_denied}, 355 {ERROR_INVALID_DRIVE, errc::no_such_device}, 356 {ERROR_INVALID_FUNCTION, errc::function_not_supported}, 357 {ERROR_INVALID_HANDLE, errc::invalid_argument}, 358 {ERROR_INVALID_NAME, errc::no_such_file_or_directory}, 359 {ERROR_INVALID_PARAMETER, errc::invalid_argument}, 360 {ERROR_LOCK_VIOLATION, errc::no_lock_available}, 361 {ERROR_LOCKED, errc::no_lock_available}, 362 {ERROR_NEGATIVE_SEEK, errc::invalid_argument}, 363 {ERROR_NOACCESS, errc::permission_denied}, 364 {ERROR_NOT_ENOUGH_MEMORY, errc::not_enough_memory}, 365 {ERROR_NOT_READY, errc::resource_unavailable_try_again}, 366 {ERROR_NOT_SAME_DEVICE, errc::cross_device_link}, 367 {ERROR_NOT_SUPPORTED, errc::not_supported}, 368 {ERROR_OPEN_FAILED, errc::io_error}, 369 {ERROR_OPEN_FILES, errc::device_or_resource_busy}, 370 {ERROR_OPERATION_ABORTED, errc::operation_canceled}, 371 {ERROR_OUTOFMEMORY, errc::not_enough_memory}, 372 {ERROR_PATH_NOT_FOUND, errc::no_such_file_or_directory}, 373 {ERROR_READ_FAULT, errc::io_error}, 374 {ERROR_REPARSE_TAG_INVALID, errc::invalid_argument}, 375 {ERROR_RETRY, errc::resource_unavailable_try_again}, 376 {ERROR_SEEK, errc::io_error}, 377 {ERROR_SHARING_VIOLATION, errc::permission_denied}, 378 {ERROR_TOO_MANY_OPEN_FILES, errc::too_many_files_open}, 379 {ERROR_WRITE_FAULT, errc::io_error}, 380 {ERROR_WRITE_PROTECT, errc::permission_denied}, 381 }; 382 383 for (const auto &pair : win_error_mapping) 384 if (pair.win == static_cast<DWORD>(err)) 385 return pair.errc; 386 return errc::invalid_argument; 387 } 388 389 } // namespace detail 390 #endif 391 392 namespace detail { 393 namespace { 394 395 using value_type = path::value_type; 396 using string_type = path::string_type; 397 398 struct FileDescriptor { 399 const path& name; 400 int fd = -1; 401 StatT m_stat; 402 file_status m_status; 403 404 template <class... Args> 405 static FileDescriptor create(const path* p, error_code& ec, Args... args) { 406 ec.clear(); 407 int fd; 408 if ((fd = detail::open(p->c_str(), args...)) == -1) { 409 ec = capture_errno(); 410 return FileDescriptor{p}; 411 } 412 return FileDescriptor(p, fd); 413 } 414 415 template <class... Args> 416 static FileDescriptor create_with_status(const path* p, error_code& ec, 417 Args... args) { 418 FileDescriptor fd = create(p, ec, args...); 419 if (!ec) 420 fd.refresh_status(ec); 421 422 return fd; 423 } 424 425 file_status get_status() const { return m_status; } 426 StatT const& get_stat() const { return m_stat; } 427 428 bool status_known() const { return _VSTD_FS::status_known(m_status); } 429 430 file_status refresh_status(error_code& ec); 431 432 void close() noexcept { 433 if (fd != -1) 434 detail::close(fd); 435 fd = -1; 436 } 437 438 FileDescriptor(FileDescriptor&& other) 439 : name(other.name), fd(other.fd), m_stat(other.m_stat), 440 m_status(other.m_status) { 441 other.fd = -1; 442 other.m_status = file_status{}; 443 } 444 445 ~FileDescriptor() { close(); } 446 447 FileDescriptor(FileDescriptor const&) = delete; 448 FileDescriptor& operator=(FileDescriptor const&) = delete; 449 450 private: 451 explicit FileDescriptor(const path* p, int fd = -1) : name(*p), fd(fd) {} 452 }; 453 454 perms posix_get_perms(const StatT& st) noexcept { 455 return static_cast<perms>(st.st_mode) & perms::mask; 456 } 457 458 file_status create_file_status(error_code& m_ec, path const& p, 459 const StatT& path_stat, error_code* ec) { 460 if (ec) 461 *ec = m_ec; 462 if (m_ec && (m_ec.value() == ENOENT || m_ec.value() == ENOTDIR)) { 463 return file_status(file_type::not_found); 464 } else if (m_ec) { 465 ErrorHandler<void> err("posix_stat", ec, &p); 466 err.report(m_ec, "failed to determine attributes for the specified path"); 467 return file_status(file_type::none); 468 } 469 // else 470 471 file_status fs_tmp; 472 auto const mode = path_stat.st_mode; 473 if (S_ISLNK(mode)) 474 fs_tmp.type(file_type::symlink); 475 else if (S_ISREG(mode)) 476 fs_tmp.type(file_type::regular); 477 else if (S_ISDIR(mode)) 478 fs_tmp.type(file_type::directory); 479 else if (S_ISBLK(mode)) 480 fs_tmp.type(file_type::block); 481 else if (S_ISCHR(mode)) 482 fs_tmp.type(file_type::character); 483 else if (S_ISFIFO(mode)) 484 fs_tmp.type(file_type::fifo); 485 else if (S_ISSOCK(mode)) 486 fs_tmp.type(file_type::socket); 487 else 488 fs_tmp.type(file_type::unknown); 489 490 fs_tmp.permissions(detail::posix_get_perms(path_stat)); 491 return fs_tmp; 492 } 493 494 file_status posix_stat(path const& p, StatT& path_stat, error_code* ec) { 495 error_code m_ec; 496 if (detail::stat(p.c_str(), &path_stat) == -1) 497 m_ec = detail::capture_errno(); 498 return create_file_status(m_ec, p, path_stat, ec); 499 } 500 501 file_status posix_stat(path const& p, error_code* ec) { 502 StatT path_stat; 503 return posix_stat(p, path_stat, ec); 504 } 505 506 file_status posix_lstat(path const& p, StatT& path_stat, error_code* ec) { 507 error_code m_ec; 508 if (detail::lstat(p.c_str(), &path_stat) == -1) 509 m_ec = detail::capture_errno(); 510 return create_file_status(m_ec, p, path_stat, ec); 511 } 512 513 file_status posix_lstat(path const& p, error_code* ec) { 514 StatT path_stat; 515 return posix_lstat(p, path_stat, ec); 516 } 517 518 // http://pubs.opengroup.org/onlinepubs/9699919799/functions/ftruncate.html 519 bool posix_ftruncate(const FileDescriptor& fd, off_t to_size, error_code& ec) { 520 if (detail::ftruncate(fd.fd, to_size) == -1) { 521 ec = capture_errno(); 522 return true; 523 } 524 ec.clear(); 525 return false; 526 } 527 528 bool posix_fchmod(const FileDescriptor& fd, const StatT& st, error_code& ec) { 529 if (detail::fchmod(fd.fd, st.st_mode) == -1) { 530 ec = capture_errno(); 531 return true; 532 } 533 ec.clear(); 534 return false; 535 } 536 537 bool stat_equivalent(const StatT& st1, const StatT& st2) { 538 return (st1.st_dev == st2.st_dev && st1.st_ino == st2.st_ino); 539 } 540 541 file_status FileDescriptor::refresh_status(error_code& ec) { 542 // FD must be open and good. 543 m_status = file_status{}; 544 m_stat = {}; 545 error_code m_ec; 546 if (detail::fstat(fd, &m_stat) == -1) 547 m_ec = capture_errno(); 548 m_status = create_file_status(m_ec, name, m_stat, &ec); 549 return m_status; 550 } 551 } // namespace 552 } // end namespace detail 553 554 using detail::capture_errno; 555 using detail::ErrorHandler; 556 using detail::StatT; 557 using detail::TimeSpec; 558 using parser::createView; 559 using parser::PathParser; 560 using parser::string_view_t; 561 562 const bool _FilesystemClock::is_steady; 563 564 _FilesystemClock::time_point _FilesystemClock::now() noexcept { 565 typedef chrono::duration<rep> __secs; 566 #if defined(_LIBCPP_WIN32API) 567 typedef chrono::duration<rep, nano> __nsecs; 568 FILETIME time; 569 GetSystemTimeAsFileTime(&time); 570 TimeSpec tp = detail::filetime_to_timespec(time); 571 return time_point(__secs(tp.tv_sec) + 572 chrono::duration_cast<duration>(__nsecs(tp.tv_nsec))); 573 #elif defined(CLOCK_REALTIME) 574 typedef chrono::duration<rep, nano> __nsecs; 575 struct timespec tp; 576 if (0 != clock_gettime(CLOCK_REALTIME, &tp)) 577 __throw_system_error(errno, "clock_gettime(CLOCK_REALTIME) failed"); 578 return time_point(__secs(tp.tv_sec) + 579 chrono::duration_cast<duration>(__nsecs(tp.tv_nsec))); 580 #else 581 typedef chrono::duration<rep, micro> __microsecs; 582 timeval tv; 583 gettimeofday(&tv, 0); 584 return time_point(__secs(tv.tv_sec) + __microsecs(tv.tv_usec)); 585 #endif // CLOCK_REALTIME 586 } 587 588 filesystem_error::~filesystem_error() {} 589 590 #if defined(_LIBCPP_WIN32API) 591 #define PS_FMT "%ls" 592 #else 593 #define PS_FMT "%s" 594 #endif 595 596 void filesystem_error::__create_what(int __num_paths) { 597 const char* derived_what = system_error::what(); 598 __storage_->__what_ = [&]() -> string { 599 const path::value_type* p1 = path1().native().empty() ? PS("\"\"") : path1().c_str(); 600 const path::value_type* p2 = path2().native().empty() ? PS("\"\"") : path2().c_str(); 601 switch (__num_paths) { 602 default: 603 return detail::format_string("filesystem error: %s", derived_what); 604 case 1: 605 return detail::format_string("filesystem error: %s [" PS_FMT "]", derived_what, 606 p1); 607 case 2: 608 return detail::format_string("filesystem error: %s [" PS_FMT "] [" PS_FMT "]", 609 derived_what, p1, p2); 610 } 611 }(); 612 } 613 614 static path __do_absolute(const path& p, path* cwd, error_code* ec) { 615 if (ec) 616 ec->clear(); 617 if (p.is_absolute()) 618 return p; 619 *cwd = __current_path(ec); 620 if (ec && *ec) 621 return {}; 622 return (*cwd) / p; 623 } 624 625 path __absolute(const path& p, error_code* ec) { 626 path cwd; 627 return __do_absolute(p, &cwd, ec); 628 } 629 630 path __canonical(path const& orig_p, error_code* ec) { 631 path cwd; 632 ErrorHandler<path> err("canonical", ec, &orig_p, &cwd); 633 634 path p = __do_absolute(orig_p, &cwd, ec); 635 #if (defined(_POSIX_VERSION) && _POSIX_VERSION >= 200112) || defined(_LIBCPP_WIN32API) 636 std::unique_ptr<path::value_type, decltype(&::free)> 637 hold(detail::realpath(p.c_str(), nullptr), &::free); 638 if (hold.get() == nullptr) 639 return err.report(capture_errno()); 640 return {hold.get()}; 641 #else 642 #if defined(__MVS__) && !defined(PATH_MAX) 643 path::value_type buff[ _XOPEN_PATH_MAX + 1 ]; 644 #else 645 path::value_type buff[PATH_MAX + 1]; 646 #endif 647 path::value_type* ret; 648 if ((ret = detail::realpath(p.c_str(), buff)) == nullptr) 649 return err.report(capture_errno()); 650 return {ret}; 651 #endif 652 } 653 654 void __copy(const path& from, const path& to, copy_options options, 655 error_code* ec) { 656 ErrorHandler<void> err("copy", ec, &from, &to); 657 658 const bool sym_status = bool( 659 options & (copy_options::create_symlinks | copy_options::skip_symlinks)); 660 661 const bool sym_status2 = bool(options & copy_options::copy_symlinks); 662 663 error_code m_ec1; 664 StatT f_st = {}; 665 const file_status f = sym_status || sym_status2 666 ? detail::posix_lstat(from, f_st, &m_ec1) 667 : detail::posix_stat(from, f_st, &m_ec1); 668 if (m_ec1) 669 return err.report(m_ec1); 670 671 StatT t_st = {}; 672 const file_status t = sym_status ? detail::posix_lstat(to, t_st, &m_ec1) 673 : detail::posix_stat(to, t_st, &m_ec1); 674 675 if (not status_known(t)) 676 return err.report(m_ec1); 677 678 if (!exists(f) || is_other(f) || is_other(t) || 679 (is_directory(f) && is_regular_file(t)) || 680 detail::stat_equivalent(f_st, t_st)) { 681 return err.report(errc::function_not_supported); 682 } 683 684 if (ec) 685 ec->clear(); 686 687 if (is_symlink(f)) { 688 if (bool(copy_options::skip_symlinks & options)) { 689 // do nothing 690 } else if (not exists(t)) { 691 __copy_symlink(from, to, ec); 692 } else { 693 return err.report(errc::file_exists); 694 } 695 return; 696 } else if (is_regular_file(f)) { 697 if (bool(copy_options::directories_only & options)) { 698 // do nothing 699 } else if (bool(copy_options::create_symlinks & options)) { 700 __create_symlink(from, to, ec); 701 } else if (bool(copy_options::create_hard_links & options)) { 702 __create_hard_link(from, to, ec); 703 } else if (is_directory(t)) { 704 __copy_file(from, to / from.filename(), options, ec); 705 } else { 706 __copy_file(from, to, options, ec); 707 } 708 return; 709 } else if (is_directory(f) && bool(copy_options::create_symlinks & options)) { 710 return err.report(errc::is_a_directory); 711 } else if (is_directory(f) && (bool(copy_options::recursive & options) || 712 copy_options::none == options)) { 713 714 if (!exists(t)) { 715 // create directory to with attributes from 'from'. 716 __create_directory(to, from, ec); 717 if (ec && *ec) { 718 return; 719 } 720 } 721 directory_iterator it = 722 ec ? directory_iterator(from, *ec) : directory_iterator(from); 723 if (ec && *ec) { 724 return; 725 } 726 error_code m_ec2; 727 for (; it != directory_iterator(); it.increment(m_ec2)) { 728 if (m_ec2) { 729 return err.report(m_ec2); 730 } 731 __copy(it->path(), to / it->path().filename(), 732 options | copy_options::__in_recursive_copy, ec); 733 if (ec && *ec) { 734 return; 735 } 736 } 737 } 738 } 739 740 namespace detail { 741 namespace { 742 743 #if defined(_LIBCPP_FILESYSTEM_USE_SENDFILE) 744 bool copy_file_impl(FileDescriptor& read_fd, FileDescriptor& write_fd, error_code& ec) { 745 size_t count = read_fd.get_stat().st_size; 746 do { 747 ssize_t res; 748 if ((res = ::sendfile(write_fd.fd, read_fd.fd, nullptr, count)) == -1) { 749 ec = capture_errno(); 750 return false; 751 } 752 count -= res; 753 } while (count > 0); 754 755 ec.clear(); 756 757 return true; 758 } 759 #elif defined(_LIBCPP_FILESYSTEM_USE_COPYFILE) 760 bool copy_file_impl(FileDescriptor& read_fd, FileDescriptor& write_fd, error_code& ec) { 761 struct CopyFileState { 762 copyfile_state_t state; 763 CopyFileState() { state = copyfile_state_alloc(); } 764 ~CopyFileState() { copyfile_state_free(state); } 765 766 private: 767 CopyFileState(CopyFileState const&) = delete; 768 CopyFileState& operator=(CopyFileState const&) = delete; 769 }; 770 771 CopyFileState cfs; 772 if (fcopyfile(read_fd.fd, write_fd.fd, cfs.state, COPYFILE_DATA) < 0) { 773 ec = capture_errno(); 774 return false; 775 } 776 777 ec.clear(); 778 return true; 779 } 780 #elif defined(_LIBCPP_FILESYSTEM_USE_FSTREAM) 781 bool copy_file_impl(FileDescriptor& read_fd, FileDescriptor& write_fd, error_code& ec) { 782 ifstream in; 783 in.__open(read_fd.fd, ios::binary); 784 if (!in.is_open()) { 785 // This assumes that __open didn't reset the error code. 786 ec = capture_errno(); 787 return false; 788 } 789 read_fd.fd = -1; 790 ofstream out; 791 out.__open(write_fd.fd, ios::binary); 792 if (!out.is_open()) { 793 ec = capture_errno(); 794 return false; 795 } 796 write_fd.fd = -1; 797 798 if (in.good() && out.good()) { 799 using InIt = istreambuf_iterator<char>; 800 using OutIt = ostreambuf_iterator<char>; 801 InIt bin(in); 802 InIt ein; 803 OutIt bout(out); 804 copy(bin, ein, bout); 805 } 806 if (out.fail() || in.fail()) { 807 ec = make_error_code(errc::io_error); 808 return false; 809 } 810 811 ec.clear(); 812 return true; 813 } 814 #else 815 # error "Unknown implementation for copy_file_impl" 816 #endif // copy_file_impl implementation 817 818 } // end anonymous namespace 819 } // end namespace detail 820 821 bool __copy_file(const path& from, const path& to, copy_options options, 822 error_code* ec) { 823 using detail::FileDescriptor; 824 ErrorHandler<bool> err("copy_file", ec, &to, &from); 825 826 error_code m_ec; 827 FileDescriptor from_fd = FileDescriptor::create_with_status( 828 &from, m_ec, O_RDONLY | O_NONBLOCK | O_BINARY); 829 if (m_ec) 830 return err.report(m_ec); 831 832 auto from_st = from_fd.get_status(); 833 StatT const& from_stat = from_fd.get_stat(); 834 if (!is_regular_file(from_st)) { 835 if (not m_ec) 836 m_ec = make_error_code(errc::not_supported); 837 return err.report(m_ec); 838 } 839 840 const bool skip_existing = bool(copy_options::skip_existing & options); 841 const bool update_existing = bool(copy_options::update_existing & options); 842 const bool overwrite_existing = 843 bool(copy_options::overwrite_existing & options); 844 845 StatT to_stat_path; 846 file_status to_st = detail::posix_stat(to, to_stat_path, &m_ec); 847 if (!status_known(to_st)) 848 return err.report(m_ec); 849 850 const bool to_exists = exists(to_st); 851 if (to_exists && !is_regular_file(to_st)) 852 return err.report(errc::not_supported); 853 854 if (to_exists && detail::stat_equivalent(from_stat, to_stat_path)) 855 return err.report(errc::file_exists); 856 857 if (to_exists && skip_existing) 858 return false; 859 860 bool ShouldCopy = [&]() { 861 if (to_exists && update_existing) { 862 auto from_time = detail::extract_mtime(from_stat); 863 auto to_time = detail::extract_mtime(to_stat_path); 864 if (from_time.tv_sec < to_time.tv_sec) 865 return false; 866 if (from_time.tv_sec == to_time.tv_sec && 867 from_time.tv_nsec <= to_time.tv_nsec) 868 return false; 869 return true; 870 } 871 if (!to_exists || overwrite_existing) 872 return true; 873 return err.report(errc::file_exists); 874 }(); 875 if (!ShouldCopy) 876 return false; 877 878 // Don't truncate right away. We may not be opening the file we originally 879 // looked at; we'll check this later. 880 int to_open_flags = O_WRONLY | O_BINARY; 881 if (!to_exists) 882 to_open_flags |= O_CREAT; 883 FileDescriptor to_fd = FileDescriptor::create_with_status( 884 &to, m_ec, to_open_flags, from_stat.st_mode); 885 if (m_ec) 886 return err.report(m_ec); 887 888 if (to_exists) { 889 // Check that the file we initially stat'ed is equivalent to the one 890 // we opened. 891 // FIXME: report this better. 892 if (!detail::stat_equivalent(to_stat_path, to_fd.get_stat())) 893 return err.report(errc::bad_file_descriptor); 894 895 // Set the permissions and truncate the file we opened. 896 if (detail::posix_fchmod(to_fd, from_stat, m_ec)) 897 return err.report(m_ec); 898 if (detail::posix_ftruncate(to_fd, 0, m_ec)) 899 return err.report(m_ec); 900 } 901 902 if (!copy_file_impl(from_fd, to_fd, m_ec)) { 903 // FIXME: Remove the dest file if we failed, and it didn't exist previously. 904 return err.report(m_ec); 905 } 906 907 return true; 908 } 909 910 void __copy_symlink(const path& existing_symlink, const path& new_symlink, 911 error_code* ec) { 912 const path real_path(__read_symlink(existing_symlink, ec)); 913 if (ec && *ec) { 914 return; 915 } 916 #if defined(_LIBCPP_WIN32API) 917 error_code local_ec; 918 if (is_directory(real_path, local_ec)) 919 __create_directory_symlink(real_path, new_symlink, ec); 920 else 921 #endif 922 __create_symlink(real_path, new_symlink, ec); 923 } 924 925 bool __create_directories(const path& p, error_code* ec) { 926 ErrorHandler<bool> err("create_directories", ec, &p); 927 928 error_code m_ec; 929 auto const st = detail::posix_stat(p, &m_ec); 930 if (!status_known(st)) 931 return err.report(m_ec); 932 else if (is_directory(st)) 933 return false; 934 else if (exists(st)) 935 return err.report(errc::file_exists); 936 937 const path parent = p.parent_path(); 938 if (!parent.empty()) { 939 const file_status parent_st = status(parent, m_ec); 940 if (not status_known(parent_st)) 941 return err.report(m_ec); 942 if (not exists(parent_st)) { 943 __create_directories(parent, ec); 944 if (ec && *ec) { 945 return false; 946 } 947 } 948 } 949 return __create_directory(p, ec); 950 } 951 952 bool __create_directory(const path& p, error_code* ec) { 953 ErrorHandler<bool> err("create_directory", ec, &p); 954 955 if (detail::mkdir(p.c_str(), static_cast<int>(perms::all)) == 0) 956 return true; 957 958 if (errno == EEXIST) { 959 error_code mec = capture_errno(); 960 error_code ignored_ec; 961 const file_status st = status(p, ignored_ec); 962 if (!is_directory(st)) { 963 err.report(mec); 964 } 965 } else { 966 err.report(capture_errno()); 967 } 968 return false; 969 } 970 971 bool __create_directory(path const& p, path const& attributes, error_code* ec) { 972 ErrorHandler<bool> err("create_directory", ec, &p, &attributes); 973 974 StatT attr_stat; 975 error_code mec; 976 auto st = detail::posix_stat(attributes, attr_stat, &mec); 977 if (!status_known(st)) 978 return err.report(mec); 979 if (!is_directory(st)) 980 return err.report(errc::not_a_directory, 981 "the specified attribute path is invalid"); 982 983 if (detail::mkdir(p.c_str(), attr_stat.st_mode) == 0) 984 return true; 985 986 if (errno == EEXIST) { 987 error_code mec = capture_errno(); 988 error_code ignored_ec; 989 const file_status st = status(p, ignored_ec); 990 if (!is_directory(st)) { 991 err.report(mec); 992 } 993 } else { 994 err.report(capture_errno()); 995 } 996 return false; 997 } 998 999 void __create_directory_symlink(path const& from, path const& to, 1000 error_code* ec) { 1001 ErrorHandler<void> err("create_directory_symlink", ec, &from, &to); 1002 if (detail::symlink_dir(from.c_str(), to.c_str()) == -1) 1003 return err.report(capture_errno()); 1004 } 1005 1006 void __create_hard_link(const path& from, const path& to, error_code* ec) { 1007 ErrorHandler<void> err("create_hard_link", ec, &from, &to); 1008 if (detail::link(from.c_str(), to.c_str()) == -1) 1009 return err.report(capture_errno()); 1010 } 1011 1012 void __create_symlink(path const& from, path const& to, error_code* ec) { 1013 ErrorHandler<void> err("create_symlink", ec, &from, &to); 1014 if (detail::symlink_file(from.c_str(), to.c_str()) == -1) 1015 return err.report(capture_errno()); 1016 } 1017 1018 path __current_path(error_code* ec) { 1019 ErrorHandler<path> err("current_path", ec); 1020 1021 #if defined(_LIBCPP_WIN32API) 1022 // Common extension outside of POSIX getcwd() spec, without needing to 1023 // preallocate a buffer. Also supported by a number of other POSIX libcs. 1024 int size = 0; 1025 path::value_type* ptr = nullptr; 1026 typedef decltype(&::free) Deleter; 1027 Deleter deleter = &::free; 1028 #else 1029 auto size = ::pathconf(".", _PC_PATH_MAX); 1030 _LIBCPP_ASSERT(size >= 0, "pathconf returned a 0 as max size"); 1031 1032 auto buff = unique_ptr<path::value_type[]>(new path::value_type[size + 1]); 1033 path::value_type* ptr = buff.get(); 1034 1035 // Preallocated buffer, don't free the buffer in the second unique_ptr 1036 // below. 1037 struct Deleter { void operator()(void*) const {} }; 1038 Deleter deleter; 1039 #endif 1040 1041 unique_ptr<path::value_type, Deleter> hold(detail::getcwd(ptr, size), 1042 deleter); 1043 if (hold.get() == nullptr) 1044 return err.report(capture_errno(), "call to getcwd failed"); 1045 1046 return {hold.get()}; 1047 } 1048 1049 void __current_path(const path& p, error_code* ec) { 1050 ErrorHandler<void> err("current_path", ec, &p); 1051 if (detail::chdir(p.c_str()) == -1) 1052 err.report(capture_errno()); 1053 } 1054 1055 bool __equivalent(const path& p1, const path& p2, error_code* ec) { 1056 ErrorHandler<bool> err("equivalent", ec, &p1, &p2); 1057 1058 error_code ec1, ec2; 1059 StatT st1 = {}, st2 = {}; 1060 auto s1 = detail::posix_stat(p1.native(), st1, &ec1); 1061 if (!exists(s1)) 1062 return err.report(errc::not_supported); 1063 auto s2 = detail::posix_stat(p2.native(), st2, &ec2); 1064 if (!exists(s2)) 1065 return err.report(errc::not_supported); 1066 1067 return detail::stat_equivalent(st1, st2); 1068 } 1069 1070 uintmax_t __file_size(const path& p, error_code* ec) { 1071 ErrorHandler<uintmax_t> err("file_size", ec, &p); 1072 1073 error_code m_ec; 1074 StatT st; 1075 file_status fst = detail::posix_stat(p, st, &m_ec); 1076 if (!exists(fst) || !is_regular_file(fst)) { 1077 errc error_kind = 1078 is_directory(fst) ? errc::is_a_directory : errc::not_supported; 1079 if (!m_ec) 1080 m_ec = make_error_code(error_kind); 1081 return err.report(m_ec); 1082 } 1083 // is_regular_file(p) == true 1084 return static_cast<uintmax_t>(st.st_size); 1085 } 1086 1087 uintmax_t __hard_link_count(const path& p, error_code* ec) { 1088 ErrorHandler<uintmax_t> err("hard_link_count", ec, &p); 1089 1090 error_code m_ec; 1091 StatT st; 1092 detail::posix_stat(p, st, &m_ec); 1093 if (m_ec) 1094 return err.report(m_ec); 1095 return static_cast<uintmax_t>(st.st_nlink); 1096 } 1097 1098 bool __fs_is_empty(const path& p, error_code* ec) { 1099 ErrorHandler<bool> err("is_empty", ec, &p); 1100 1101 error_code m_ec; 1102 StatT pst; 1103 auto st = detail::posix_stat(p, pst, &m_ec); 1104 if (m_ec) 1105 return err.report(m_ec); 1106 else if (!is_directory(st) && !is_regular_file(st)) 1107 return err.report(errc::not_supported); 1108 else if (is_directory(st)) { 1109 auto it = ec ? directory_iterator(p, *ec) : directory_iterator(p); 1110 if (ec && *ec) 1111 return false; 1112 return it == directory_iterator{}; 1113 } else if (is_regular_file(st)) 1114 return static_cast<uintmax_t>(pst.st_size) == 0; 1115 1116 _LIBCPP_UNREACHABLE(); 1117 } 1118 1119 static file_time_type __extract_last_write_time(const path& p, const StatT& st, 1120 error_code* ec) { 1121 using detail::fs_time; 1122 ErrorHandler<file_time_type> err("last_write_time", ec, &p); 1123 1124 auto ts = detail::extract_mtime(st); 1125 if (!fs_time::is_representable(ts)) 1126 return err.report(errc::value_too_large); 1127 1128 return fs_time::convert_from_timespec(ts); 1129 } 1130 1131 file_time_type __last_write_time(const path& p, error_code* ec) { 1132 using namespace chrono; 1133 ErrorHandler<file_time_type> err("last_write_time", ec, &p); 1134 1135 error_code m_ec; 1136 StatT st; 1137 detail::posix_stat(p, st, &m_ec); 1138 if (m_ec) 1139 return err.report(m_ec); 1140 return __extract_last_write_time(p, st, ec); 1141 } 1142 1143 void __last_write_time(const path& p, file_time_type new_time, error_code* ec) { 1144 using detail::fs_time; 1145 ErrorHandler<void> err("last_write_time", ec, &p); 1146 1147 #if defined(_LIBCPP_WIN32API) 1148 TimeSpec ts; 1149 if (!fs_time::convert_to_timespec(ts, new_time)) 1150 return err.report(errc::value_too_large); 1151 detail::WinHandle h(p.c_str(), FILE_WRITE_ATTRIBUTES, 0); 1152 if (!h) 1153 return err.report(detail::make_windows_error(GetLastError())); 1154 FILETIME last_write = timespec_to_filetime(ts); 1155 if (!SetFileTime(h, nullptr, nullptr, &last_write)) 1156 return err.report(detail::make_windows_error(GetLastError())); 1157 #else 1158 error_code m_ec; 1159 array<TimeSpec, 2> tbuf; 1160 #if !defined(_LIBCPP_USE_UTIMENSAT) 1161 // This implementation has a race condition between determining the 1162 // last access time and attempting to set it to the same value using 1163 // ::utimes 1164 StatT st; 1165 file_status fst = detail::posix_stat(p, st, &m_ec); 1166 if (m_ec) 1167 return err.report(m_ec); 1168 tbuf[0] = detail::extract_atime(st); 1169 #else 1170 tbuf[0].tv_sec = 0; 1171 tbuf[0].tv_nsec = UTIME_OMIT; 1172 #endif 1173 if (!fs_time::convert_to_timespec(tbuf[1], new_time)) 1174 return err.report(errc::value_too_large); 1175 1176 detail::set_file_times(p, tbuf, m_ec); 1177 if (m_ec) 1178 return err.report(m_ec); 1179 #endif 1180 } 1181 1182 void __permissions(const path& p, perms prms, perm_options opts, 1183 error_code* ec) { 1184 ErrorHandler<void> err("permissions", ec, &p); 1185 1186 auto has_opt = [&](perm_options o) { return bool(o & opts); }; 1187 const bool resolve_symlinks = !has_opt(perm_options::nofollow); 1188 const bool add_perms = has_opt(perm_options::add); 1189 const bool remove_perms = has_opt(perm_options::remove); 1190 _LIBCPP_ASSERT( 1191 (add_perms + remove_perms + has_opt(perm_options::replace)) == 1, 1192 "One and only one of the perm_options constants replace, add, or remove " 1193 "is present in opts"); 1194 1195 bool set_sym_perms = false; 1196 prms &= perms::mask; 1197 if (!resolve_symlinks || (add_perms || remove_perms)) { 1198 error_code m_ec; 1199 file_status st = resolve_symlinks ? detail::posix_stat(p, &m_ec) 1200 : detail::posix_lstat(p, &m_ec); 1201 set_sym_perms = is_symlink(st); 1202 if (m_ec) 1203 return err.report(m_ec); 1204 _LIBCPP_ASSERT(st.permissions() != perms::unknown, 1205 "Permissions unexpectedly unknown"); 1206 if (add_perms) 1207 prms |= st.permissions(); 1208 else if (remove_perms) 1209 prms = st.permissions() & ~prms; 1210 } 1211 const auto real_perms = static_cast<detail::ModeT>(prms & perms::mask); 1212 1213 #if defined(AT_SYMLINK_NOFOLLOW) && defined(AT_FDCWD) 1214 const int flags = set_sym_perms ? AT_SYMLINK_NOFOLLOW : 0; 1215 if (detail::fchmodat(AT_FDCWD, p.c_str(), real_perms, flags) == -1) { 1216 return err.report(capture_errno()); 1217 } 1218 #else 1219 if (set_sym_perms) 1220 return err.report(errc::operation_not_supported); 1221 if (::chmod(p.c_str(), real_perms) == -1) { 1222 return err.report(capture_errno()); 1223 } 1224 #endif 1225 } 1226 1227 path __read_symlink(const path& p, error_code* ec) { 1228 ErrorHandler<path> err("read_symlink", ec, &p); 1229 1230 #if defined(PATH_MAX) || defined(MAX_SYMLINK_SIZE) 1231 struct NullDeleter { void operator()(void*) const {} }; 1232 #ifdef MAX_SYMLINK_SIZE 1233 const size_t size = MAX_SYMLINK_SIZE + 1; 1234 #else 1235 const size_t size = PATH_MAX + 1; 1236 #endif 1237 path::value_type stack_buff[size]; 1238 auto buff = std::unique_ptr<path::value_type[], NullDeleter>(stack_buff); 1239 #else 1240 StatT sb; 1241 if (detail::lstat(p.c_str(), &sb) == -1) { 1242 return err.report(capture_errno()); 1243 } 1244 const size_t size = sb.st_size + 1; 1245 auto buff = unique_ptr<path::value_type[]>(new path::value_type[size]); 1246 #endif 1247 detail::SSizeT ret; 1248 if ((ret = detail::readlink(p.c_str(), buff.get(), size)) == -1) 1249 return err.report(capture_errno()); 1250 _LIBCPP_ASSERT(ret > 0, "TODO"); 1251 if (static_cast<size_t>(ret) >= size) 1252 return err.report(errc::value_too_large); 1253 buff[ret] = 0; 1254 return {buff.get()}; 1255 } 1256 1257 bool __remove(const path& p, error_code* ec) { 1258 ErrorHandler<bool> err("remove", ec, &p); 1259 if (detail::remove(p.c_str()) == -1) { 1260 if (errno != ENOENT) 1261 err.report(capture_errno()); 1262 return false; 1263 } 1264 return true; 1265 } 1266 1267 namespace { 1268 1269 uintmax_t remove_all_impl(path const& p, error_code& ec) { 1270 const auto npos = static_cast<uintmax_t>(-1); 1271 const file_status st = __symlink_status(p, &ec); 1272 if (ec) 1273 return npos; 1274 uintmax_t count = 1; 1275 if (is_directory(st)) { 1276 for (directory_iterator it(p, ec); !ec && it != directory_iterator(); 1277 it.increment(ec)) { 1278 auto other_count = remove_all_impl(it->path(), ec); 1279 if (ec) 1280 return npos; 1281 count += other_count; 1282 } 1283 if (ec) 1284 return npos; 1285 } 1286 if (!__remove(p, &ec)) 1287 return npos; 1288 return count; 1289 } 1290 1291 } // end namespace 1292 1293 uintmax_t __remove_all(const path& p, error_code* ec) { 1294 ErrorHandler<uintmax_t> err("remove_all", ec, &p); 1295 1296 error_code mec; 1297 auto count = remove_all_impl(p, mec); 1298 if (mec) { 1299 if (mec == errc::no_such_file_or_directory) 1300 return 0; 1301 return err.report(mec); 1302 } 1303 return count; 1304 } 1305 1306 void __rename(const path& from, const path& to, error_code* ec) { 1307 ErrorHandler<void> err("rename", ec, &from, &to); 1308 if (detail::rename(from.c_str(), to.c_str()) == -1) 1309 err.report(capture_errno()); 1310 } 1311 1312 void __resize_file(const path& p, uintmax_t size, error_code* ec) { 1313 ErrorHandler<void> err("resize_file", ec, &p); 1314 if (detail::truncate(p.c_str(), static_cast< ::off_t>(size)) == -1) 1315 return err.report(capture_errno()); 1316 } 1317 1318 space_info __space(const path& p, error_code* ec) { 1319 ErrorHandler<void> err("space", ec, &p); 1320 space_info si; 1321 detail::StatVFS m_svfs = {}; 1322 if (detail::statvfs(p.c_str(), &m_svfs) == -1) { 1323 err.report(capture_errno()); 1324 si.capacity = si.free = si.available = static_cast<uintmax_t>(-1); 1325 return si; 1326 } 1327 // Multiply with overflow checking. 1328 auto do_mult = [&](uintmax_t& out, uintmax_t other) { 1329 out = other * m_svfs.f_frsize; 1330 if (other == 0 || out / other != m_svfs.f_frsize) 1331 out = static_cast<uintmax_t>(-1); 1332 }; 1333 do_mult(si.capacity, m_svfs.f_blocks); 1334 do_mult(si.free, m_svfs.f_bfree); 1335 do_mult(si.available, m_svfs.f_bavail); 1336 return si; 1337 } 1338 1339 file_status __status(const path& p, error_code* ec) { 1340 return detail::posix_stat(p, ec); 1341 } 1342 1343 file_status __symlink_status(const path& p, error_code* ec) { 1344 return detail::posix_lstat(p, ec); 1345 } 1346 1347 path __temp_directory_path(error_code* ec) { 1348 ErrorHandler<path> err("temp_directory_path", ec); 1349 1350 #if defined(_LIBCPP_WIN32API) 1351 wchar_t buf[MAX_PATH]; 1352 DWORD retval = GetTempPathW(MAX_PATH, buf); 1353 if (!retval) 1354 return err.report(detail::make_windows_error(GetLastError())); 1355 if (retval > MAX_PATH) 1356 return err.report(errc::filename_too_long); 1357 // GetTempPathW returns a path with a trailing slash, which we 1358 // shouldn't include for consistency. 1359 if (buf[retval-1] == L'\\') 1360 buf[retval-1] = L'\0'; 1361 path p(buf); 1362 #else 1363 const char* env_paths[] = {"TMPDIR", "TMP", "TEMP", "TEMPDIR"}; 1364 const char* ret = nullptr; 1365 1366 for (auto& ep : env_paths) 1367 if ((ret = getenv(ep))) 1368 break; 1369 if (ret == nullptr) 1370 ret = "/tmp"; 1371 1372 path p(ret); 1373 #endif 1374 error_code m_ec; 1375 file_status st = detail::posix_stat(p, &m_ec); 1376 if (!status_known(st)) 1377 return err.report(m_ec, "cannot access path \"" PS_FMT "\"", p); 1378 1379 if (!exists(st) || !is_directory(st)) 1380 return err.report(errc::not_a_directory, "path \"" PS_FMT "\" is not a directory", 1381 p); 1382 1383 return p; 1384 } 1385 1386 path __weakly_canonical(const path& p, error_code* ec) { 1387 ErrorHandler<path> err("weakly_canonical", ec, &p); 1388 1389 if (p.empty()) 1390 return __canonical("", ec); 1391 1392 path result; 1393 path tmp; 1394 tmp.__reserve(p.native().size()); 1395 auto PP = PathParser::CreateEnd(p.native()); 1396 --PP; 1397 vector<string_view_t> DNEParts; 1398 1399 while (PP.State != PathParser::PS_BeforeBegin) { 1400 tmp.assign(createView(p.native().data(), &PP.RawEntry.back())); 1401 error_code m_ec; 1402 file_status st = __status(tmp, &m_ec); 1403 if (!status_known(st)) { 1404 return err.report(m_ec); 1405 } else if (exists(st)) { 1406 result = __canonical(tmp, ec); 1407 break; 1408 } 1409 DNEParts.push_back(*PP); 1410 --PP; 1411 } 1412 if (PP.State == PathParser::PS_BeforeBegin) 1413 result = __canonical("", ec); 1414 if (ec) 1415 ec->clear(); 1416 if (DNEParts.empty()) 1417 return result; 1418 for (auto It = DNEParts.rbegin(); It != DNEParts.rend(); ++It) 1419 result /= *It; 1420 return result.lexically_normal(); 1421 } 1422 1423 /////////////////////////////////////////////////////////////////////////////// 1424 // path definitions 1425 /////////////////////////////////////////////////////////////////////////////// 1426 1427 constexpr path::value_type path::preferred_separator; 1428 1429 path& path::replace_extension(path const& replacement) { 1430 path p = extension(); 1431 if (not p.empty()) { 1432 __pn_.erase(__pn_.size() - p.native().size()); 1433 } 1434 if (!replacement.empty()) { 1435 if (replacement.native()[0] != '.') { 1436 __pn_ += PS("."); 1437 } 1438 __pn_.append(replacement.__pn_); 1439 } 1440 return *this; 1441 } 1442 1443 /////////////////////////////////////////////////////////////////////////////// 1444 // path.decompose 1445 1446 string_view_t path::__root_name() const { 1447 auto PP = PathParser::CreateBegin(__pn_); 1448 if (PP.State == PathParser::PS_InRootName) 1449 return *PP; 1450 return {}; 1451 } 1452 1453 string_view_t path::__root_directory() const { 1454 auto PP = PathParser::CreateBegin(__pn_); 1455 if (PP.State == PathParser::PS_InRootName) 1456 ++PP; 1457 if (PP.State == PathParser::PS_InRootDir) 1458 return *PP; 1459 return {}; 1460 } 1461 1462 string_view_t path::__root_path_raw() const { 1463 auto PP = PathParser::CreateBegin(__pn_); 1464 if (PP.State == PathParser::PS_InRootName) { 1465 auto NextCh = PP.peek(); 1466 if (NextCh && isSeparator(*NextCh)) { 1467 ++PP; 1468 return createView(__pn_.data(), &PP.RawEntry.back()); 1469 } 1470 return PP.RawEntry; 1471 } 1472 if (PP.State == PathParser::PS_InRootDir) 1473 return *PP; 1474 return {}; 1475 } 1476 1477 static bool ConsumeRootName(PathParser *PP) { 1478 static_assert(PathParser::PS_BeforeBegin == 1 && 1479 PathParser::PS_InRootName == 2, 1480 "Values for enums are incorrect"); 1481 while (PP->State <= PathParser::PS_InRootName) 1482 ++(*PP); 1483 return PP->State == PathParser::PS_AtEnd; 1484 } 1485 1486 static bool ConsumeRootDir(PathParser* PP) { 1487 static_assert(PathParser::PS_BeforeBegin == 1 && 1488 PathParser::PS_InRootName == 2 && 1489 PathParser::PS_InRootDir == 3, "Values for enums are incorrect"); 1490 while (PP->State <= PathParser::PS_InRootDir) 1491 ++(*PP); 1492 return PP->State == PathParser::PS_AtEnd; 1493 } 1494 1495 string_view_t path::__relative_path() const { 1496 auto PP = PathParser::CreateBegin(__pn_); 1497 if (ConsumeRootDir(&PP)) 1498 return {}; 1499 return createView(PP.RawEntry.data(), &__pn_.back()); 1500 } 1501 1502 string_view_t path::__parent_path() const { 1503 if (empty()) 1504 return {}; 1505 // Determine if we have a root path but not a relative path. In that case 1506 // return *this. 1507 { 1508 auto PP = PathParser::CreateBegin(__pn_); 1509 if (ConsumeRootDir(&PP)) 1510 return __pn_; 1511 } 1512 // Otherwise remove a single element from the end of the path, and return 1513 // a string representing that path 1514 { 1515 auto PP = PathParser::CreateEnd(__pn_); 1516 --PP; 1517 if (PP.RawEntry.data() == __pn_.data()) 1518 return {}; 1519 --PP; 1520 return createView(__pn_.data(), &PP.RawEntry.back()); 1521 } 1522 } 1523 1524 string_view_t path::__filename() const { 1525 if (empty()) 1526 return {}; 1527 { 1528 PathParser PP = PathParser::CreateBegin(__pn_); 1529 if (ConsumeRootDir(&PP)) 1530 return {}; 1531 } 1532 return *(--PathParser::CreateEnd(__pn_)); 1533 } 1534 1535 string_view_t path::__stem() const { 1536 return parser::separate_filename(__filename()).first; 1537 } 1538 1539 string_view_t path::__extension() const { 1540 return parser::separate_filename(__filename()).second; 1541 } 1542 1543 //////////////////////////////////////////////////////////////////////////// 1544 // path.gen 1545 1546 enum PathPartKind : unsigned char { 1547 PK_None, 1548 PK_RootSep, 1549 PK_Filename, 1550 PK_Dot, 1551 PK_DotDot, 1552 PK_TrailingSep 1553 }; 1554 1555 static PathPartKind ClassifyPathPart(string_view_t Part) { 1556 if (Part.empty()) 1557 return PK_TrailingSep; 1558 if (Part == PS(".")) 1559 return PK_Dot; 1560 if (Part == PS("..")) 1561 return PK_DotDot; 1562 if (Part == PS("/")) 1563 return PK_RootSep; 1564 #if defined(_LIBCPP_WIN32API) 1565 if (Part == PS("\\")) 1566 return PK_RootSep; 1567 #endif 1568 return PK_Filename; 1569 } 1570 1571 path path::lexically_normal() const { 1572 if (__pn_.empty()) 1573 return *this; 1574 1575 using PartKindPair = pair<string_view_t, PathPartKind>; 1576 vector<PartKindPair> Parts; 1577 // Guess as to how many elements the path has to avoid reallocating. 1578 Parts.reserve(32); 1579 1580 // Track the total size of the parts as we collect them. This allows the 1581 // resulting path to reserve the correct amount of memory. 1582 size_t NewPathSize = 0; 1583 auto AddPart = [&](PathPartKind K, string_view_t P) { 1584 NewPathSize += P.size(); 1585 Parts.emplace_back(P, K); 1586 }; 1587 auto LastPartKind = [&]() { 1588 if (Parts.empty()) 1589 return PK_None; 1590 return Parts.back().second; 1591 }; 1592 1593 bool MaybeNeedTrailingSep = false; 1594 // Build a stack containing the remaining elements of the path, popping off 1595 // elements which occur before a '..' entry. 1596 for (auto PP = PathParser::CreateBegin(__pn_); PP; ++PP) { 1597 auto Part = *PP; 1598 PathPartKind Kind = ClassifyPathPart(Part); 1599 switch (Kind) { 1600 case PK_Filename: 1601 case PK_RootSep: { 1602 // Add all non-dot and non-dot-dot elements to the stack of elements. 1603 AddPart(Kind, Part); 1604 MaybeNeedTrailingSep = false; 1605 break; 1606 } 1607 case PK_DotDot: { 1608 // Only push a ".." element if there are no elements preceding the "..", 1609 // or if the preceding element is itself "..". 1610 auto LastKind = LastPartKind(); 1611 if (LastKind == PK_Filename) { 1612 NewPathSize -= Parts.back().first.size(); 1613 Parts.pop_back(); 1614 } else if (LastKind != PK_RootSep) 1615 AddPart(PK_DotDot, PS("..")); 1616 MaybeNeedTrailingSep = LastKind == PK_Filename; 1617 break; 1618 } 1619 case PK_Dot: 1620 case PK_TrailingSep: { 1621 MaybeNeedTrailingSep = true; 1622 break; 1623 } 1624 case PK_None: 1625 _LIBCPP_UNREACHABLE(); 1626 } 1627 } 1628 // [fs.path.generic]p6.8: If the path is empty, add a dot. 1629 if (Parts.empty()) 1630 return PS("."); 1631 1632 // [fs.path.generic]p6.7: If the last filename is dot-dot, remove any 1633 // trailing directory-separator. 1634 bool NeedTrailingSep = MaybeNeedTrailingSep && LastPartKind() == PK_Filename; 1635 1636 path Result; 1637 Result.__pn_.reserve(Parts.size() + NewPathSize + NeedTrailingSep); 1638 for (auto& PK : Parts) 1639 Result /= PK.first; 1640 1641 if (NeedTrailingSep) 1642 Result /= PS(""); 1643 1644 return Result; 1645 } 1646 1647 static int DetermineLexicalElementCount(PathParser PP) { 1648 int Count = 0; 1649 for (; PP; ++PP) { 1650 auto Elem = *PP; 1651 if (Elem == PS("..")) 1652 --Count; 1653 else if (Elem != PS(".") && Elem != PS("")) 1654 ++Count; 1655 } 1656 return Count; 1657 } 1658 1659 path path::lexically_relative(const path& base) const { 1660 { // perform root-name/root-directory mismatch checks 1661 auto PP = PathParser::CreateBegin(__pn_); 1662 auto PPBase = PathParser::CreateBegin(base.__pn_); 1663 auto CheckIterMismatchAtBase = [&]() { 1664 return PP.State != PPBase.State && 1665 (PP.inRootPath() || PPBase.inRootPath()); 1666 }; 1667 if (PP.inRootName() && PPBase.inRootName()) { 1668 if (*PP != *PPBase) 1669 return {}; 1670 } else if (CheckIterMismatchAtBase()) 1671 return {}; 1672 1673 if (PP.inRootPath()) 1674 ++PP; 1675 if (PPBase.inRootPath()) 1676 ++PPBase; 1677 if (CheckIterMismatchAtBase()) 1678 return {}; 1679 } 1680 1681 // Find the first mismatching element 1682 auto PP = PathParser::CreateBegin(__pn_); 1683 auto PPBase = PathParser::CreateBegin(base.__pn_); 1684 while (PP && PPBase && PP.State == PPBase.State && *PP == *PPBase) { 1685 ++PP; 1686 ++PPBase; 1687 } 1688 1689 // If there is no mismatch, return ".". 1690 if (!PP && !PPBase) 1691 return "."; 1692 1693 // Otherwise, determine the number of elements, 'n', which are not dot or 1694 // dot-dot minus the number of dot-dot elements. 1695 int ElemCount = DetermineLexicalElementCount(PPBase); 1696 if (ElemCount < 0) 1697 return {}; 1698 1699 // if n == 0 and (a == end() || a->empty()), returns path("."); otherwise 1700 if (ElemCount == 0 && (PP.atEnd() || *PP == PS(""))) 1701 return PS("."); 1702 1703 // return a path constructed with 'n' dot-dot elements, followed by the the 1704 // elements of '*this' after the mismatch. 1705 path Result; 1706 // FIXME: Reserve enough room in Result that it won't have to re-allocate. 1707 while (ElemCount--) 1708 Result /= PS(".."); 1709 for (; PP; ++PP) 1710 Result /= *PP; 1711 return Result; 1712 } 1713 1714 //////////////////////////////////////////////////////////////////////////// 1715 // path.comparisons 1716 static int CompareRootName(PathParser *LHS, PathParser *RHS) { 1717 if (!LHS->inRootName() && !RHS->inRootName()) 1718 return 0; 1719 1720 auto GetRootName = [](PathParser *Parser) -> string_view_t { 1721 return Parser->inRootName() ? **Parser : PS(""); 1722 }; 1723 int res = GetRootName(LHS).compare(GetRootName(RHS)); 1724 ConsumeRootName(LHS); 1725 ConsumeRootName(RHS); 1726 return res; 1727 } 1728 1729 static int CompareRootDir(PathParser *LHS, PathParser *RHS) { 1730 if (!LHS->inRootDir() && RHS->inRootDir()) 1731 return -1; 1732 else if (LHS->inRootDir() && !RHS->inRootDir()) 1733 return 1; 1734 else { 1735 ConsumeRootDir(LHS); 1736 ConsumeRootDir(RHS); 1737 return 0; 1738 } 1739 } 1740 1741 static int CompareRelative(PathParser *LHSPtr, PathParser *RHSPtr) { 1742 auto &LHS = *LHSPtr; 1743 auto &RHS = *RHSPtr; 1744 1745 int res; 1746 while (LHS && RHS) { 1747 if ((res = (*LHS).compare(*RHS)) != 0) 1748 return res; 1749 ++LHS; 1750 ++RHS; 1751 } 1752 return 0; 1753 } 1754 1755 static int CompareEndState(PathParser *LHS, PathParser *RHS) { 1756 if (LHS->atEnd() && !RHS->atEnd()) 1757 return -1; 1758 else if (!LHS->atEnd() && RHS->atEnd()) 1759 return 1; 1760 return 0; 1761 } 1762 1763 int path::__compare(string_view_t __s) const { 1764 auto LHS = PathParser::CreateBegin(__pn_); 1765 auto RHS = PathParser::CreateBegin(__s); 1766 int res; 1767 1768 if ((res = CompareRootName(&LHS, &RHS)) != 0) 1769 return res; 1770 1771 if ((res = CompareRootDir(&LHS, &RHS)) != 0) 1772 return res; 1773 1774 if ((res = CompareRelative(&LHS, &RHS)) != 0) 1775 return res; 1776 1777 return CompareEndState(&LHS, &RHS); 1778 } 1779 1780 //////////////////////////////////////////////////////////////////////////// 1781 // path.nonmembers 1782 size_t hash_value(const path& __p) noexcept { 1783 auto PP = PathParser::CreateBegin(__p.native()); 1784 size_t hash_value = 0; 1785 hash<string_view_t> hasher; 1786 while (PP) { 1787 hash_value = __hash_combine(hash_value, hasher(*PP)); 1788 ++PP; 1789 } 1790 return hash_value; 1791 } 1792 1793 //////////////////////////////////////////////////////////////////////////// 1794 // path.itr 1795 path::iterator path::begin() const { 1796 auto PP = PathParser::CreateBegin(__pn_); 1797 iterator it; 1798 it.__path_ptr_ = this; 1799 it.__state_ = static_cast<path::iterator::_ParserState>(PP.State); 1800 it.__entry_ = PP.RawEntry; 1801 it.__stashed_elem_.__assign_view(*PP); 1802 return it; 1803 } 1804 1805 path::iterator path::end() const { 1806 iterator it{}; 1807 it.__state_ = path::iterator::_AtEnd; 1808 it.__path_ptr_ = this; 1809 return it; 1810 } 1811 1812 path::iterator& path::iterator::__increment() { 1813 PathParser PP(__path_ptr_->native(), __entry_, __state_); 1814 ++PP; 1815 __state_ = static_cast<_ParserState>(PP.State); 1816 __entry_ = PP.RawEntry; 1817 __stashed_elem_.__assign_view(*PP); 1818 return *this; 1819 } 1820 1821 path::iterator& path::iterator::__decrement() { 1822 PathParser PP(__path_ptr_->native(), __entry_, __state_); 1823 --PP; 1824 __state_ = static_cast<_ParserState>(PP.State); 1825 __entry_ = PP.RawEntry; 1826 __stashed_elem_.__assign_view(*PP); 1827 return *this; 1828 } 1829 1830 #if defined(_LIBCPP_WIN32API) 1831 //////////////////////////////////////////////////////////////////////////// 1832 // Windows path conversions 1833 size_t __wide_to_char(const wstring &str, char *out, size_t outlen) { 1834 if (str.empty()) 1835 return 0; 1836 ErrorHandler<size_t> err("__wide_to_char", nullptr); 1837 UINT codepage = AreFileApisANSI() ? CP_ACP : CP_OEMCP; 1838 BOOL used_default = FALSE; 1839 int ret = WideCharToMultiByte(codepage, 0, str.data(), str.size(), out, 1840 outlen, nullptr, &used_default); 1841 if (ret <= 0 || used_default) 1842 return err.report(errc::illegal_byte_sequence); 1843 return ret; 1844 } 1845 1846 size_t __char_to_wide(const string &str, wchar_t *out, size_t outlen) { 1847 if (str.empty()) 1848 return 0; 1849 ErrorHandler<size_t> err("__char_to_wide", nullptr); 1850 UINT codepage = AreFileApisANSI() ? CP_ACP : CP_OEMCP; 1851 int ret = MultiByteToWideChar(codepage, MB_ERR_INVALID_CHARS, str.data(), 1852 str.size(), out, outlen); 1853 if (ret <= 0) 1854 return err.report(errc::illegal_byte_sequence); 1855 return ret; 1856 } 1857 #endif 1858 1859 1860 /////////////////////////////////////////////////////////////////////////////// 1861 // directory entry definitions 1862 /////////////////////////////////////////////////////////////////////////////// 1863 1864 error_code directory_entry::__do_refresh() noexcept { 1865 __data_.__reset(); 1866 error_code failure_ec; 1867 1868 StatT full_st; 1869 file_status st = detail::posix_lstat(__p_, full_st, &failure_ec); 1870 if (!status_known(st)) { 1871 __data_.__reset(); 1872 return failure_ec; 1873 } 1874 1875 if (!_VSTD_FS::exists(st) || !_VSTD_FS::is_symlink(st)) { 1876 __data_.__cache_type_ = directory_entry::_RefreshNonSymlink; 1877 __data_.__type_ = st.type(); 1878 __data_.__non_sym_perms_ = st.permissions(); 1879 } else { // we have a symlink 1880 __data_.__sym_perms_ = st.permissions(); 1881 // Get the information about the linked entity. 1882 // Ignore errors from stat, since we don't want errors regarding symlink 1883 // resolution to be reported to the user. 1884 error_code ignored_ec; 1885 st = detail::posix_stat(__p_, full_st, &ignored_ec); 1886 1887 __data_.__type_ = st.type(); 1888 __data_.__non_sym_perms_ = st.permissions(); 1889 1890 // If we failed to resolve the link, then only partially populate the 1891 // cache. 1892 if (!status_known(st)) { 1893 __data_.__cache_type_ = directory_entry::_RefreshSymlinkUnresolved; 1894 return error_code{}; 1895 } 1896 // Otherwise, we resolved the link, potentially as not existing. 1897 // That's OK. 1898 __data_.__cache_type_ = directory_entry::_RefreshSymlink; 1899 } 1900 1901 if (_VSTD_FS::is_regular_file(st)) 1902 __data_.__size_ = static_cast<uintmax_t>(full_st.st_size); 1903 1904 if (_VSTD_FS::exists(st)) { 1905 __data_.__nlink_ = static_cast<uintmax_t>(full_st.st_nlink); 1906 1907 // Attempt to extract the mtime, and fail if it's not representable using 1908 // file_time_type. For now we ignore the error, as we'll report it when 1909 // the value is actually used. 1910 error_code ignored_ec; 1911 __data_.__write_time_ = 1912 __extract_last_write_time(__p_, full_st, &ignored_ec); 1913 } 1914 1915 return failure_ec; 1916 } 1917 1918 _LIBCPP_END_NAMESPACE_FILESYSTEM 1919