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