Add basic console monitor and implement monitor support

1 files changed, 10 insertions, 1 deletions

diff --git a/src/buffer.cc b/src/buffer.cc
index d0c5fbb..4bde195 100644
--- a/src/buffer.cc
+++ b/src/buffer.cc
@@ -12,7 +12,8 @@ namespace {
 class BufferImpl : public Buffer {
 public:
   BufferImpl(size_t capacity, size_t min_avail)
-    : capacity_(capacity), min_avail_(min_avail) {
+    : capacity_(capacity), min_avail_(
+        std::max(min_avail, static_cast<size_t>(1))) {
     data_ = capacity_ > 0 ?
       reinterpret_cast<char*>(malloc(capacity_)) : nullptr;
     end_ = data_;
@@ -117,3 +118,11 @@ void Buffer::write(void const* data, size_t size) {
   }
 }
 
+void Buffer::clear() {
+  while (true) {
+    size_t avail;
+    read_ptr(&avail);
+    if (avail == 0) return;
+    consume(avail);
+  }
+}