Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 149) sorted by relevance

123456

/frameworks/base/libs/hwui/tests/unit/
DLayerUpdateQueueTests.cpp28 LayerUpdateQueue queue; in TEST() local
29 EXPECT_TRUE(queue.entries().empty()); in TEST()
44 LayerUpdateQueue queue; in TEST() local
45 queue.enqueueLayerWithDamage(a.get(), Rect(25, 25, 75, 75)); in TEST()
46 queue.enqueueLayerWithDamage(b.get(), Rect(100, 100, 300, 300)); in TEST()
47 queue.enqueueLayerWithDamage(c.get(), Rect(.5, .5, .5, .5)); in TEST()
49 EXPECT_EQ(3u, queue.entries().size()); in TEST()
51 EXPECT_EQ(a.get(), queue.entries()[0].renderNode); in TEST()
52 EXPECT_EQ(Rect(25, 25, 75, 75), queue.entries()[0].damage); in TEST()
53 EXPECT_EQ(b.get(), queue.entries()[1].renderNode); in TEST()
[all …]
/frameworks/volley/src/test/java/com/android/volley/
DRequestQueueIntegrationTest.java84 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestProcessedInCorrectOrder() local
85 queue.addRequestFinishedListener(listener); in add_requestProcessedInCorrectOrder()
86 queue.add(lowerPriorityReq); in add_requestProcessedInCorrectOrder()
87 queue.add(higherPriorityReq); in add_requestProcessedInCorrectOrder()
88 queue.start(); in add_requestProcessedInCorrectOrder()
97 queue.stop(); in add_requestProcessedInCorrectOrder()
122 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 3, mDelivery); in add_dedupeByCacheKey() local
123 queue.addRequestFinishedListener(listener); in add_dedupeByCacheKey()
124 queue.add(req1); in add_dedupeByCacheKey()
125 queue.add(req2); in add_dedupeByCacheKey()
[all …]
DRequestQueueTest.java49 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 0, mDelivery); in cancelAll_onlyCorrectTag() local
61 queue.add(req1); // A in cancelAll_onlyCorrectTag()
62 queue.add(req2); // B in cancelAll_onlyCorrectTag()
63 queue.add(req3); // A in cancelAll_onlyCorrectTag()
64 queue.cancelAll(tagA); in cancelAll_onlyCorrectTag()
65 queue.add(req4); // A in cancelAll_onlyCorrectTag()
/frameworks/base/native/android/
Dsensor.cpp87 sp<SensorEventQueue> queue = in ASensorManager_createEventQueue() local
89 if (queue != 0) { in ASensorManager_createEventQueue()
90 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data); in ASensorManager_createEventQueue()
91 queue->looper = looper; in ASensorManager_createEventQueue()
92 queue->incStrong(manager); in ASensorManager_createEventQueue()
94 return static_cast<ASensorEventQueue*>(queue.get()); in ASensorManager_createEventQueue()
100 sp<SensorEventQueue> queue = static_cast<SensorEventQueue*>(inQueue); in ASensorManager_destroyEventQueue() local
101 ALooper_removeFd(queue->looper, queue->getFd()); in ASensorManager_destroyEventQueue()
102 queue->decStrong(manager); in ASensorManager_destroyEventQueue()
108 int ASensorEventQueue_registerSensor(ASensorEventQueue* queue, ASensor const* sensor, in ASensorEventQueue_registerSensor() argument
[all …]
Dinput.cpp273 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/
DAAVCAssembler.cpp48 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 …]
DAH263Assembler.cpp54 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 …]
DAMPEG2TSAssembler.cpp55 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
57 if (queue->empty()) { in addPacket()
62 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
63 while (it != queue->end()) { in addPacket()
68 it = queue->erase(it); in addPacket()
71 if (queue->empty()) { in addPacket()
76 sp<ABuffer> buffer = *queue->begin(); in addPacket()
90 queue->erase(queue->begin()); in addPacket()
102 queue->erase(queue->begin()); in addPacket()
DAAMRAssembler.cpp103 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 …]
DARawAudioAssembler.cpp55 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
57 if (queue->empty()) { in addPacket()
62 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
63 while (it != queue->end()) { in addPacket()
68 it = queue->erase(it); in addPacket()
71 if (queue->empty()) { in addPacket()
76 sp<ABuffer> buffer = *queue->begin(); in addPacket()
90 queue->erase(queue->begin()); in addPacket()
102 queue->erase(queue->begin()); in addPacket()
DAMPEG4ElementaryAssembler.cpp208 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()
368 queue->erase(queue->begin()); in addPacket()
DAMPEG4AudioAssembler.cpp491 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
493 if (queue->empty()) { in addPacket()
498 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
499 while (it != queue->end()) { in addPacket()
504 it = queue->erase(it); in addPacket()
507 if (queue->empty()) { in addPacket()
512 sp<ABuffer> buffer = *queue->begin(); in addPacket()
535 queue->erase(queue->begin()); in addPacket()
/frameworks/support/samples/Support4Demos/src/com/example/android/supportv4/media/utils/
DQueueHelper.java80 public static int getMusicIndexOnQueue(Iterable<MediaSessionCompat.QueueItem> queue, in getMusicIndexOnQueue() argument
83 for (MediaSessionCompat.QueueItem item : queue) { in getMusicIndexOnQueue()
92 public static int getMusicIndexOnQueue(Iterable<MediaSessionCompat.QueueItem> queue, in getMusicIndexOnQueue() argument
95 for (MediaSessionCompat.QueueItem item : queue) { in getMusicIndexOnQueue()
106 List<MediaSessionCompat.QueueItem> queue = new ArrayList<>(); in convertToQueue() local
123 queue.add(item); in convertToQueue()
125 return queue; in convertToQueue()
147 public static boolean isIndexPlayable(int index, List<MediaSessionCompat.QueueItem> queue) { in isIndexPlayable() argument
148 return (queue != null && index >= 0 && index < queue.size()); in isIndexPlayable()
/frameworks/base/core/jni/
Dandroid_view_InputQueue.cpp204 sp<InputQueue> queue = InputQueue::createQueue(queueWeak, messageQueue->getLooper()); in nativeInit() local
205 if (!queue.get()) { in nativeInit()
209 queue->incStrong(&gInputQueueClassInfo); in nativeInit()
210 return reinterpret_cast<jlong>(queue.get()); in nativeInit()
214 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); in nativeDispose() local
215 queue->detachLooper(); in nativeDispose()
216 queue->decStrong(&gInputQueueClassInfo); in nativeDispose()
221 InputQueue* queue = reinterpret_cast<InputQueue*>(ptr); in nativeSendKeyEvent() local
222 KeyEvent* event = queue->createKeyEvent(); in nativeSendKeyEvent()
225 queue->recycleInputEvent(event); in nativeSendKeyEvent()
[all …]
/frameworks/base/core/java/android/hardware/
DSystemSensorManager.java152 SensorEventQueue queue = mSensorListeners.get(listener); in registerListenerImpl() local
153 if (queue == null) { in registerListenerImpl()
158 queue = new SensorEventQueue(listener, looper, this, fullClassName); in registerListenerImpl()
159 if (!queue.addSensor(sensor, delayUs, maxBatchReportLatencyUs)) { in registerListenerImpl()
160 queue.dispose(); in registerListenerImpl()
163 mSensorListeners.put(listener, queue); in registerListenerImpl()
166 return queue.addSensor(sensor, delayUs, maxBatchReportLatencyUs); in registerListenerImpl()
180 SensorEventQueue queue = mSensorListeners.get(listener); in unregisterListenerImpl() local
181 if (queue != null) { in unregisterListenerImpl()
184 result = queue.removeAllSensors(); in unregisterListenerImpl()
[all …]
/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/
DFrameQueue.java38 public void attachQueue(FrameQueue queue) { in attachQueue() argument
39 mAttachedQueues.add(queue); in attachQueue()
51 private void buildQueueImpl(FrameQueue queue) { in buildQueueImpl() argument
52 QueueImpl queueImpl = queue.new SingleFrameQueueImpl(); in buildQueueImpl()
53 queue.mQueueImpl = queueImpl; in buildQueueImpl()
58 for (FrameQueue queue : mAttachedQueues) { in buildType()
59 result = FrameType.merge(result, queue.mType); in buildType()
/frameworks/native/include/android/
Dsensor.h390 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue);
399 int ASensorEventQueue_registerSensor(ASensorEventQueue* queue, ASensor const* sensor,
405 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor);
410 int ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor);
419 int ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec);
426 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue);
441 ssize_t ASensorEventQueue_getEvents(ASensorEventQueue* queue,
/frameworks/av/media/libstagefright/
DMediaCodecSource.cpp145 Mutexed<Queue>::Locked queue(mQueue); in readBuffer() local
146 return queue->readBuffer(mbuf); in readBuffer()
184 Mutexed<Queue>::Locked queue(mQueue); in stop() local
185 queue->mPulling = false; in stop()
186 …interrupt = queue->mReadPendingSince && (queue->mReadPendingSince < ALooper::GetNowUs() - 1000000); in stop()
187 queue->flush(); // flush any unprocessed pulled buffers in stop()
207 Mutexed<Queue>::Locked queue(mQueue); in pause() local
208 queue->mPaused = true; in pause()
212 Mutexed<Queue>::Locked queue(mQueue); in resume() local
213 queue->mPaused = false; in resume()
[all …]
/frameworks/rs/api/
Drs_io.spec30 summary: Receive new content from the queue
32 Receive a new set of contents from the queue.
45 summary: Send new content to the queue
47 Send the contents of the Allocation to the queue.
63 message queue is full.
85 until there is room on the message queue for this message.
/frameworks/base/core/java/android/hardware/camera2/legacy/
DRequestHandlerThread.java99 MessageQueue queue = handler.getLooper().getQueue(); in waitUntilIdle() local
100 if (queue.isIdle()) { in waitUntilIdle()
104 queue.addIdleHandler(mIdleHandler); in waitUntilIdle()
107 if (queue.isIdle()) { in waitUntilIdle()
/frameworks/base/core/java/android/os/
DHandler.java605 MessageQueue queue = mQueue; in sendMessageAtTime() local
606 if (queue == null) { in sendMessageAtTime()
612 return enqueueMessage(queue, msg, uptimeMillis); in sendMessageAtTime()
628 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue() local
629 if (queue == null) { in sendMessageAtFrontOfQueue()
635 return enqueueMessage(queue, msg, 0); in sendMessageAtFrontOfQueue()
638 private boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) { in enqueueMessage() argument
643 return queue.enqueueMessage(msg, uptimeMillis); in enqueueMessage()
/frameworks/base/tests/CoreTests/android/core/
DHeapTest.java230 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/
DLoaderTestCase.java57 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/main/java/com/android/volley/toolbox/
DVolley.java65 RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network); in newRequestQueue() local
66 queue.start(); in newRequestQueue()
68 return queue; in newRequestQueue()
/frameworks/support/samples/Support4Demos/src/com/example/android/supportv4/media/
DQueueFragment.java79 List<MediaSessionCompat.QueueItem> queue = mMediaController.getQueue();
80 if (queue != null) {
83 mQueueAdapter.addAll(queue);
124 public void onQueueChanged(List<MediaSessionCompat.QueueItem> queue) {
125 Log.d(TAG, "onQueueChanged " + queue);
126 if (queue != null) {
129 mQueueAdapter.addAll(queue);

123456