Searched refs:BufferWorkQueue (Results 1 – 4 of 4) sorted by relevance
| /external/zstd/contrib/pzstd/ |
| D | Pzstd.cpp | 59 WorkQueue<std::shared_ptr<BufferWorkQueue>> outs{options.numThreads + 1}; in handleOneInput()
266 std::shared_ptr<BufferWorkQueue> in, in compress()
267 std::shared_ptr<BufferWorkQueue> out, in compress()
361 readData(BufferWorkQueue& queue, size_t chunkSize, size_t size, FILE* fd, in readData()
379 WorkQueue<std::shared_ptr<BufferWorkQueue>>& chunks, in asyncCompressChunks()
395 auto in = std::make_shared<BufferWorkQueue>(); in asyncCompressChunks()
398 auto out = std::make_shared<BufferWorkQueue>(); in asyncCompressChunks()
425 std::shared_ptr<BufferWorkQueue> in, in decompress()
426 std::shared_ptr<BufferWorkQueue> out) { in decompress()
494 WorkQueue<std::shared_ptr<BufferWorkQueue>>& frames, in asyncDecompressFrames()
[all …]
|
| D | Pzstd.h | 108 WorkQueue<std::shared_ptr<BufferWorkQueue>>& chunks,
130 WorkQueue<std::shared_ptr<BufferWorkQueue>>& frames,
147 WorkQueue<std::shared_ptr<BufferWorkQueue>>& outs,
|
| /external/zstd/contrib/pzstd/utils/test/ |
| D | WorkQueueTest.cpp | 254 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()
|
| /external/zstd/contrib/pzstd/utils/ |
| D | WorkQueue.h | 142 class BufferWorkQueue {
147 BufferWorkQueue(std::size_t maxSize = 0) : queue_(maxSize), size_(0) {} in queue_()
|