Searched refs:bufferMsg (Results 1 – 1 of 1) sorted by relevance
162 void submitWrite(const BufferMsg& bufferMsg) { in submitWrite() argument163 m_writeQueue.push(bufferMsg); in submitWrite()170 m_io.readChunk(bufferMsg.inputBuffer); in readingLoop()171 gateway.try_put(bufferMsg); in readingLoop()225 [&asyncNodeActivity](const BufferMsg& bufferMsg, in fgCompressionAsyncNode()227 asyncNodeActivity.submitWrite(bufferMsg); in fgCompressionAsyncNode()250 io.readChunk(bufferMsg.inputBuffer); in fgCompression()251 return bufferMsg; in fgCompression()266 g, oneapi::tbb::flow::serial, [&io](const BufferMsg& bufferMsg) { in fgCompression() argument267 io.writeChunk(bufferMsg.outputBuffer); in fgCompression()[all …]