Searched refs:input_queue (Results 1 – 1 of 1) sorted by relevance
336 queue_node<int> input_queue(g); in test_reserve_release_messages() local342 make_edge(input_queue, limit); in test_reserve_release_messages()348 input_queue.try_put(list[0]); // succeeds in test_reserve_release_messages()349 input_queue.try_put(list[1]); // succeeds in test_reserve_release_messages()350 input_queue.try_put(list[2]); // fails, stored in upstream buffer in test_reserve_release_messages()363 input_queue.try_put(list[3]); //success in test_reserve_release_messages()