From b4d6df902253637f24647d3db2bc3781d69eec1c Mon Sep 17 00:00:00 2001
From: Joel Klinghed <the_jk@spawned.biz>
Date: Thu, 20 Feb 2025 22:54:56 +0100
Subject: Initial commit

---
 src/ro_buffer.cc | 27 +++++++++++++++++++++++++++
 1 file changed, 27 insertions(+)
 create mode 100644 src/ro_buffer.cc

(limited to 'src/ro_buffer.cc')

diff --git a/src/ro_buffer.cc b/src/ro_buffer.cc
new file mode 100644
index 0000000..a071321
--- /dev/null
+++ b/src/ro_buffer.cc
@@ -0,0 +1,27 @@
+#include "ro_buffer.hh"
+
+#include <algorithm>
+#include <cassert>
+
+size_t RoBuffer::read(void* data, size_t len) {
+  assert(data);
+  if (len == 0)
+    return 0;
+  auto* d = reinterpret_cast<char*>(data);
+  size_t got = 0;
+  while (true) {
+    size_t avail;
+    auto want = len - got;
+    auto* ptr = rbuf(want, avail);
+    if (avail == 0)
+      return got;
+    if (avail >= want) {
+      std::copy_n(ptr, want, d + got);
+      rcommit(want);
+      return len;
+    }
+    std::copy_n(ptr, avail, d + got);
+    rcommit(avail);
+    got += avail;
+  }
+}
-- 
cgit v1.2.3-70-g09d2