38 struct BufferMsg {  struct
39     BufferMsg() {}  in BufferMsg()  function
40     BufferMsg(Buffer& inputBuffer, Buffer& outputBuffer, std::size_t seqId, bool isLast = false)  in BufferMsg()  argument
46     static BufferMsg createBufferMsg(std::size_t seqId, std::size_t chunkSize) {  in createBufferMsg()  argument
56         return BufferMsg(inputBuffer, outputBuffer, seqId);  in createBufferMsg()
59     static void destroyBufferMsg(const BufferMsg& destroyMsg) {  in destroyBufferMsg()  argument
79     BufferMsg operator()(BufferMsg buffer) const {  in operator ()()  argument
140 typedef oneapi::tbb::flow::async_node<oneapi::tbb::flow::continue_msg, BufferMsg>
142 typedef oneapi::tbb::flow::async_node<BufferMsg, oneapi::tbb::flow::continue_msg>
162     void submitWrite(const BufferMsg& bufferMsg) {  in submitWrite()
169             BufferMsg bufferMsg = BufferMsg::createBufferMsg(m_io.chunksRead(), m_io.chunkSize());  in readingLoop()
178         BufferMsg buffer;  in writingLoop()
187         BufferMsg lastMsg;  in sendLastMessage()
194     oneapi::tbb::concurrent_bounded_queue<BufferMsg> m_writeQueue;
213     oneapi::tbb::flow::function_node<BufferMsg, BufferMsg> compressor(  in fgCompressionAsyncNode()
216     oneapi::tbb::flow::sequencer_node<BufferMsg> ordering(g,  in fgCompressionAsyncNode()
217                                                           [](const BufferMsg& bufferMsg) -> size_t {  in fgCompressionAsyncNode()
225         [&asyncNodeActivity](const BufferMsg& bufferMsg,  in fgCompressionAsyncNode()
246     oneapi::tbb::flow::input_node<BufferMsg> file_reader(  in fgCompression()
247         g, [&io](oneapi::tbb::flow_control& fc) -> BufferMsg {  in fgCompression()
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()
261     oneapi::tbb::flow::sequencer_node<BufferMsg> ordering(g, [](const BufferMsg& buffer) -> size_t {  in fgCompression()
265     oneapi::tbb::flow::function_node<BufferMsg> output_writer(  in fgCompression()
266         g, oneapi::tbb::flow::serial, [&io](const BufferMsg& bufferMsg) {  in fgCompression()
268             BufferMsg::destroyBufferMsg(bufferMsg);  in fgCompression()