Lines Matching refs:gateway
156 void submitRead(async_file_reader_node::gateway_type& gateway) { in submitRead() argument
157 gateway.reserve_wait(); in submitRead()
158 std::thread(&AsyncNodeActivity::readingLoop, this, std::ref(gateway)) in submitRead()
167 void readingLoop(async_file_reader_node::gateway_type& gateway) { in readingLoop() argument
171 gateway.try_put(bufferMsg); in readingLoop()
173 sendLastMessage(gateway); in readingLoop()
174 gateway.release_wait(); in readingLoop()
186 void sendLastMessage(async_file_reader_node::gateway_type& gateway) { in sendLastMessage() argument
189 gateway.try_put(lastMsg); in sendLastMessage()
209 async_file_reader_node::gateway_type& gateway) { in fgCompressionAsyncNode() argument
210 asyncNodeActivity.submitRead(gateway); in fgCompressionAsyncNode()
226 async_file_writer_node::gateway_type& gateway) { in fgCompressionAsyncNode() argument