/Users/eugenesiegel/btc/bitcoin/src/streams.cpp
| Line | Count | Source (jump to first uncovered line) | 
| 1 |  | // Copyright (c) 2009-present The Bitcoin Core developers | 
| 2 |  | // Distributed under the MIT software license, see the accompanying | 
| 3 |  | // file COPYING or https://opensource.org/license/mit/. | 
| 4 |  |  | 
| 5 |  | #include <memusage.h> | 
| 6 |  | #include <span.h> | 
| 7 |  | #include <streams.h> | 
| 8 |  | #include <util/fs_helpers.h> | 
| 9 |  | #include <util/obfuscation.h> | 
| 10 |  |  | 
| 11 |  | #include <array> | 
| 12 |  |  | 
| 13 | 1.07M | AutoFile::AutoFile(std::FILE* file, const Obfuscation& obfuscation) : m_file{file}, m_obfuscation{obfuscation} | 
| 14 | 1.07M | { | 
| 15 | 1.07M |     if (!IsNull()) { | 
| 16 | 1.07M |         auto pos{std::ftell(m_file)}; | 
| 17 | 1.07M |         if (pos >= 0) m_position = pos; | 
| 18 | 1.07M |     } | 
| 19 | 1.07M | } | 
| 20 |  |  | 
| 21 |  | std::size_t AutoFile::detail_fread(std::span<std::byte> dst) | 
| 22 | 2.20M | { | 
| 23 | 2.20M |     if (!m_file) throw std::ios_base::failure("AutoFile::read: file handle is nullptr")0; | 
| 24 | 2.20M |     const size_t ret = std::fread(dst.data(), 1, dst.size(), m_file); | 
| 25 | 2.20M |     if (m_obfuscation) { | 
| 26 | 2.15M |         if (!m_position) throw std::ios_base::failure("AutoFile::read: position unknown")0; | 
| 27 | 2.15M |         m_obfuscation(dst.subspan(0, ret), *m_position); | 
| 28 | 2.15M |     } | 
| 29 | 2.20M |     if (m_position) *m_position += ret; | 
| 30 | 2.20M |     return ret; | 
| 31 | 2.20M | } | 
| 32 |  |  | 
| 33 |  | void AutoFile::seek(int64_t offset, int origin) | 
| 34 | 0 | { | 
| 35 | 0 |     if (IsNull()) { | 
| 36 | 0 |         throw std::ios_base::failure("AutoFile::seek: file handle is nullptr"); | 
| 37 | 0 |     } | 
| 38 | 0 |     if (std::fseek(m_file, offset, origin) != 0) { | 
| 39 | 0 |         throw std::ios_base::failure(feof() ? "AutoFile::seek: end of file" : "AutoFile::seek: fseek failed"); | 
| 40 | 0 |     } | 
| 41 | 0 |     if (origin == SEEK_SET) { | 
| 42 | 0 |         m_position = offset; | 
| 43 | 0 |     } else if (origin == SEEK_CUR && m_position.has_value()) { | 
| 44 | 0 |         *m_position += offset; | 
| 45 | 0 |     } else { | 
| 46 | 0 |         int64_t r{std::ftell(m_file)}; | 
| 47 | 0 |         if (r < 0) { | 
| 48 | 0 |             throw std::ios_base::failure("AutoFile::seek: ftell failed"); | 
| 49 | 0 |         } | 
| 50 | 0 |         m_position = r; | 
| 51 | 0 |     } | 
| 52 | 0 | } | 
| 53 |  |  | 
| 54 |  | int64_t AutoFile::tell() | 
| 55 | 0 | { | 
| 56 | 0 |     if (!m_position.has_value()) throw std::ios_base::failure("AutoFile::tell: position unknown"); | 
| 57 | 0 |     return *m_position; | 
| 58 | 0 | } | 
| 59 |  |  | 
| 60 |  | void AutoFile::read(std::span<std::byte> dst) | 
| 61 | 1.59M | { | 
| 62 | 1.59M |     if (detail_fread(dst) != dst.size()) { | 
| 63 | 0 |         throw std::ios_base::failure(feof() ? "AutoFile::read: end of file" : "AutoFile::read: fread failed"); | 
| 64 | 0 |     } | 
| 65 | 1.59M | } | 
| 66 |  |  | 
| 67 |  | void AutoFile::ignore(size_t nSize) | 
| 68 | 0 | { | 
| 69 | 0 |     if (!m_file) throw std::ios_base::failure("AutoFile::ignore: file handle is nullptr"); | 
| 70 | 0 |     unsigned char data[4096]; | 
| 71 | 0 |     while (nSize > 0) { | 
| 72 | 0 |         size_t nNow = std::min<size_t>(nSize, sizeof(data)); | 
| 73 | 0 |         if (std::fread(data, 1, nNow, m_file) != nNow) { | 
| 74 | 0 |             throw std::ios_base::failure(feof() ? "AutoFile::ignore: end of file" : "AutoFile::ignore: fread failed"); | 
| 75 | 0 |         } | 
| 76 | 0 |         nSize -= nNow; | 
| 77 | 0 |         if (m_position.has_value()) *m_position += nNow; | 
| 78 | 0 |     } | 
| 79 | 0 | } | 
| 80 |  |  | 
| 81 |  | void AutoFile::write(std::span<const std::byte> src) | 
| 82 | 0 | { | 
| 83 | 0 |     if (!m_file) throw std::ios_base::failure("AutoFile::write: file handle is nullptr"); | 
| 84 | 0 |     if (!m_obfuscation) { | 
| 85 | 0 |         if (std::fwrite(src.data(), 1, src.size(), m_file) != src.size()) { | 
| 86 | 0 |             throw std::ios_base::failure("AutoFile::write: write failed"); | 
| 87 | 0 |         } | 
| 88 | 0 |         m_was_written = true; | 
| 89 | 0 |         if (m_position.has_value()) *m_position += src.size(); | 
| 90 | 0 |     } else { | 
| 91 | 0 |         std::array<std::byte, 4096> buf; | 
| 92 | 0 |         while (src.size()) { | 
| 93 | 0 |             auto buf_now{std::span{buf}.first(std::min<size_t>(src.size(), buf.size()))}; | 
| 94 | 0 |             std::copy_n(src.begin(), buf_now.size(), buf_now.begin()); | 
| 95 | 0 |             write_buffer(buf_now); | 
| 96 | 0 |             src = src.subspan(buf_now.size()); | 
| 97 | 0 |         } | 
| 98 | 0 |     } | 
| 99 | 0 | } | 
| 100 |  |  | 
| 101 |  | void AutoFile::write_buffer(std::span<std::byte> src) | 
| 102 | 50.0k | { | 
| 103 | 50.0k |     if (!m_file) throw std::ios_base::failure("AutoFile::write_buffer: file handle is nullptr")0; | 
| 104 | 50.0k |     if (m_obfuscation) { | 
| 105 | 50.0k |         if (!m_position) throw std::ios_base::failure("AutoFile::write_buffer: obfuscation position unknown")0; | 
| 106 | 50.0k |         m_obfuscation(src, *m_position); // obfuscate in-place | 
| 107 | 50.0k |     } | 
| 108 | 50.0k |     if (std::fwrite(src.data(), 1, src.size(), m_file) != src.size()) { | 
| 109 | 0 |         throw std::ios_base::failure("AutoFile::write_buffer: write failed"); | 
| 110 | 0 |     } | 
| 111 | 50.0k |     m_was_written = true; | 
| 112 | 50.0k |     if (m_position) *m_position += src.size(); | 
| 113 | 50.0k | } | 
| 114 |  |  | 
| 115 |  | bool AutoFile::Commit() | 
| 116 | 0 | { | 
| 117 | 0 |     return ::FileCommit(m_file); | 
| 118 | 0 | } | 
| 119 |  |  | 
| 120 |  | bool AutoFile::Truncate(unsigned size) | 
| 121 | 0 | { | 
| 122 | 0 |     m_was_written = true; | 
| 123 | 0 |     return ::TruncateFile(m_file, size); | 
| 124 | 0 | } | 
| 125 |  |  | 
| 126 |  | size_t DataStream::GetMemoryUsage() const noexcept | 
| 127 | 13.1M | { | 
| 128 | 13.1M |     return sizeof(*this) + memusage::DynamicUsage(vch); | 
| 129 | 13.1M | } |