Lines Matching refs:messageQueue
107 MessageQueue messageQueue; in TestMessageQueue() local
122 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue()
125 messageQueue.Enqueue(*messages[0]); in TestMessageQueue()
126 VerifyMessageQueueContent(messageQueue, 1, messages[0]); in TestMessageQueue()
127 messageQueue.Dequeue(*messages[0]); in TestMessageQueue()
128 VerifyMessageQueueContent(messageQueue, 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()
134 VerifyMessageQueueContent(messageQueue, 0); 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()
150 messageQueue.GetInfo(info); 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()
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()
203 VerifyMessageQueueContent(messageQueue, 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()
219 for (Message &message : messageQueue) in TestMessageQueue()
223 messageQueue.Dequeue(message); in TestMessageQueue()
232 for (Message &message : messageQueue) in TestMessageQueue()
240 messageQueue.Dequeue(message); in TestMessageQueue()
243 VerifyMessageQueueContent(messageQueue, 0); in TestMessageQueue()