Home
last modified time | relevance | path

Searched refs:BufferWorkQueue (Results 1 – 4 of 4) sorted by relevance

/freebsd-12.1/sys/contrib/zstd/contrib/pzstd/
H A DPzstd.cpp273 std::shared_ptr<BufferWorkQueue> in, in compress()
274 std::shared_ptr<BufferWorkQueue> out, in compress()
386 WorkQueue<std::shared_ptr<BufferWorkQueue>>& chunks, in asyncCompressChunks()
402 auto in = std::make_shared<BufferWorkQueue>(); in asyncCompressChunks()
405 auto out = std::make_shared<BufferWorkQueue>(); in asyncCompressChunks()
432 std::shared_ptr<BufferWorkQueue> in, in decompress()
433 std::shared_ptr<BufferWorkQueue> out) { in decompress()
515 auto in = std::make_shared<BufferWorkQueue>(); in asyncDecompressFrames()
518 auto out = std::make_shared<BufferWorkQueue>(); in asyncDecompressFrames()
578 WorkQueue<std::shared_ptr<BufferWorkQueue>>& outs, in writeFile()
[all …]
H A DPzstd.h108 WorkQueue<std::shared_ptr<BufferWorkQueue>>& chunks,
130 WorkQueue<std::shared_ptr<BufferWorkQueue>>& frames,
147 WorkQueue<std::shared_ptr<BufferWorkQueue>>& outs,
/freebsd-12.1/sys/contrib/zstd/contrib/pzstd/utils/test/
H A DWorkQueueTest.cpp254 TEST(BufferWorkQueue, SizeCalculatedCorrectly) { in TEST() argument
256 BufferWorkQueue queue; in TEST()
261 BufferWorkQueue queue; in TEST()
267 BufferWorkQueue queue; in TEST()
274 BufferWorkQueue queue; in TEST()
/freebsd-12.1/sys/contrib/zstd/contrib/pzstd/utils/
H A DWorkQueue.h142 class BufferWorkQueue {
147 BufferWorkQueue(std::size_t maxSize = 0) : queue_(maxSize), size_(0) {} in queue_()