Lines Matching refs:gateway
113 void operator()( const int &input, counting_gateway_type& gateway) { in operator ()()
125 gateway.try_put(input); in operator ()()
138 void operator()( const int &input, counting_gateway_type& gateway ) { in operator ()()
140 base_type::operator()( input, gateway ); in operator ()()
321 gateway_type* gateway; member
354 void submit( const input_type &input, gateway_type& gateway ) { in submit() argument
355 work_type work = {input, &gateway}; in submit()
368 work.gateway->try_put(output); in process()
371 work.gateway->release_wait(); in process()
424 [&] (const input_type &input, gateway_type& gateway) { in run() argument
427 gateway.reserve_wait(); in run()
428 my_async_activity.submit(input, gateway); in run()
448 offload_node.gateway().reserve_wait(); in run()
544 [&](const input_type &input, gateway_type& gateway) { in run() argument
547 gateway.reserve_wait(); in run()
548 my_async_activity.submit(input, gateway); in run()
564 offload_node.gateway().reserve_wait(); in run()
627 [&](const input_type &input, gateway_type& gateway) { in operator ()() argument
628 gateway.reserve_wait(); in operator ()()
629 my_async_activity->submit( input, gateway ); in operator ()()
679 gateway_t* gateway; member
687 w.gateway->try_put(res); in __anon62ab872d0a02()
688 w.gateway->release_wait(); in __anon62ab872d0a02()
694 void submit(int i, gateway_t* gateway) { in submit() argument
695 work_type w = {i, gateway}; in submit()
696 gateway->reserve_wait(); in submit()