| /frameworks/base/native/android/ |
| D | sensor.cpp | 65 sp<SensorEventQueue> queue = in ASensorManager_createEventQueue() local
67 if (queue != 0) { in ASensorManager_createEventQueue()
68 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data); in ASensorManager_createEventQueue()
69 queue->looper = looper; in ASensorManager_createEventQueue()
70 queue->incStrong(manager); in ASensorManager_createEventQueue()
72 return static_cast<ASensorEventQueue*>(queue.get()); in ASensorManager_createEventQueue()
78 sp<SensorEventQueue> queue = static_cast<SensorEventQueue*>(inQueue); in ASensorManager_destroyEventQueue() local
79 ALooper_removeFd(queue->looper, queue->getFd()); in ASensorManager_destroyEventQueue()
80 queue->decStrong(manager); in ASensorManager_destroyEventQueue()
86 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor) in ASensorEventQueue_enableSensor() argument
[all …]
|
| D | input.cpp | 273 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper, in AInputQueue_attachLooper() argument
275 InputQueue* iq = static_cast<InputQueue*>(queue); in AInputQueue_attachLooper()
280 void AInputQueue_detachLooper(AInputQueue* queue) { in AInputQueue_detachLooper() argument
281 InputQueue* iq = static_cast<InputQueue*>(queue); in AInputQueue_detachLooper()
285 int32_t AInputQueue_hasEvents(AInputQueue* queue) { in AInputQueue_hasEvents() argument
286 InputQueue* iq = static_cast<InputQueue*>(queue); in AInputQueue_hasEvents()
290 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent) { in AInputQueue_getEvent() argument
291 InputQueue* iq = static_cast<InputQueue*>(queue); in AInputQueue_getEvent()
298 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event) { in AInputQueue_preDispatchEvent() argument
299 InputQueue* iq = static_cast<InputQueue*>(queue); in AInputQueue_preDispatchEvent()
[all …]
|
| /frameworks/av/media/libstagefright/rtsp/ |
| D | AAVCAssembler.cpp | 48 List<sp<ABuffer> > *queue = source->queue(); in addNALUnit() local
50 if (queue->empty()) { in addNALUnit()
55 List<sp<ABuffer> >::iterator it = queue->begin(); in addNALUnit()
56 while (it != queue->end()) { in addNALUnit()
61 it = queue->erase(it); in addNALUnit()
64 if (queue->empty()) { in addNALUnit()
69 sp<ABuffer> buffer = *queue->begin(); in addNALUnit()
87 queue->erase(queue->begin()); in addNALUnit()
96 queue->erase(queue->begin()); in addNALUnit()
101 return addFragmentedNALUnit(queue); in addNALUnit()
[all …]
|
| D | AMPEG2TSAssembler.cpp | 53 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
55 if (queue->empty()) { in addPacket()
60 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
61 while (it != queue->end()) { in addPacket()
66 it = queue->erase(it); in addPacket()
69 if (queue->empty()) { in addPacket()
74 sp<ABuffer> buffer = *queue->begin(); in addPacket()
88 queue->erase(queue->begin()); in addPacket()
100 queue->erase(queue->begin()); in addPacket()
|
| D | AH263Assembler.cpp | 54 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
56 if (queue->empty()) { in addPacket()
61 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
62 while (it != queue->end()) { in addPacket()
67 it = queue->erase(it); in addPacket()
70 if (queue->empty()) { in addPacket()
75 sp<ABuffer> buffer = *queue->begin(); in addPacket()
99 queue->erase(queue->begin()); in addPacket()
113 queue->erase(queue->begin()); in addPacket()
121 queue->erase(queue->begin()); in addPacket()
[all …]
|
| D | ARawAudioAssembler.cpp | 53 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
55 if (queue->empty()) { in addPacket()
60 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
61 while (it != queue->end()) { in addPacket()
66 it = queue->erase(it); in addPacket()
69 if (queue->empty()) { in addPacket()
74 sp<ABuffer> buffer = *queue->begin(); in addPacket()
88 queue->erase(queue->begin()); in addPacket()
100 queue->erase(queue->begin()); in addPacket()
|
| D | AAMRAssembler.cpp | 103 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
105 if (queue->empty()) { in addPacket()
110 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
111 while (it != queue->end()) { in addPacket()
116 it = queue->erase(it); in addPacket()
119 if (queue->empty()) { in addPacket()
124 sp<ABuffer> buffer = *queue->begin(); in addPacket()
138 queue->erase(queue->begin()); in addPacket()
155 queue->erase(queue->begin()); in addPacket()
169 queue->erase(queue->begin()); in addPacket()
[all …]
|
| D | AMPEG4ElementaryAssembler.cpp | 208 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
210 if (queue->empty()) { in addPacket()
215 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
216 while (it != queue->end()) { in addPacket()
221 it = queue->erase(it); in addPacket()
224 if (queue->empty()) { in addPacket()
229 sp<ABuffer> buffer = *queue->begin(); in addPacket()
359 queue->erase(queue->begin()); in addPacket()
|
| D | AMPEG4AudioAssembler.cpp | 487 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
489 if (queue->empty()) { in addPacket()
494 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
495 while (it != queue->end()) { in addPacket()
500 it = queue->erase(it); in addPacket()
503 if (queue->empty()) { in addPacket()
508 sp<ABuffer> buffer = *queue->begin(); in addPacket()
531 queue->erase(queue->begin()); in addPacket()
|
| /frameworks/base/core/java/android/hardware/ |
| D | SystemSensorManager.java | 108 SensorEventQueue queue = mSensorListeners.get(listener); in registerListenerImpl() local
109 if (queue == null) { in registerListenerImpl()
111 queue = new SensorEventQueue(listener, looper, this); in registerListenerImpl()
112 if (!queue.addSensor(sensor, delay)) { in registerListenerImpl()
113 queue.dispose(); in registerListenerImpl()
116 mSensorListeners.put(listener, queue); in registerListenerImpl()
119 return queue.addSensor(sensor, delay); in registerListenerImpl()
133 SensorEventQueue queue = mSensorListeners.get(listener); in unregisterListenerImpl() local
134 if (queue != null) { in unregisterListenerImpl()
137 result = queue.removeAllSensors(); in unregisterListenerImpl()
[all …]
|
| /frameworks/volley/tests/src/com/android/volley/ |
| D | RequestQueueTest.java | 73 RequestQueue queue = new RequestQueue(new NoCache(), network, 1, mDelivery); in testAdd_requestProcessedInCorrectOrder() local
76 queue.add(request); in testAdd_requestProcessedInCorrectOrder()
80 queue.start(); in testAdd_requestProcessedInCorrectOrder()
82 queue.stop(); in testAdd_requestProcessedInCorrectOrder()
101 RequestQueue queue = new RequestQueue(new NoCache(), network, 3, mDelivery); in testAdd_dedupeByCacheKey() local
102 queue.add(req1); in testAdd_dedupeByCacheKey()
103 queue.add(req2); in testAdd_dedupeByCacheKey()
104 queue.start(); in testAdd_dedupeByCacheKey()
106 queue.stop(); in testAdd_dedupeByCacheKey()
111 RequestQueue queue = new RequestQueue(new NoCache(), network, 3, mDelivery); in testCancelAll_onlyCorrectTag() local
[all …]
|
| /frameworks/base/core/jni/ |
| D | android_view_InputQueue.cpp | 202 sp<InputQueue> queue = InputQueue::createQueue(queueWeak, messageQueue->getLooper()); in nativeInit() local
203 if (!queue.get()) { in nativeInit()
207 queue->incStrong(&gInputQueueClassInfo); in nativeInit()
208 return reinterpret_cast<jint>(queue.get()); in nativeInit()
212 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); in nativeDispose() local
213 queue->detachLooper(); in nativeDispose()
214 queue->decStrong(&gInputQueueClassInfo); in nativeDispose()
219 InputQueue* queue = reinterpret_cast<InputQueue*>(ptr); in nativeSendKeyEvent() local
220 KeyEvent* event = queue->createKeyEvent(); in nativeSendKeyEvent()
223 queue->recycleInputEvent(event); in nativeSendKeyEvent()
[all …]
|
| /frameworks/native/include/android/ |
| D | sensor.h | 174 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue);
182 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor);
187 int ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor);
196 int ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec);
203 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue);
218 ssize_t ASensorEventQueue_getEvents(ASensorEventQueue* queue,
|
| D | input.h | 809 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper,
815 void AInputQueue_detachLooper(AInputQueue* queue);
822 int32_t AInputQueue_hasEvents(AInputQueue* queue);
828 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent);
838 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event);
844 void AInputQueue_finishEvent(AInputQueue* queue, AInputEvent* event, int handled);
|
| D | native_activity.h | 199 void (*onInputQueueCreated)(ANativeActivity* activity, AInputQueue* queue);
206 void (*onInputQueueDestroyed)(ANativeActivity* activity, AInputQueue* queue);
|
| /frameworks/base/core/java/android/os/ |
| D | Handler.java | 585 MessageQueue queue = mQueue; in sendMessageAtTime() local
586 if (queue == null) { in sendMessageAtTime()
592 return enqueueMessage(queue, msg, uptimeMillis); in sendMessageAtTime()
608 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue() local
609 if (queue == null) { in sendMessageAtFrontOfQueue()
615 return enqueueMessage(queue, msg, 0); in sendMessageAtFrontOfQueue()
618 private boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) { in enqueueMessage() argument
623 return queue.enqueueMessage(msg, uptimeMillis); in enqueueMessage()
|
| /frameworks/base/test-runner/src/android/test/ |
| D | LoaderTestCase.java | 57 final ArrayBlockingQueue<T> queue = new ArrayBlockingQueue<T>(1); in getLoaderResultSynchronously() local
70 queue.add(data); in getLoaderResultSynchronously()
92 result = queue.take(); in getLoaderResultSynchronously()
|
| /frameworks/volley/src/com/android/volley/toolbox/ |
| D | Volley.java | 66 RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network); in newRequestQueue() local
67 queue.start(); in newRequestQueue()
69 return queue; in newRequestQueue()
|
| /frameworks/base/tests/CoreTests/android/core/ |
| D | HeapTest.java | 230 ReferenceQueue<Object> queue) { in makeRefs() argument
233 refs[i] = new PhantomReference<Object>(objects[i], queue); in makeRefs()
238 ReferenceQueue<T> queue) { in checkRefs() argument
262 while ((ref = (PhantomReference<T>) queue.poll()) != null) { in checkRefs()
316 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in testPhantomRefs() local
321 makeRefs(objects, refs, queue); in testPhantomRefs()
323 checkRefs(objects, refs, queue); in testPhantomRefs()
333 checkRefs(objects, refs, queue); in testPhantomRefs()
343 checkRefs(objects, refs, queue); in testPhantomRefs()
|
| /frameworks/av/media/libstagefright/include/ |
| D | TimedEventQueue.h | 45 virtual void fire(TimedEventQueue *queue, int64_t now_us) = 0;
106 virtual void fire(TimedEventQueue *queue, int64_t now_us) { in fire()
107 queue->mStopped = true; in fire()
|
| /frameworks/native/libs/gui/ |
| D | SensorManager.cpp | 132 sp<SensorEventQueue> queue; in createEventQueue() local
143 queue = new SensorEventQueue(connection); in createEventQueue()
146 return queue; in createEventQueue()
|
| /frameworks/base/core/java/android/app/ |
| D | NativeActivity.java | 95 private native int loadNativeCode(String path, String funcname, MessageQueue queue, in loadNativeCode() argument
289 public void onInputQueueCreated(InputQueue queue) { in onInputQueueCreated() argument
291 mCurInputQueue = queue; in onInputQueueCreated()
292 onInputQueueCreatedNative(mNativeHandle, queue.getNativePtr()); in onInputQueueCreated()
296 public void onInputQueueDestroyed(InputQueue queue) { in onInputQueueDestroyed() argument
298 onInputQueueDestroyedNative(mNativeHandle, queue.getNativePtr()); in onInputQueueDestroyed()
|
| /frameworks/base/docs/html/training/multiple-threads/ |
| D | create-threadpool.jd | 40 {@link java.util.concurrent.ThreadPoolExecutor}, which runs a task from a queue when a thread
41 in its pool becomes free. To run a task, all you have to do is add it to the queue.
102 Define a method in the thread pool class that adds a task to a thread pool's queue. For
187 A queue of tasks
190 The incoming queue from which {@link java.util.concurrent.ThreadPoolExecutor} takes
192 {@link java.lang.Runnable} object from a first-in, first-out queue and attaches it to the
193 thread. You provide this queue object when you create the thread pool, using any queue class
195 requirements of your app, you can choose from the available queue implementations; to learn
203 // A queue of Runnables
206 // Instantiates the queue of Runnables as a LinkedBlockingQueue
|
| /frameworks/native/services/surfaceflinger/ |
| D | MessageQueue.h | 72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } in Handler() argument
|
| /frameworks/volley/src/com/android/volley/ |
| D | NetworkDispatcher.java | 55 public NetworkDispatcher(BlockingQueue<Request> queue, in NetworkDispatcher() argument
58 mQueue = queue; in NetworkDispatcher()
|