Searched refs:BufferMsg (Results 1 – 1 of 1) sorted by relevance
38 struct BufferMsg { struct39 BufferMsg() {} in BufferMsg() function79 BufferMsg operator()(BufferMsg buffer) const { in operator ()() argument169 BufferMsg bufferMsg = BufferMsg::createBufferMsg(m_io.chunksRead(), m_io.chunkSize()); in readingLoop()178 BufferMsg buffer; in writingLoop()187 BufferMsg lastMsg; in sendLastMessage()213 oneapi::tbb::flow::function_node<BufferMsg, BufferMsg> compressor( in fgCompressionAsyncNode()249 BufferMsg bufferMsg = BufferMsg::createBufferMsg(io.chunksRead(), io.chunkSize()); in fgCompression()254 return BufferMsg{}; in fgCompression()258 oneapi::tbb::flow::function_node<BufferMsg, BufferMsg> compressor( in fgCompression()[all …]