/frameworks/base/libs/hwui/tests/unit/ |
H A D | LayerUpdateQueueTests.cpp | 28 LayerUpdateQueue queue; local 29 EXPECT_TRUE(queue.entries().empty()); 44 LayerUpdateQueue queue; local 45 queue.enqueueLayerWithDamage(a.get(), Rect(25, 25, 75, 75)); 46 queue.enqueueLayerWithDamage(b.get(), Rect(100, 100, 300, 300)); 47 queue.enqueueLayerWithDamage(c.get(), Rect(.5, .5, .5, .5)); 49 EXPECT_EQ(3u, queue.entries().size()); 51 EXPECT_EQ(a.get(), queue.entries()[0].renderNode); 52 EXPECT_EQ(Rect(25, 25, 75, 75), queue.entries()[0].damage); 53 EXPECT_EQ(b.get(), queue 62 LayerUpdateQueue queue; local 75 LayerUpdateQueue queue; local [all...] |
/frameworks/av/media/libstagefright/rtsp/ |
H A D | AMPEG2TSAssembler.cpp | 55 List<sp<ABuffer> > *queue = source->queue(); local 57 if (queue->empty()) { 62 List<sp<ABuffer> >::iterator it = queue->begin(); 63 while (it != queue->end()) { 68 it = queue->erase(it); 71 if (queue->empty()) { 76 sp<ABuffer> buffer = *queue->begin(); 90 queue->erase(queue [all...] |
H A D | AH263Assembler.cpp | 54 List<sp<ABuffer> > *queue = source->queue(); local 56 if (queue->empty()) { 61 List<sp<ABuffer> >::iterator it = queue->begin(); 62 while (it != queue->end()) { 67 it = queue->erase(it); 70 if (queue->empty()) { 75 sp<ABuffer> buffer = *queue->begin(); 99 queue->erase(queue [all...] |
H A D | ARawAudioAssembler.cpp | 55 List<sp<ABuffer> > *queue = source->queue(); local 57 if (queue->empty()) { 62 List<sp<ABuffer> >::iterator it = queue->begin(); 63 while (it != queue->end()) { 68 it = queue->erase(it); 71 if (queue->empty()) { 76 sp<ABuffer> buffer = *queue->begin(); 90 queue->erase(queue [all...] |
H A D | AAVCAssembler.cpp | 48 List<sp<ABuffer> > *queue = source->queue(); local 50 if (queue->empty()) { 55 List<sp<ABuffer> >::iterator it = queue->begin(); 56 while (it != queue->end()) { 61 it = queue->erase(it); 64 if (queue->empty()) { 69 sp<ABuffer> buffer = *queue->begin(); 87 queue->erase(queue 180 addFragmentedNALUnit( List<sp<ABuffer> > *queue) argument [all...] |
H A D | AAMRAssembler.cpp | 103 List<sp<ABuffer> > *queue = source->queue(); local 105 if (queue->empty()) { 110 List<sp<ABuffer> >::iterator it = queue->begin(); 111 while (it != queue->end()) { 116 it = queue->erase(it); 119 if (queue->empty()) { 124 sp<ABuffer> buffer = *queue->begin(); 138 queue->erase(queue [all...] |
H A D | AMPEG4ElementaryAssembler.cpp | 208 List<sp<ABuffer> > *queue = source->queue(); local 210 if (queue->empty()) { 215 List<sp<ABuffer> >::iterator it = queue->begin(); 216 while (it != queue->end()) { 221 it = queue->erase(it); 224 if (queue->empty()) { 229 sp<ABuffer> buffer = *queue->begin(); 368 queue->erase(queue [all...] |
/frameworks/base/native/android/ |
H A D | sensor.cpp | 87 sp<SensorEventQueue> queue = local 89 if (queue != 0) { 90 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data); 91 queue->looper = looper; 92 queue->incStrong(manager); 94 return static_cast<ASensorEventQueue*>(queue.get()); 100 sp<SensorEventQueue> queue = static_cast<SensorEventQueue*>(inQueue); local 101 ALooper_removeFd(queue->looper, queue->getFd()); 102 queue 108 ASensorEventQueue_registerSensor(ASensorEventQueue* queue, ASensor const* sensor, int32_t samplingPeriodUs, int maxBatchReportLatencyUs) argument 116 ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor) argument 122 ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor) argument 128 ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec) argument 135 ASensorEventQueue_hasEvents(ASensorEventQueue* queue) argument 153 ASensorEventQueue_getEvents(ASensorEventQueue* queue, ASensorEvent* events, size_t count) argument [all...] |
H A D | input.cpp | 273 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper, argument 275 InputQueue* iq = static_cast<InputQueue*>(queue); 280 void AInputQueue_detachLooper(AInputQueue* queue) { argument 281 InputQueue* iq = static_cast<InputQueue*>(queue); 285 int32_t AInputQueue_hasEvents(AInputQueue* queue) { argument 286 InputQueue* iq = static_cast<InputQueue*>(queue); 290 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent) { argument 291 InputQueue* iq = static_cast<InputQueue*>(queue); 298 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event) { argument 299 InputQueue* iq = static_cast<InputQueue*>(queue); 304 AInputQueue_finishEvent(AInputQueue* queue, AInputEvent* event, int handled) argument [all...] |
/frameworks/volley/src/test/java/com/android/volley/ |
H A D | RequestQueueIntegrationTest.java | 84 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); 85 queue.addRequestFinishedListener(listener); 86 queue.add(lowerPriorityReq); 87 queue.add(higherPriorityReq); 88 queue.start(); 97 queue.stop(); 122 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 3, mDelivery); 123 queue.addRequestFinishedListener(listener); 124 queue.add(req1); 125 queue [all...] |
H A D | RequestQueueTest.java | 49 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 0, mDelivery); 61 queue.add(req1); // A 62 queue.add(req2); // B 63 queue.add(req3); // A 64 queue.cancelAll(tagA); 65 queue.add(req4); // A
|
/frameworks/base/core/java/android/hardware/camera2/legacy/ |
H A D | RequestHandlerThread.java | 28 * Ensure that the MessageQueue's idle handler gets run by poking the message queue; 29 * normally if the message queue is already idle, the idle handler won't get invoked. 99 MessageQueue queue = handler.getLooper().getQueue(); 100 if (queue.isIdle()) { 104 queue.addIdleHandler(mIdleHandler); 107 if (queue.isIdle()) {
|
/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
H A D | FrameQueue.java | 38 public void attachQueue(FrameQueue queue) { argument 39 mAttachedQueues.add(queue); 51 private void buildQueueImpl(FrameQueue queue) { argument 52 QueueImpl queueImpl = queue.new SingleFrameQueueImpl(); 53 queue.mQueueImpl = queueImpl; 58 for (FrameQueue queue : mAttachedQueues) { 59 result = FrameType.merge(result, queue.mType); 67 throw new RuntimeException("Cannot build connection queue '" + queueName + "' as "
|
/frameworks/support/frameworks/support/samples/Support4Demos/src/com/example/android/supportv4/media/utils/ |
H A D | QueueHelper.java | 34 * Utility class to help on queue related tasks. 47 Log.e(TAG, "Could not build a playing queue for this mediaId: " + mediaId); 53 Log.d(TAG, "Creating playing queue for " + categoryType + ", " + categoryValue); 74 Log.d(TAG, "Creating playing queue for musics from search " + query); 80 public static int getMusicIndexOnQueue(Iterable<MediaSessionCompat.QueueItem> queue, argument 83 for (MediaSessionCompat.QueueItem item : queue) { 92 public static int getMusicIndexOnQueue(Iterable<MediaSessionCompat.QueueItem> queue, argument 95 for (MediaSessionCompat.QueueItem item : queue) { 106 List<MediaSessionCompat.QueueItem> queue = new ArrayList<>(); 110 // We create a hierarchy-aware mediaID, so we know what the queue i 147 isIndexPlayable(int index, List<MediaSessionCompat.QueueItem> queue) argument [all...] |
/frameworks/support/samples/Support4Demos/src/com/example/android/supportv4/media/utils/ |
H A D | QueueHelper.java | 34 * Utility class to help on queue related tasks. 47 Log.e(TAG, "Could not build a playing queue for this mediaId: " + mediaId); 53 Log.d(TAG, "Creating playing queue for " + categoryType + ", " + categoryValue); 74 Log.d(TAG, "Creating playing queue for musics from search " + query); 80 public static int getMusicIndexOnQueue(Iterable<MediaSessionCompat.QueueItem> queue, argument 83 for (MediaSessionCompat.QueueItem item : queue) { 92 public static int getMusicIndexOnQueue(Iterable<MediaSessionCompat.QueueItem> queue, argument 95 for (MediaSessionCompat.QueueItem item : queue) { 106 List<MediaSessionCompat.QueueItem> queue = new ArrayList<>(); 110 // We create a hierarchy-aware mediaID, so we know what the queue i 147 isIndexPlayable(int index, List<MediaSessionCompat.QueueItem> queue) argument [all...] |
/frameworks/base/core/jni/ |
H A D | android_view_InputQueue.cpp | 204 sp<InputQueue> queue = InputQueue::createQueue(queueWeak, messageQueue->getLooper()); local 205 if (!queue.get()) { 209 queue->incStrong(&gInputQueueClassInfo); 210 return reinterpret_cast<jlong>(queue.get()); 214 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); local 215 queue->detachLooper(); 216 queue->decStrong(&gInputQueueClassInfo); 221 InputQueue* queue = reinterpret_cast<InputQueue*>(ptr); local 222 KeyEvent* event = queue->createKeyEvent(); 225 queue 239 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); local [all...] |
/frameworks/base/test-runner/src/android/test/ |
H A D | LoaderTestCase.java | 56 // The test thread blocks on this queue until the loader puts it's result in 57 final ArrayBlockingQueue<T> queue = new ArrayBlockingQueue<T>(1); 60 // when it puts the result into the blocking queue 70 queue.add(data); 88 // Block on the queue waiting for the result of the load to be inserted 92 result = queue.take();
|
/frameworks/native/vulkan/include/vulkan/ |
H A D | vk_android_native_buffer.h | 51 typedef VkResult (VKAPI_PTR *PFN_vkQueueSignalReleaseImageANDROID)(VkQueue queue, uint32_t waitSemaphoreCount, const VkSemaphore* pWaitSemaphores, VkImage image, int* pNativeFenceFd); 68 VkQueue queue, 81 VkQueue queue,
|
/frameworks/volley/src/main/java/com/android/volley/toolbox/ |
H A D | Volley.java | 65 RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network); 66 queue.start(); 68 return queue;
|
/frameworks/base/core/java/android/hardware/ |
H A D | SystemSensorManager.java | 152 SensorEventQueue queue = mSensorListeners.get(listener); 153 if (queue == null) { 158 queue = new SensorEventQueue(listener, looper, this, fullClassName); 159 if (!queue.addSensor(sensor, delayUs, maxBatchReportLatencyUs)) { 160 queue.dispose(); 163 mSensorListeners.put(listener, queue); 166 return queue.addSensor(sensor, delayUs, maxBatchReportLatencyUs); 180 SensorEventQueue queue = mSensorListeners.get(listener); 181 if (queue != null) { 184 result = queue [all...] |
/frameworks/native/include/android/ |
H A D | sensor.h | 378 * Creates a new sensor event queue and associate it with a looper. 388 * Destroys the event queue and free all resources associated to it. 390 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); 423 * sensor queue. Returns 1 if the queue has events; 0 if 426 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue); [all...] |
/frameworks/rs/api/ |
H A D | rs_io.spec | 30 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/media/java/android/media/session/ |
H A D | ISessionControllerCallback.aidl | 35 void onQueueChanged(in ParceledListSlice queue);
|
/frameworks/native/vulkan/libvulkan/ |
H A D | api.h | 50 inline DeviceData& GetData(VkQueue queue) { argument 51 return driver::GetData(queue).opaque_api_data;
|
/frameworks/base/tests/CoreTests/android/core/ |
H A D | HeapTest.java | 230 ReferenceQueue<Object> queue) { 233 refs[i] = new PhantomReference<Object>(objects[i], queue); 238 ReferenceQueue<T> queue) { 242 * the queue are marked as enqueued. Once we 243 * pull them off the queue, they will no longer 258 /* Make sure that all of the references on the queue 262 while ((ref = (PhantomReference<T>) queue.poll()) != null) { 273 "unexpected ref on queue"); 316 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); 321 makeRefs(objects, refs, queue); 229 makeRefs(Object objects[], PhantomReference<Object> refs[], ReferenceQueue<Object> queue) argument 237 checkRefs(T objects[], PhantomReference<T> refs[], ReferenceQueue<T> queue) argument [all...] |