162     void submitWrite(const BufferMsg& bufferMsg) {  in submitWrite()  argument
163         m_writeQueue.push(bufferMsg);  in submitWrite()
169             BufferMsg bufferMsg = BufferMsg::createBufferMsg(m_io.chunksRead(), m_io.chunkSize());  in readingLoop()  local
170             m_io.readChunk(bufferMsg.inputBuffer);  in readingLoop()
171             gateway.try_put(bufferMsg);  in readingLoop()
217                                                           [](const BufferMsg& bufferMsg) -> size_t {  in fgCompressionAsyncNode()  argument
218                                                               return bufferMsg.seqId;  in fgCompressionAsyncNode()
225         [&asyncNodeActivity](const BufferMsg& bufferMsg,  in fgCompressionAsyncNode()
227             asyncNodeActivity.submitWrite(bufferMsg);  in fgCompressionAsyncNode()
249                 BufferMsg bufferMsg = BufferMsg::createBufferMsg(io.chunksRead(), io.chunkSize());  in fgCompression()  local
250                 io.readChunk(bufferMsg.inputBuffer);  in fgCompression()
251                 return bufferMsg;  in fgCompression()
266         g, oneapi::tbb::flow::serial, [&io](const BufferMsg& bufferMsg) {  in fgCompression()  argument
267             io.writeChunk(bufferMsg.outputBuffer);  in fgCompression()
268             BufferMsg::destroyBufferMsg(bufferMsg);  in fgCompression()