147     AsyncNodeActivity(IOOperations& io)  in AsyncNodeActivity()  argument
148             : m_io(io),  in AsyncNodeActivity()
200 void fgCompressionAsyncNode(IOOperations& io, int blockSizeIn100KB) {  in fgCompressionAsyncNode()  argument
203     AsyncNodeActivity asyncNodeActivity(io);  in fgCompressionAsyncNode()
243 void fgCompression(IOOperations& io, int blockSizeIn100KB) {  in fgCompression()  argument
247         g, [&io](oneapi::tbb::flow_control& fc) -> BufferMsg {  in fgCompression()
248             if (io.hasDataToRead()) {  in fgCompression()
249                 BufferMsg bufferMsg = BufferMsg::createBufferMsg(io.chunksRead(), io.chunkSize());  in fgCompression()
250                 io.readChunk(bufferMsg.inputBuffer);  in fgCompression()
266         g, oneapi::tbb::flow::serial, [&io](const BufferMsg& bufferMsg) {  in fgCompression()
267             io.writeChunk(bufferMsg.outputBuffer);  in fgCompression()
344     IOOperations io(inputStream, outputStream, chunkSize);  in main()  local
351         fgCompressionAsyncNode(io, blockSizeIn100KB);  in main()
357         fgCompression(io, blockSizeIn100KB);  in main()