Lines Matching defs:queue
67 explicit TestEnqueueEnd(Queue<std::string>* queue, Handler* handler) in TestEnqueueEnd()
132 explicit TestDequeueEnd(Queue<std::string>* queue, Handler* handler, int capacity) in TestDequeueEnd()
204 Queue<std::string> queue(kQueueSize); in TEST_F() local
228 Queue<std::string> queue(kQueueSize); in TEST_F() local
246 Queue<std::string> queue(kQueueSize); in TEST_F() local
280 Queue<std::string> queue(kQueueSize); in TEST_F() local
313 Queue<std::string> queue(kQueueSize); in TEST_F() local
346 Queue<std::string> queue(kQueueSize); in TEST_F() local
382 Queue<std::string> queue(kQueueSize); in TEST_F() local
411 Queue<std::string> queue(kQueueSize); in TEST_F() local
453 Queue<std::string> queue(kQueueSize); in TEST_F() local
487 Queue<std::string> queue(kQueueSizeOne); in TEST_F() local
519 Queue<std::string> queue(kQueueSize); in TEST_F() local
556 Queue<std::string> queue(kQueueSizeOne); in TEST_F() local
590 Queue<std::string> queue(kQueueSize); in TEST_F() local
624 Queue<std::string> queue(kQueueSize); in TEST_F() local
664 Queue<std::string> queue(kQueueSize); in TEST_F() local
688 Queue<std::string>* queue = new Queue<std::string>(kQueueSize); in TEST_F() local
696 [](Queue<std::string>* queue, std::shared_ptr<std::string> shared) { in TEST_F()
707 [](Queue<std::string>* queue, std::string valid) { in TEST_F()
720 [](os::Handler* dequeue_handler, Queue<std::string>* queue, std::promise<void>* promise) { in TEST_F()
722 [](Queue<std::string>* queue, std::promise<void>* promise) { in TEST_F()
742 Queue<std::string> queue(10); in TEST_F() local
752 int* to_increase, Queue<std::string>* queue, std::atomic_bool* is_registered) { in sleep_and_enqueue_callback_and_unregister()
762 Queue<std::string> queue(10); in TEST_F() local
787 Queue<std::string> queue(10); in TEST_F() local
791 [](Queue<std::string>* queue) { in TEST_F()
809 Queue<std::string>* queue = new Queue<std::string>(kQueueSizeOne); in RegisterEnqueueAndDelete() local
818 Queue<std::string>* queue = new Queue<std::string>(kQueueSizeOne); in RegisterDequeueAndDelete() local
821 … common::Bind([](Queue<std::string>* queue) { queue->TryDequeue(); }, common::Unretained(queue))); in RegisterDequeueAndDelete()
913 Queue<int>* queue = new Queue<int>(kQueueSize); in TEST_F() local