Lines Matching refs:messageQueue
80 ot::MessageQueue messageQueue; in TestMessageQueue() local
95 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue()
98 messageQueue.Enqueue(*messages[0]); in TestMessageQueue()
99 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue()
100 messageQueue.Dequeue(*messages[0]); in TestMessageQueue()
101 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue()
104 messageQueue.Enqueue(*messages[0], ot::MessageQueue::kQueuePositionHead); in TestMessageQueue()
105 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue()
106 messageQueue.Dequeue(*messages[0]); in TestMessageQueue()
107 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue()
110 messageQueue.Enqueue(*messages[0]); in TestMessageQueue()
111 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue()
112 messageQueue.Enqueue(*messages[1]); in TestMessageQueue()
113 VerifyMessageQueueContent(messageQueue, 2, messages[0], messages[1]); in TestMessageQueue()
114 messageQueue.Enqueue(*messages[2]); in TestMessageQueue()
115 VerifyMessageQueueContent(messageQueue, 3, messages[0], messages[1], messages[2]); in TestMessageQueue()
116 messageQueue.Enqueue(*messages[3]); in TestMessageQueue()
117 VerifyMessageQueueContent(messageQueue, 4, messages[0], messages[1], messages[2], messages[3]); in TestMessageQueue()
118 messageQueue.Enqueue(*messages[4]); in TestMessageQueue()
119 …VerifyMessageQueueContent(messageQueue, 5, messages[0], messages[1], messages[2], messages[3], mes… in TestMessageQueue()
122 messageQueue.GetInfo(msgCount, bufferCount); in TestMessageQueue()
126 messageQueue.Dequeue(*messages[0]); in TestMessageQueue()
127 VerifyMessageQueueContent(messageQueue, 4, messages[1], messages[2], messages[3], messages[4]); in TestMessageQueue()
130 messageQueue.Dequeue(*messages[3]); in TestMessageQueue()
131 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[2], messages[4]); in TestMessageQueue()
134 messageQueue.Dequeue(*messages[4]); in TestMessageQueue()
135 VerifyMessageQueueContent(messageQueue, 2, messages[1], messages[2]); in TestMessageQueue()
138 messageQueue.Enqueue(*messages[0]); in TestMessageQueue()
139 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[2], messages[0]); in TestMessageQueue()
140 messageQueue.Enqueue(*messages[3]); in TestMessageQueue()
141 VerifyMessageQueueContent(messageQueue, 4, messages[1], messages[2], messages[0], messages[3]); in TestMessageQueue()
144 messageQueue.Dequeue(*messages[2]); in TestMessageQueue()
145 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[0], messages[3]); in TestMessageQueue()
148 messageQueue.Enqueue(*messages[2], ot::MessageQueue::kQueuePositionHead); in TestMessageQueue()
149 VerifyMessageQueueContent(messageQueue, 4, messages[2], messages[1], messages[0], messages[3]); in TestMessageQueue()
152 messageQueue.Dequeue(*messages[2]); in TestMessageQueue()
153 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[0], messages[3]); in TestMessageQueue()
156 messageQueue.Dequeue(*messages[1]); in TestMessageQueue()
157 VerifyMessageQueueContent(messageQueue, 2, messages[0], messages[3]); in TestMessageQueue()
160 messageQueue.Enqueue(*messages[1], ot::MessageQueue::kQueuePositionHead); in TestMessageQueue()
161 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[0], messages[3]); in TestMessageQueue()
164 messageQueue.Enqueue(*messages[2], ot::MessageQueue::kQueuePositionTail); in TestMessageQueue()
165 VerifyMessageQueueContent(messageQueue, 4, messages[1], messages[0], messages[3], messages[2]); in TestMessageQueue()
168 messageQueue.Dequeue(*messages[3]); in TestMessageQueue()
169 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[0], messages[2]); in TestMessageQueue()
170 messageQueue.Dequeue(*messages[1]); in TestMessageQueue()
171 VerifyMessageQueueContent(messageQueue, 2, messages[0], messages[2]); in TestMessageQueue()
172 messageQueue.Dequeue(*messages[2]); in TestMessageQueue()
173 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue()
174 messageQueue.Dequeue(*messages[0]); in TestMessageQueue()
175 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue()