/packages/apps/Launcher2/src/com/android/launcher2/ |
DeferredHandler.java | 35 private LinkedList<Runnable> mQueue = new LinkedList(); 42 synchronized (mQueue) { 43 if (mQueue.size() == 0) { 46 r = mQueue.removeFirst(); 49 synchronized (mQueue) { 77 synchronized (mQueue) { 78 mQueue.add(runnable); 79 if (mQueue.size() == 1) { 91 synchronized (mQueue) { 92 while (mQueue.remove(runnable)) { [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/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/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/base/core/java/android/os/ |
Looper.java | 59 final MessageQueue mQueue; 88 myLooper().mQueue.mQuitAllowed = false; 108 MessageQueue queue = me.mQueue; 159 return myLooper().mQueue; 163 mQueue = new MessageQueue(); 173 mQueue.enqueueMessage(msg, 0); 185 return mQueue; 192 pw.println(prefix + "mQueue=" + ((mQueue != null) ? mQueue : "(null")) [all...] |
Handler.java | 124 mQueue = mLooper.mQueue; 148 mQueue = mLooper.mQueue; 157 mQueue = looper.mQueue; 167 mQueue = looper.mQueue; 344 mQueue.removeMessages(this, r, null); 353 mQueue.removeMessages(this, r, token) [all...] |
/frameworks/base/media/libstagefright/ |
ThreadedSource.cpp | 110 while (mQueue.empty() && mFinalResult == OK) { 114 if (!mQueue.empty()) { 115 *buffer = *mQueue.begin(); 116 mQueue.erase(mQueue.begin()); 159 if (mQueue.size() == kMaxQueueSize) { 177 mQueue.push_back(buffer); 179 if (mQueue.size() < kMaxQueueSize) { 204 while (!mQueue.empty()) { 205 MediaBuffer *buffer = *mQueue.begin() [all...] |
TimedEventQueue.cpp | 85 mQueue.clear(); 113 List<QueueItem>::iterator it = mQueue.begin(); 114 while (it != mQueue.end() && realtime_us >= (*it).realtime_us) { 122 if (it == mQueue.begin()) { 126 mQueue.insert(it, item); 166 List<QueueItem>::iterator it = mQueue.begin(); 167 while (it != mQueue.end()) { 173 if (it == mQueue.begin()) { 180 it = mQueue.erase(it); 238 while (mQueue.empty()) [all...] |
AwesomePlayer.cpp | 256 mQueue.stop(); 265 mQueue.cancelEvent(mVideoEvent->eventID()); 267 mQueue.cancelEvent(mStreamDoneEvent->eventID()); 269 mQueue.cancelEvent(mCheckAudioStatusEvent->eventID()); 273 mQueue.cancelEvent(mBufferingEvent->eventID()); [all...] |
/packages/apps/Camera/src/com/android/camera/gallery/ |
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(); 68 key, new Entry<K, V>(key, value, mQueue)); 83 mQueue = new ReferenceQueue<V>();
|
ImageListUber.java | 35 private final PriorityQueue<MergeSlot> mQueue; 51 mQueue = new PriorityQueue<MergeSlot>(4, 59 mQueue.clear(); 63 if (slot.next()) mQueue.add(slot); 116 if (slot.next()) mQueue.add(slot); 119 if (slot.next()) mQueue.add(slot); 124 MergeSlot slot = mQueue.poll();
|
/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);
|
/dalvik/tests/079-phantom/src/ |
Bitmap.java | 126 ReferenceQueue<PhantomWrapper> mQueue; 130 mQueue = queue; 137 PhantomWrapper ref = (PhantomWrapper) mQueue.remove();
|
/frameworks/base/media/libstagefright/rtsp/ |
ARTPSource.h | 44 List<sp<ABuffer> > *queue() { return &mQueue; } 58 List<sp<ABuffer> > mQueue;
|
ARTPSource.cpp | 105 for (List<sp<ABuffer> >::iterator it = mQueue.begin(); 106 it != mQueue.end(); ++it) { 131 mQueue.push_back(buffer); 168 List<sp<ABuffer> >::iterator it = mQueue.begin(); 169 while (it != mQueue.end() && (uint32_t)(*it)->int32Data() < seqNum) { 173 if (it != mQueue.end() && (uint32_t)(*it)->int32Data() == seqNum) { 178 mQueue.insert(it, buffer);
|
/packages/apps/Calendar/src/com/android/calendar/ |
EventLoader.java | 151 LinkedBlockingQueue<LoadRequest> mQueue; 155 mQueue = queue; 161 mQueue.put(new ShutdownRequest()); 176 LoadRequest request = mQueue.take(); 180 while (!mQueue.isEmpty()) { 185 request = mQueue.take();
|
/frameworks/base/media/libstagefright/include/ |
ThreadedSource.h | 57 List<MediaBuffer *> mQueue;
|
TimedEventQueue.h | 112 List<QueueItem> mQueue;
|
AwesomePlayer.h | 119 TimedEventQueue mQueue;
|
/frameworks/base/media/libstagefright/mpeg2ts/ |
ATSParser.cpp | 92 ElementaryStreamQueue mQueue; 274 mQueue(streamType == 0x1b 314 mQueue.clear(); 505 status_t err = mQueue.appendData(data, size, timeUs); 509 while ((accessUnit = mQueue.dequeueAccessUnit()) != NULL) { 511 sp<MetaData> meta = mQueue.getFormat(); 518 } else if (mQueue.getFormat() != NULL) {
|
/frameworks/base/media/libstagefright/omx/ |
OMX.cpp | 59 List<omx_message> mQueue; 99 mQueue.push_back(msg); 127 while (!mDone && mQueue.empty()) { 135 msg = *mQueue.begin(); 136 mQueue.erase(mQueue.begin());
|
/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/ |
LatinKeyboardBaseView.java | 349 private LinkedList<PointerTracker> mQueue = new LinkedList<PointerTracker>(); 352 mQueue.add(tracker); 356 LinkedList<PointerTracker> queue = mQueue; 366 LinkedList<PointerTracker> queue = mQueue; 380 for (PointerTracker t : mQueue) { 386 mQueue.clear(); 388 mQueue.add(tracker); 392 mQueue.remove(tracker); [all...] |
/frameworks/base/services/java/com/android/server/ |
BackupManagerService.java | [all...] |