queuepool_test.cpp - OpenGrok cross reference for /foundation/ai/ai_engine/test/common/queuepool/queuepool

Lines Matching refs:queuePool
54     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
55     ASSERT_NE(queuePool, nullptr);
68     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
69     ASSERT_NE(queuePool, nullptr);
70     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
84     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
85     ASSERT_NE(queuePool, nullptr);
86     auto busyNum = queuePool->BusyQueueNum();
100     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
101     ASSERT_NE(queuePool, nullptr);
102     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
104     auto busyNum = queuePool->BusyQueueNum();
118     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
119     ASSERT_NE(queuePool, nullptr);
120     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
122     queuePool->Push(queue);
123     auto busy = queuePool->BusyQueueNum();
137     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
138     ASSERT_NE(queuePool, nullptr);
140     if (queuePool == nullptr) {
153     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
154     ASSERT_NE(queuePool, nullptr);
158         queue = queuePool->Pop();
162     queue = queuePool->Pop();
176     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
177     ASSERT_NE(queuePool, nullptr);
180     queuePool->Push(queue);
181     auto busyNum = queuePool->BusyQueueNum();
195     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
196     ASSERT_NE(queuePool, nullptr);
197     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
213     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
214     ASSERT_NE(queuePool, nullptr);
215     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
234     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
235     ASSERT_NE(queuePool, nullptr);
236     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
255     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
256     ASSERT_NE(queuePool, nullptr);
257     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
272     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
273     ASSERT_NE(queuePool, nullptr);
274     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
292     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
293     ASSERT_NE(queuePool, nullptr);
294     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
312     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
313     ASSERT_NE(queuePool, nullptr);
314     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
338     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
339     ASSERT_NE(queuePool, nullptr);
340     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
358     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
359     ASSERT_NE(queuePool, nullptr);
360     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
380     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
381     ASSERT_NE(queuePool, nullptr);
382     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
409     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
410     ASSERT_NE(queuePool, nullptr);
411     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
427     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
428     ASSERT_NE(queuePool, nullptr);
429     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
456     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
457     ASSERT_NE(queuePool, nullptr);
458     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
488     QueuePool<int> *queuePool = QueuePool<int>::GetInstance(SINGLE_QUEUE_CAPACITY);
489     ASSERT_NE(queuePool, nullptr);
490     std::shared_ptr<Queue<int>> queue = queuePool->Pop();
493     queuePool->Push(queue);
495     queue = queuePool->Pop();