Searched refs:file_reader (Results 1 – 1 of 1) sorted by relevance
205 async_file_reader_node file_reader( in fgCompressionAsyncNode() local230 make_edge(file_reader, compressor); in fgCompressionAsyncNode()234 file_reader.try_put(oneapi::tbb::flow::continue_msg()); in fgCompressionAsyncNode()246 oneapi::tbb::flow::input_node<BufferMsg> file_reader( in fgCompression() local256 file_reader.activate(); in fgCompression()271 make_edge(file_reader, compressor); in fgCompression()