Lines Matching full:messages
48 // This function verifies the content of the message queue to match the passed in messages
108 Message *messages[kNumTestMessages]; in TestMessageQueue() local
116 for (Message *&msg : messages) in TestMessageQueue()
125 messageQueue.Enqueue(*messages[0]); in TestMessageQueue()
126 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue()
127 messageQueue.Dequeue(*messages[0]); in TestMessageQueue()
131 messageQueue.Enqueue(*messages[0], MessageQueue::kQueuePositionHead); in TestMessageQueue()
132 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue()
133 messageQueue.Dequeue(*messages[0]); in TestMessageQueue()
136 // Enqueue 5 messages in TestMessageQueue()
137 messageQueue.Enqueue(*messages[0]); in TestMessageQueue()
138 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue()
139 messageQueue.Enqueue(*messages[1]); in TestMessageQueue()
140 VerifyMessageQueueContent(messageQueue, 2, messages[0], messages[1]); in TestMessageQueue()
141 messageQueue.Enqueue(*messages[2]); in TestMessageQueue()
142 VerifyMessageQueueContent(messageQueue, 3, messages[0], messages[1], messages[2]); in TestMessageQueue()
143 messageQueue.Enqueue(*messages[3]); in TestMessageQueue()
144 VerifyMessageQueueContent(messageQueue, 4, messages[0], messages[1], messages[2], messages[3]); in TestMessageQueue()
145 messageQueue.Enqueue(*messages[4]); in TestMessageQueue()
146 …VerifyMessageQueueContent(messageQueue, 5, messages[0], messages[1], messages[2], messages[3], mes… in TestMessageQueue()
154 messageQueue.Dequeue(*messages[0]); in TestMessageQueue()
155 VerifyMessageQueueContent(messageQueue, 4, messages[1], messages[2], messages[3], messages[4]); in TestMessageQueue()
158 messageQueue.Dequeue(*messages[3]); in TestMessageQueue()
159 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[2], messages[4]); in TestMessageQueue()
162 messageQueue.Dequeue(*messages[4]); in TestMessageQueue()
163 VerifyMessageQueueContent(messageQueue, 2, messages[1], messages[2]); in TestMessageQueue()
166 messageQueue.Enqueue(*messages[0]); in TestMessageQueue()
167 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[2], messages[0]); in TestMessageQueue()
168 messageQueue.Enqueue(*messages[3]); in TestMessageQueue()
169 VerifyMessageQueueContent(messageQueue, 4, messages[1], messages[2], messages[0], messages[3]); in TestMessageQueue()
172 messageQueue.Dequeue(*messages[2]); in TestMessageQueue()
173 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[0], messages[3]); in TestMessageQueue()
176 messageQueue.Enqueue(*messages[2], MessageQueue::kQueuePositionHead); in TestMessageQueue()
177 VerifyMessageQueueContent(messageQueue, 4, messages[2], messages[1], messages[0], messages[3]); in TestMessageQueue()
180 messageQueue.Dequeue(*messages[2]); in TestMessageQueue()
181 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[0], messages[3]); in TestMessageQueue()
184 messageQueue.Dequeue(*messages[1]); in TestMessageQueue()
185 VerifyMessageQueueContent(messageQueue, 2, messages[0], messages[3]); in TestMessageQueue()
188 messageQueue.Enqueue(*messages[1], MessageQueue::kQueuePositionHead); in TestMessageQueue()
189 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[0], messages[3]); in TestMessageQueue()
192 messageQueue.Enqueue(*messages[2], MessageQueue::kQueuePositionTail); in TestMessageQueue()
193 VerifyMessageQueueContent(messageQueue, 4, messages[1], messages[0], messages[3], messages[2]); in TestMessageQueue()
195 // Remove all messages. in TestMessageQueue()
196 messageQueue.Dequeue(*messages[3]); in TestMessageQueue()
197 VerifyMessageQueueContent(messageQueue, 3, messages[1], messages[0], messages[2]); in TestMessageQueue()
198 messageQueue.Dequeue(*messages[1]); in TestMessageQueue()
199 VerifyMessageQueueContent(messageQueue, 2, messages[0], messages[2]); in TestMessageQueue()
200 messageQueue.Dequeue(*messages[2]); in TestMessageQueue()
201 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue()
202 messageQueue.Dequeue(*messages[0]); in TestMessageQueue()
211 messageQueue.Enqueue(*messages[0]); in TestMessageQueue()
212 messageQueue.Enqueue(*messages[1]); in TestMessageQueue()
213 messageQueue.Enqueue(*messages[2]); in TestMessageQueue()
214 messageQueue.Enqueue(*messages[3]); in TestMessageQueue()
215 messageQueue.Enqueue(*messages[4]); in TestMessageQueue()
216 …VerifyMessageQueueContent(messageQueue, 5, messages[0], messages[1], messages[2], messages[3], mes… in TestMessageQueue()
226 VerifyOrQuit(&message == messages[index++]); in TestMessageQueue()
239 VerifyOrQuit(&message == messages[index++]); in TestMessageQueue()
249 // This function verifies the content of the message queue to match the passed in messages
285 otMessage *messages[kNumTestMessages]; in TestMessageQueueOtApis() local
292 for (otMessage *&msg : messages) in TestMessageQueueOtApis()
305 otMessageQueueEnqueue(&queue, messages[0]); in TestMessageQueueOtApis()
306 VerifyMessageQueueContentUsingOtApi(&queue, 1, messages[0]); in TestMessageQueueOtApis()
307 otMessageQueueEnqueue(&queue, messages[1]); in TestMessageQueueOtApis()
308 VerifyMessageQueueContentUsingOtApi(&queue, 2, messages[0], messages[1]); in TestMessageQueueOtApis()
309 otMessageQueueEnqueueAtHead(&queue, messages[2]); in TestMessageQueueOtApis()
310 VerifyMessageQueueContentUsingOtApi(&queue, 3, messages[2], messages[0], messages[1]); in TestMessageQueueOtApis()
311 otMessageQueueEnqueue(&queue, messages[3]); in TestMessageQueueOtApis()
312 …VerifyMessageQueueContentUsingOtApi(&queue, 4, messages[2], messages[0], messages[1], messages[3]); in TestMessageQueueOtApis()
315 otMessageQueueDequeue(&queue, messages[1]); in TestMessageQueueOtApis()
316 VerifyMessageQueueContentUsingOtApi(&queue, 3, messages[2], messages[0], messages[3]); in TestMessageQueueOtApis()
317 otMessageQueueDequeue(&queue, messages[0]); in TestMessageQueueOtApis()
318 VerifyMessageQueueContentUsingOtApi(&queue, 2, messages[2], messages[3]); in TestMessageQueueOtApis()
319 otMessageQueueDequeue(&queue, messages[3]); in TestMessageQueueOtApis()
320 VerifyMessageQueueContentUsingOtApi(&queue, 1, messages[2]); in TestMessageQueueOtApis()
325 message = otMessageQueueGetNext(&queue, messages[1]); in TestMessageQueueOtApis()
329 otMessageQueueEnqueue(&queue2, messages[0]); in TestMessageQueueOtApis()
330 VerifyMessageQueueContentUsingOtApi(&queue2, 1, messages[0]); in TestMessageQueueOtApis()
331 otMessageQueueEnqueue(&queue2, messages[1]); in TestMessageQueueOtApis()
332 VerifyMessageQueueContentUsingOtApi(&queue2, 2, messages[0], messages[1]); in TestMessageQueueOtApis()
334 message = otMessageQueueGetNext(&queue2, messages[0]); in TestMessageQueueOtApis()
335 VerifyOrQuit(message == messages[1], "otMessageQueueGetNext() failed"); in TestMessageQueueOtApis()
336 message = otMessageQueueGetNext(&queue, messages[0]); in TestMessageQueueOtApis()
340 otMessageQueueDequeue(&queue, messages[2]); in TestMessageQueueOtApis()