Searched refs:eventQueue (Results 1 – 3 of 3) sorted by relevance
| /packages/modules/StatsD/statsd/tests/ |
| D | SocketListener_test.cpp | 122 LogEventQueue eventQueue(kEventCount /*buffer limit*/); in TEST() local
132 generateAtomLogging(eventQueue, logEventFilter, kEventCount, kAtomId); in TEST()
135 EXPECT_EQ(kEventCount, eventQueue.mQueue.size()); in TEST()
137 auto logEvent = eventQueue.waitPop(); in TEST()
145 LogEventQueue eventQueue(kEventCount /*buffer limit*/); in TEST() local
156 generateAtomLogging(eventQueue, logEventFilter, kEventCount, kAtomId); in TEST()
159 EXPECT_EQ(kEventCount, eventQueue.mQueue.size()); in TEST()
161 auto logEvent = eventQueue.waitPop(); in TEST()
168 auto logEvent = eventQueue.waitPop(); in TEST()
176 LogEventQueue eventQueue(kEventCount * 3 /*buffer limit*/); in TEST() local
[all …]
|
| /packages/modules/StatsD/statsd/src/ |
| D | main.cpp | 93 std::shared_ptr<LogEventQueue> eventQueue = in main() local
105 gSocketListener = new StatsSocketListener(eventQueue, logEventFilter); in main()
114 gStatsService = SharedRefBase::make<StatsService>(uidMap, eventQueue, logEventFilter); in main()
|
| /packages/modules/StatsD/statsd/fuzzers/ |
| D | statsd_service_fuzzer.cpp | 30 std::shared_ptr<LogEventQueue> eventQueue = in LLVMFuzzerTestOneInput() local
34 SharedRefBase::make<StatsService>(uidMap, eventQueue, logEventFilter); in LLVMFuzzerTestOneInput()
|