Searched refs:asyncNodeActivity (Results 1 – 1 of 1) sorted by relevance
203 AsyncNodeActivity asyncNodeActivity(io); in fgCompressionAsyncNode() local208 [&asyncNodeActivity](const oneapi::tbb::flow::continue_msg& msg, in fgCompressionAsyncNode()210 asyncNodeActivity.submitRead(gateway); in fgCompressionAsyncNode()225 [&asyncNodeActivity](const BufferMsg& bufferMsg, in fgCompressionAsyncNode()227 asyncNodeActivity.submitWrite(bufferMsg); in fgCompressionAsyncNode()