79     BufferMsg operator()(BufferMsg buffer) const {  in operator ()()
80         if (!buffer.isLast) {  in operator ()()
81             unsigned int outSize = buffer.outputBuffer.len;  in operator ()()
82             BZ2_bzBuffToBuffCompress(buffer.outputBuffer.b,  in operator ()()
84                                      buffer.inputBuffer.b,  in operator ()()
85                                      buffer.inputBuffer.len,  in operator ()()
89             buffer.outputBuffer.len = outSize;  in operator ()()
91         return buffer;  in operator ()()
106     void readChunk(Buffer& buffer) {  in readChunk()  argument
107         m_inputStream.read(buffer.b, m_chunkSize);  in readChunk()
108         buffer.len = static_cast<std::size_t>(m_inputStream.gcount());  in readChunk()
112     void writeChunk(const Buffer& buffer) {  in writeChunk()  argument
113         m_outputStream.write(buffer.b, buffer.len);  in writeChunk()
178         BufferMsg buffer;  in writingLoop()  local
179         m_writeQueue.pop(buffer);  in writingLoop()
180         while (!buffer.isLast) {  in writingLoop()
181             m_io.writeChunk(buffer.outputBuffer);  in writingLoop()
182             m_writeQueue.pop(buffer);  in writingLoop()
261     oneapi::tbb::flow::sequencer_node<BufferMsg> ordering(g, [](const BufferMsg& buffer) -> size_t {  in fgCompression()  argument
262         return buffer.seqId;  in fgCompression()