| /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 | 270 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper, in AInputQueue_attachLooper() argument
272 queue->attachLooper(looper, ident, callback, data); in AInputQueue_attachLooper()
275 void AInputQueue_detachLooper(AInputQueue* queue) { in AInputQueue_detachLooper() argument
276 queue->detachLooper(); in AInputQueue_detachLooper()
279 int32_t AInputQueue_hasEvents(AInputQueue* queue) { in AInputQueue_hasEvents() argument
280 return queue->hasEvents(); in AInputQueue_hasEvents()
283 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent) { in AInputQueue_getEvent() argument
284 return queue->getEvent(outEvent); in AInputQueue_getEvent()
287 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event) { in AInputQueue_preDispatchEvent() argument
288 return queue->preDispatchEvent(event) ? 1 : 0; 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 | 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()
156 queue->erase(queue->begin()); in addPacket()
170 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 | AH263Assembler.cpp | 51 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
53 if (queue->empty()) { in addPacket()
58 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
59 while (it != queue->end()) { in addPacket()
64 it = queue->erase(it); in addPacket()
67 if (queue->empty()) { in addPacket()
72 sp<ABuffer> buffer = *queue->begin(); in addPacket()
96 queue->erase(queue->begin()); in addPacket()
120 queue->erase(queue->begin()); in addPacket()
|
| 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 | 480 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
482 if (queue->empty()) { in addPacket()
487 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
488 while (it != queue->end()) { in addPacket()
493 it = queue->erase(it); in addPacket()
496 if (queue->empty()) { in addPacket()
501 sp<ABuffer> buffer = *queue->begin(); in addPacket()
524 queue->erase(queue->begin()); in addPacket()
|
| /frameworks/support/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_hardware_SensorManager.cpp | 89 sp<SensorEventQueue> queue(mgr.createEventQueue()); in sensors_create_queue() local
90 queue->incStrong(clazz); in sensors_create_queue()
91 return reinterpret_cast<int>(queue.get()); in sensors_create_queue()
97 sp<SensorEventQueue> queue(reinterpret_cast<SensorEventQueue *>(nativeQueue)); in sensors_destroy_queue() local
98 if (queue != 0) { in sensors_destroy_queue()
99 queue->decStrong(clazz); in sensors_destroy_queue()
107 sp<SensorEventQueue> queue(reinterpret_cast<SensorEventQueue *>(nativeQueue)); in sensors_enable_sensor() local
108 if (queue == 0) return JNI_FALSE; in sensors_enable_sensor()
111 res = queue->enableSensor(sensor, delay); in sensors_enable_sensor()
113 res = queue->disableSensor(sensor); in sensors_enable_sensor()
[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 | 807 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper,
813 void AInputQueue_detachLooper(AInputQueue* queue);
820 int32_t AInputQueue_hasEvents(AInputQueue* queue);
826 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent);
836 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event);
842 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/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/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/base/core/java/android/os/ |
| D | Handler.java | 470 MessageQueue queue = mQueue; in sendMessageAtTime() local
471 if (queue != null) { in sendMessageAtTime()
473 sent = queue.enqueueMessage(msg, uptimeMillis); in sendMessageAtTime()
498 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue() local
499 if (queue != null) { in sendMessageAtFrontOfQueue()
501 sent = queue.enqueueMessage(msg, 0); in sendMessageAtFrontOfQueue()
|
| D | Looper.java | 116 final MessageQueue queue = me.mQueue; in loop() local
124 Message msg = queue.next(); // might block in loop()
|
| /frameworks/base/core/java/android/view/ |
| D | InputQueue.java | 33 void onInputQueueCreated(InputQueue queue); in onInputQueueCreated() argument
39 void onInputQueueDestroyed(InputQueue queue); in onInputQueueDestroyed() argument
|
| /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 | 86 private native int loadNativeCode(String path, String funcname, MessageQueue queue, in loadNativeCode() argument
316 public void onInputQueueCreated(InputQueue queue) { in onInputQueueCreated() argument
318 mCurInputQueue = queue; in onInputQueueCreated()
319 onInputChannelCreatedNative(mNativeHandle, queue.getInputChannel()); in onInputQueueCreated()
323 public void onInputQueueDestroyed(InputQueue queue) { in onInputQueueDestroyed() argument
326 onInputChannelDestroyedNative(mNativeHandle, queue.getInputChannel()); in onInputQueueDestroyed()
|
| /frameworks/native/services/surfaceflinger/ |
| D | MessageQueue.h | 71 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } in Handler() argument
|
| D | MessageQueue.cpp | 145 MessageQueue* queue = reinterpret_cast<MessageQueue *>(data); in cb_eventReceiver() local
146 return queue->eventReceiver(fd, events); in cb_eventReceiver()
|
| /frameworks/support/volley/src/com/android/volley/ |
| D | NetworkDispatcher.java | 51 public NetworkDispatcher(BlockingQueue<Request> queue, in NetworkDispatcher() argument
54 mQueue = queue; in NetworkDispatcher()
|
| D | RequestQueue.java | 245 private void cancelDrainable(PriorityBlockingQueue<Request> queue, int sequenceNumber) { in cancelDrainable() argument
248 queue.drainTo(pending); in cancelDrainable()
255 queue.add(request); in cancelDrainable()
|