Searched refs:mEventQueue (Results 1 – 3 of 3) sorted by relevance
42 private Map<String, LinkedList<EventSl4aObject>> mEventQueue = new HashMap<>(); field in Sl4aEventDispatcher79 synchronized(mEventQueue) { in internalPolling()80 if (mEventQueue.containsKey(event.getName())) { in internalPolling()81 mEventQueue.get(event.getName()).add(event); in internalPolling()85 mEventQueue.put(event.getName(), queue); in internalPolling()120 synchronized (mEventQueue) { in popEvent()121 if (mEventQueue.get(name) != null) { in popEvent()123 EventSl4aObject res = mEventQueue.get(name).poll(); in popEvent()146 synchronized (mEventQueue) { in waitForEvent()147 if (mEventQueue.get(name) != null) { in waitForEvent()[all …]
39 private Queue<T> mEventQueue = new ConcurrentLinkedQueue<T>(); field in ClusterEventUploader68 mEventQueue.add(event); in postEvent()102 while (!mEventQueue.isEmpty()) { in uploadEvents()105 while (!mEventQueue.isEmpty() && events.size() < batchSize) { in uploadEvents()106 events.add(mEventQueue.poll()); in uploadEvents()114 mEventQueue.addAll(events); in uploadEvents()
56 private final LinkedBlockingQueue<LogcatEvent> mEventQueue = new LinkedBlockingQueue<>(); field in GenericLogcatEventParser162 return mEventQueue.poll(timeoutMs, TimeUnit.MILLISECONDS); in waitForEvent()171 return mEventQueue.poll(); in pollForEvent()196 mEventQueue.add(new LogcatEvent(eventType, item.getStack())); in parseEvents()