summaryrefslogtreecommitdiff
path: root/src/line.cc
diff options
context:
space:
mode:
authorJoel Klinghed <the_jk@spawned.biz>2025-09-15 21:15:53 +0200
committerJoel Klinghed <the_jk@spawned.biz>2025-09-15 21:15:53 +0200
commitaa49abdf239bae6065fddd0839ec67a404c9748c (patch)
tree631fbb2df58aa35df3d60c65c037ef74b1807114 /src/line.cc
parentbf41a601fd0447bcf3a2937a595a1cd8ca5c1633 (diff)
Add .clang-format
Make it easier to keep a consistent style
Diffstat (limited to 'src/line.cc')
-rw-r--r--src/line.cc23
1 files changed, 13 insertions, 10 deletions
diff --git a/src/line.cc b/src/line.cc
index 2eeb116..8ee7134 100644
--- a/src/line.cc
+++ b/src/line.cc
@@ -20,16 +20,19 @@ const char kLineTerminators[] = "\r\n";
class ReaderImpl : public Reader {
public:
ReaderImpl(std::unique_ptr<io::Reader> reader, size_t max_len)
- : reader_(std::move(reader)), max_len_(max_len),
+ : reader_(std::move(reader)),
+ max_len_(max_len),
buffer_(std::make_unique_for_overwrite<char[]>(
check::add(max_len, static_cast<size_t>(2)))),
- rptr_(buffer_.get()), wptr_(buffer_.get()), search_(rptr_),
+ rptr_(buffer_.get()),
+ wptr_(buffer_.get()),
+ search_(rptr_),
end_(buffer_.get() + check::add(max_len, static_cast<size_t>(2))) {}
[[nodiscard]] std::expected<std::string_view, ReadError> read() override {
while (true) {
- search_ = std::find_first_of(search_, wptr_,
- kLineTerminators, kLineTerminators + 2);
+ search_ = std::find_first_of(search_, wptr_, kLineTerminators,
+ kLineTerminators + 2);
if (search_ < wptr_) {
if (std::cmp_greater(search_ - rptr_, max_len_)) {
return line(max_len_, 0);
@@ -91,9 +94,11 @@ class ReaderImpl : public Reader {
void make_space_if_needed() {
size_t free = rptr_ - buffer_.get();
- if (free == 0) return;
+ if (free == 0)
+ return;
size_t avail = end_ - wptr_;
- if (avail > 1024) return;
+ if (avail > 1024)
+ return;
memmove(buffer_.get(), rptr_, wptr_ - rptr_);
search_ -= free;
wptr_ -= free;
@@ -119,11 +124,9 @@ class ReaderImpl : public Reader {
} // namespace
-ReadError::ReadError()
- : eof(true) {}
+ReadError::ReadError() : eof(true) {}
-ReadError::ReadError(io::ReadError error)
- : eof(false), io_error(error) {}
+ReadError::ReadError(io::ReadError error) : eof(false), io_error(error) {}
std::unique_ptr<Reader> open(std::unique_ptr<io::Reader> reader,
size_t max_len) {