Searched defs:bufferMsg (Results 1 – 1 of 1) sorted by relevance
162 void submitWrite(const BufferMsg& bufferMsg) { in submitWrite()169 BufferMsg bufferMsg = BufferMsg::createBufferMsg(m_io.chunksRead(), m_io.chunkSize()); in readingLoop() local217 [](const BufferMsg& bufferMsg) -> size_t { in fgCompressionAsyncNode()226 async_file_writer_node::gateway_type& gateway) { in fgCompressionAsyncNode()249 BufferMsg bufferMsg = BufferMsg::createBufferMsg(io.chunksRead(), io.chunkSize()); in fgCompression() local266 g, oneapi::tbb::flow::serial, [&io](const BufferMsg& bufferMsg) { in fgCompression()