Searched refs:concurrent_msg_queue (Results 1 – 1 of 1) sorted by relevance
76 static base::concurrent_queue<Message*> concurrent_msg_queue; variable270 if (!concurrent_msg_queue.empty()) { in generateMessages()272 while (concurrent_msg_queue.try_pop(msg)) in generateMessages()660 concurrent_msg_queue.push(msg); in enqueueMessage()