From 77dda1c0392b33e4242a61bc8196ccb68170da20 Mon Sep 17 00:00:00 2001 From: Martin Date: Sat, 22 Jan 2022 12:28:36 +0100 Subject: [PATCH] Add compression buffer for synchronous compression --- fsimageplugin/CompressedFile.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fsimageplugin/CompressedFile.cpp b/fsimageplugin/CompressedFile.cpp index 69950553..6a486d04 100644 --- a/fsimageplugin/CompressedFile.cpp +++ b/fsimageplugin/CompressedFile.cpp @@ -68,7 +68,7 @@ CompressedFile::CompressedFile( std::string pFilename, int pMode, size_t n_threa blocksize = c_cacheBuffersize; writeHeader(); hotCache.reset(new LRUMemCache(blocksize, c_ncacheItems, n_threads)); - initCompressedBuffers(n_threads); + initCompressedBuffers(n_threads + 1); } if(hotCache.get()) @@ -93,7 +93,7 @@ CompressedFile::CompressedFile(IFile* file, bool openExisting, bool readOnly, si blocksize = c_cacheBuffersize; writeHeader(); hotCache.reset(new LRUMemCache(blocksize, c_ncacheItems, n_threads)); - initCompressedBuffers(n_threads); + initCompressedBuffers(n_threads + 1); } if(hotCache.get()!=nullptr) {