We we try to write an empty buffer, replace it in the buffer cache.

hobuinc · Oct 19, 2021 · ec62df2 · ec62df2
1 parent a51906a
commit ec62df2
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/epf/Cell.cpp b/epf/Cell.cpp
@@ -41,6 +41,8 @@ void Cell::write()
     size_t size = m_pos - m_buf->data();
     if (size)
         m_writer->enqueue(m_key, std::move(m_buf), size);
+    else
+        m_writer->replace(std::move(m_buf));
 }
 
 void Cell::advance()

diff --git a/epf/Writer.cpp b/epf/Writer.cpp
@@ -78,6 +78,12 @@ void Writer::enqueue(const VoxelKey& key, DataVecPtr data, size_t dataSize)
     m_available.notify_one();
 }
 
+void Writer::replace(DataVecPtr data)
+{
+    std::lock_guard<std::mutex> lock(m_mutex);
+    m_bufferCache.replace(std::move(data));
+}
+
 void Writer::stop()
 {
     {

diff --git a/epf/Writer.hpp b/epf/Writer.hpp
@@ -40,6 +40,7 @@ class Writer
 public:
     Writer(const std::string& directory, int numThreads, size_t pointSize);
 
+    void replace(DataVecPtr data);
     void enqueue(const VoxelKey& key, DataVecPtr data, size_t dataSize);
     void stop();
     const Totals& totals()