/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.get()); 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...] |
/frameworks/base/core/proto/android/os/ |
H A D | looper.proto | 29 android.os.MessageQueueProto queue = 4;
|
/frameworks/hardware/interfaces/sensorservice/libsensorndkbridge/ |
H A D | ALooper.cpp | 31 void ALooper::signalSensorEvents(ASensorEventQueue *queue) { argument 33 mReadyQueues.insert(queue); 75 for (auto queue : mReadyQueues) { 76 queue->dispatchCallback(); 90 void ALooper::invalidateSensorQueue(ASensorEventQueue *queue) { argument 92 mReadyQueues.erase(queue);
|
H A D | ASensorManager.cpp | 158 sp<ASensorEventQueue> queue = local 161 ::android::hardware::setMinSchedulerPolicy(queue, SCHED_FIFO, 98); 165 queue, [&](const sp<IEventQueue> &queueImpl, auto tmpResult) { 171 queue->setImpl(queueImpl); 175 LOG(ERROR) << "FAILED to create event queue"; 179 queue->incStrong(NULL /* id */); 181 LOG(VERBOSE) << "Returning event queue " << queue.get(); 182 return queue.get(); 185 void ASensorManager::destroyEventQueue(ASensorEventQueue *queue) { argument 262 ASensorManager_destroyEventQueue( ASensorManager* manager, ASensorEventQueue* queue) argument 301 ASensorEventQueue_registerSensor( ASensorEventQueue* queue, ASensor const* sensor, int32_t samplingPeriodUs, int64_t maxBatchReportLatencyUs) argument 312 ASensorEventQueue_enableSensor( ASensorEventQueue* queue, ASensor const* sensor) argument 319 ASensorEventQueue_disableSensor( ASensorEventQueue* queue, ASensor const* sensor) argument 326 ASensorEventQueue_setEventRate( ASensorEventQueue* queue, ASensor const* sensor, int32_t usec) argument 334 ASensorEventQueue_hasEvents(ASensorEventQueue* queue) argument 339 ASensorEventQueue_getEvents( ASensorEventQueue* queue, ASensorEvent* events, size_t count) argument [all...] |
H A D | ALooper.h | 32 void signalSensorEvents(ASensorEventQueue *queue); 37 void invalidateSensorQueue(ASensorEventQueue *queue);
|
/frameworks/base/native/android/ |
H A D | sensor.cpp | 58 if (queue == nullptr) { \ 59 ERROR_INVALID_PARAMETER("queue cannot be NULL"); \ 113 sp<SensorEventQueue> queue = local 115 if (queue != 0) { 116 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data); 117 queue->looper = looper; 118 queue->incStrong(manager); 120 return static_cast<ASensorEventQueue*>(queue.get()); 123 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue) { argument 127 sp<SensorEventQueue> q = static_cast<SensorEventQueue*>(queue); 208 ASensorEventQueue_registerSensor(ASensorEventQueue* queue, ASensor const* sensor, int32_t samplingPeriodUs, int64_t maxBatchReportLatencyUs) argument 222 ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor) argument 230 ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor) argument 238 ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec) argument 251 ASensorEventQueue_hasEvents(ASensorEventQueue* queue) argument 270 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/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/services/tests/servicestests/src/com/android/server/pm/ |
H A D | UserManagerServiceIdRecyclingTest.java | 92 LinkedHashSet<Integer> queue = new LinkedHashSet<>(); 96 assertTrue("Returned id should not be recent. Id=" + userId + ". Recents=" + queue, 97 queue.add(userId)); 98 if (queue.size() > UserManagerService.MAX_RECENTLY_REMOVED_IDS_SIZE) { 99 queue.remove(queue.iterator().next());
|
/frameworks/av/media/mtp/ |
H A D | AsyncIO.cpp | 21 #include <queue> 55 std::queue<std::unique_ptr<struct aiocb>> queue; member in namespace:__anon955 63 queue_cond.wait(lk, []{return !queue.empty() || done;}); 64 if (queue.empty() && done) { 67 std::unique_ptr<struct aiocb> aiocbp = std::move(queue.front()); 68 queue.pop(); 79 queue_cond.wait(lk, []{return !queue.empty() || done;}); 80 if (queue.empty() && done) { 83 std::unique_ptr<struct aiocb> aiocbp = std::move(queue [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/include/android/ |
H A D | sensor.h | 416 * Creates a new sensor event queue and associate it with a looper. 426 * Destroys the event queue and free all resources associated to it. 428 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue); 530 int ASensorEventQueue_registerSensor(ASensorEventQueue* queue, ASensor const* sensor, 536 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor); 541 int ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor); 550 int ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec); 554 * sensor queue. Returns 1 if the queue has events; 0 if 557 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue); [all...] |
/frameworks/rs/script_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/hardware/interfaces/sensorservice/1.0/ |
H A D | ISensorManager.hal | 107 * Create a sensor event queue. 109 * Create a sensor event queue with an IEventQueueCallback object. 110 * Subsequently, one can enable sensors on the event queue so that sensor 114 * @return queue the event queue created. null on failure. 119 generates (IEventQueue queue, Result result);
|
/frameworks/native/cmds/surfacereplayer/replayer/ |
H A D | BufferQueueScheduler.h | 30 #include <queue> 76 std::queue<BufferEvent> mBufferEvents;
|