Make sure that replaced buffers are the correct size.

epf/BufferCache.cpp

@@ -32,7 +32,6 @@ DataVecPtr BufferCache::fetch()
         return buf;
     }
 
-    constexpr size_t BufSize = 4096 * 10;
     return DataVecPtr(new DataVec(BufSize));
 }
 
@@ -41,6 +40,8 @@ void BufferCache::replace(DataVecPtr&& buf)
 {
     std::lock_guard<std::mutex> lock(m_mutex);
 
+    //ABELL - Fix this.
+    buf->resize(BufSize);
     m_buffers.push_back(std::move(buf));
 }
 

epf/Cell.hpp

@@ -35,8 +35,6 @@ class Writer;
 class Cell
 {
 public:
-    static constexpr size_t BufSize = 4096 * 10;
-
     Cell(const VoxelKey& key, int pointSize, Writer *writer) :
         m_key(key), m_pointSize(pointSize), m_writer(writer)
     {

epf/Epf.cpp

@@ -174,9 +174,6 @@ void Epf::run(const std::vector<std::string>& options)
         processors.push_back(std::move(fp));
     }
 
-// Enable this when the sampler supports the output.
-/**
-**/
     // Wait for  all the processors to finish and restart.
     m_pool.cycle();
 
@@ -197,6 +194,7 @@ void Epf::run(const std::vector<std::string>& options)
         if (numPoints > MaxPointsPerNode)
         {
             int pointSize = layout->pointSize();
+
             m_pool.add([key, numPoints, pointSize, this]()
             {
                 Reprocessor r(key, numPoints, pointSize, m_outputDir, m_grid, m_writer.get());

epf/EpfTypes.hpp

@@ -34,6 +34,7 @@ using DataVec = std::vector<uint8_t>;
 using DataVecPtr = std::unique_ptr<DataVec>;
 using Totals = std::unordered_map<VoxelKey, size_t>;
 constexpr int MaxPointsPerNode = 100000;
+constexpr int BufSize = 4096 * 10;
 
 struct Error : public std::runtime_error
 {