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