/packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/keyboard/internal/ |
PointerTrackerQueueTests.java | 66 private final PointerTrackerQueue mQueue = new PointerTrackerQueue(); 69 assertEquals(0, mQueue.size()); 70 assertEquals("[]", mQueue.toString()); 74 mQueue.add(mElement1); 75 assertEquals(1, mQueue.size()); 76 assertEquals("[1]", mQueue.toString()); 77 mQueue.add(mElement2); 78 assertEquals(2, mQueue.size()); 79 assertEquals("[1 2]", mQueue.toString()); 80 mQueue.add(mElement3) [all...] |
/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
MockExecutor.java | 29 private final LinkedList<Runnable> mQueue = new LinkedList<Runnable>(); 35 mQueue.addLast(task); 39 mQueue.clear(); 48 return mQueue.size(); 52 if (mQueue.isEmpty()) { 55 Runnable command = mQueue.removeFirst();
|
/packages/apps/Launcher2/src/com/android/launcher2/ |
DeferredHandler.java | 35 private LinkedList<Pair<Runnable, Integer>> mQueue = new LinkedList<Pair<Runnable, Integer>>(); 43 synchronized (mQueue) { 44 if (mQueue.size() == 0) { 47 p = mQueue.removeFirst(); 51 synchronized (mQueue) { 82 synchronized (mQueue) { 83 mQueue.add(new Pair<Runnable, Integer>(runnable, type)); 84 if (mQueue.size() == 1) { 99 synchronized (mQueue) { 100 while (mQueue.remove(runnable)) { [all...] |
/packages/apps/Gallery/src/com/android/camera/ |
ImageLoader.java | 37 private final ArrayList<WorkItem> mQueue = new ArrayList<WorkItem>(); 54 synchronized (mQueue) { 56 mQueue.add(w); 57 mQueue.notifyAll(); 62 synchronized (mQueue) { 65 mQueue.remove(index); 73 // The caller should hold mQueue lock. 75 for (int i = 0; i < mQueue.size(); i++) { 76 if (mQueue.get(i).mImage == image) { 85 synchronized (mQueue) { [all...] |
/packages/apps/Nfc/nci/jni/ |
DataQueue.cpp | 50 while (mQueue.empty() == false) 52 tHeader* header = mQueue.front (); 53 mQueue.pop_front (); 63 bool retval = mQueue.empty(); 96 mQueue.push_back (header); 125 tHeader* header = mQueue.front (); 137 mQueue.pop_front ();
|
DataQueue.h | 103 Queue mQueue;
|
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
SingleThreadNamedTaskExecutor.java | 32 private final LinkedBlockingQueue<NamedTask> mQueue; 37 mQueue = new LinkedBlockingQueue<NamedTask>(); 43 if (DBG) Log.d(TAG, "Cancelling " + mQueue.size() + " tasks: " + mWorker.getName()); 47 mQueue.clear(); 53 mQueue.clear(); 60 mQueue.add(task); 78 task = mQueue.take();
|
/frameworks/ex/variablespeed/tests/src/com/android/ex/variablespeed/ |
AwaitableCompletionListener.java | 33 private final BlockingQueue<Object> mQueue = new LinkedBlockingQueue<Object>(); 38 mQueue.put(new Object()); 49 if (mQueue.poll(timeout, unit) == null) { 55 if (mQueue.peek() != null) {
|
AwaitableErrorListener.java | 31 private final BlockingQueue<Object> mQueue = new LinkedBlockingQueue<Object>(); 46 mQueue.put(new Object()); 57 if (mQueue.poll(timeout, unit) == null) { 63 if (mQueue.peek() != null) {
|
/packages/apps/Camera/src/com/android/camera/ |
MediaSaver.java | 45 private ArrayList<SaveRequest> mQueue; 55 mQueue = new ArrayList<SaveRequest>(); 61 return (mQueue.size() >= SAVE_QUEUE_LIMIT); 77 while (mQueue.size() >= SAVE_QUEUE_LIMIT) { 84 mQueue.add(r); 95 if (mQueue.isEmpty()) { 110 r = mQueue.remove(0); 117 if (!mQueue.isEmpty()) { 118 Log.e(TAG, "Media saver thread stopped with " + mQueue.size() + " images unsaved"); 119 mQueue.clear() [all...] |
/frameworks/base/core/java/android/os/ |
Looper.java | 60 final MessageQueue mQueue; 116 final MessageQueue queue = me.mQueue; 185 return myLooper().mQueue; 189 mQueue = new MessageQueue(quitAllowed); 219 mQueue.quit(false); 235 mQueue.quit(true); 262 return mQueue.enqueueSyncBarrier(SystemClock.uptimeMillis()); 277 mQueue.removeSyncBarrier(token); 289 return mQueue; 297 pw.println("mQueue=" + ((mQueue != null) ? mQueue : "(null")) [all...] |
Handler.java | 200 mQueue = mLooper.mQueue; 226 mQueue = looper.mQueue; 476 mQueue.removeMessages(this, r, null); 486 mQueue.removeMessages(this, r, token); 585 MessageQueue queue = mQueue; 588 this + " sendMessageAtTime() called with no mQueue"); 608 MessageQueue queue = mQueue; 611 this + " sendMessageAtTime() called with no mQueue"); [all...] |
/frameworks/base/core/java/android/speech/tts/ |
AudioPlaybackHandler.java | 27 private final LinkedBlockingQueue<PlaybackQueueItem> mQueue = 51 mQueue.put(item); 80 return (mQueue.peek() != null) || (mCurrentWorkItem != null); 96 mQueue.clear(); 103 Iterator<PlaybackQueueItem> it = mQueue.iterator(); 123 item = mQueue.take(); 129 // If stop() or stopForApp() are called between mQueue.take()
|
/frameworks/av/media/libmediaplayerservice/nuplayer/ |
NuPlayerStreamListener.cpp | 63 mQueue.push_back(entry); 84 mQueue.push_back(entry); 107 if (mQueue.empty()) { 113 QueueEntry *entry = &*mQueue.begin(); 119 mQueue.erase(mQueue.begin()); 130 mQueue.erase(mQueue.begin()); 157 mQueue.erase(mQueue.begin()) [all...] |
/packages/apps/Gallery/src/com/android/camera/gallery/ |
LruCache.java | 30 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>(); 53 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); 56 entry = (Entry<K, V>) mQueue.poll(); 64 key, new Entry<K, V>(key, value, mQueue)); 79 mQueue = new ReferenceQueue<V>();
|
ImageListUber.java | 39 private final PriorityQueue<MergeSlot> mQueue; 55 mQueue = new PriorityQueue<MergeSlot>(4, 63 mQueue.clear(); 67 if (slot.next()) mQueue.add(slot); 136 if (slot.next()) mQueue.add(slot); 139 if (slot.next()) mQueue.add(slot); 144 MergeSlot slot = mQueue.poll(); 234 if (slot.next()) mQueue.add(slot); 237 if (slot.next()) mQueue.add(slot);
|
/frameworks/av/media/libstagefright/ |
TimedEventQueue.cpp | 79 mQueue.clear(); 107 List<QueueItem>::iterator it = mQueue.begin(); 108 while (it != mQueue.end() && realtime_us >= (*it).realtime_us) { 116 if (it == mQueue.begin()) { 120 mQueue.insert(it, item); 160 List<QueueItem>::iterator it = mQueue.begin(); 161 while (it != mQueue.end()) { 167 if (it == mQueue.begin()) { 174 it = mQueue.erase(it); 206 while (mQueue.empty()) [all...] |
/packages/apps/Gallery2/src/com/android/gallery3d/util/ |
IdentityCache.java | 29 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>(); 44 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); 47 entry = (Entry<K, V>) mQueue.poll(); 54 key, new Entry<K, V>(key, value, mQueue)); 68 mQueue = new ReferenceQueue<V>();
|
/packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/common/ |
LruCache.java | 34 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>(); 57 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); 60 entry = (Entry<K, V>) mQueue.poll(); 73 key, new Entry<K, V>(key, value, mQueue)); 88 mQueue = new ReferenceQueue<V>();
|
/frameworks/native/services/surfaceflinger/ |
MessageQueue.cpp | 54 mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH)); 60 mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE)); 66 mQueue.mLooper->sendMessage(this, Message(MessageQueue::TRANSACTION)); 74 mQueue.mFlinger->onMessageReceived(message.what); 78 mQueue.mFlinger->onMessageReceived(message.what); 82 mQueue.mFlinger->onMessageReceived(message.what);
|
MessageQueue.h | 69 MessageQueue& mQueue; 72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { }
|
/dalvik/tests/079-phantom/src/ |
Bitmap.java | 126 ReferenceQueue<PhantomWrapper> mQueue; 130 mQueue = queue; 137 PhantomWrapper ref = (PhantomWrapper) mQueue.remove();
|
/frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/tablet/ |
TabletTicker.java | 71 private StatusBarNotification[] mQueue = new StatusBarNotification[QUEUE_LENGTH]; 93 + " mQueuePos=" + mQueuePos + " mQueue=" + Arrays.toString(mQueue)); 100 mQueue[mQueuePos] = notification; 129 mQueue[i] = mQueue[i+1]; 132 mQueue[QUEUE_LENGTH-1] = null; 147 mQueue[i] = null; 196 mCurrentNotification = mQueue[0]; 198 Slog.d(TAG, "dequeue mQueuePos=" + mQueuePos + " mQueue=" + Arrays.toString(mQueue)) [all...] |
/frameworks/volley/src/com/android/volley/ |
NetworkDispatcher.java | 36 private final BlockingQueue<Request> mQueue; 58 mQueue = queue; 80 request = mQueue.take();
|
/frameworks/av/media/libstagefright/rtsp/ |
ARTPSource.h | 44 List<sp<ABuffer> > *queue() { return &mQueue; } 54 List<sp<ABuffer> > mQueue;
|