Searched refs:queue (Results 1 - 25 of 137) sorted by relevance

123456

/frameworks/base/libs/hwui/tests/unit/
H A DLayerUpdateQueueTests.cpp28 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 DAMPEG2TSAssembler.cpp55 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 DAH263Assembler.cpp54 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 DARawAudioAssembler.cpp55 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 DAAVCAssembler.cpp48 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 DAAMRAssembler.cpp103 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 Dlooper.proto29 android.os.MessageQueueProto queue = 4;
/frameworks/hardware/interfaces/sensorservice/libsensorndkbridge/
H A DALooper.cpp31 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 DASensorManager.cpp158 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 DALooper.h32 void signalSensorEvents(ASensorEventQueue *queue);
37 void invalidateSensorQueue(ASensorEventQueue *queue);
/frameworks/base/native/android/
H A Dsensor.cpp58 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 Dinput.cpp273 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 DRequestHandlerThread.java28 * 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 DFrameQueue.java38 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 DQueueHelper.java34 * 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 DQueueHelper.java34 * 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 Dandroid_view_InputQueue.cpp204 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 DUserManagerServiceIdRecyclingTest.java92 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 DAsyncIO.cpp21 #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 DLoaderTestCase.java56 // 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 Dsensor.h416 * 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 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/media/java/android/media/session/
H A DISessionControllerCallback.aidl35 void onQueueChanged(in ParceledListSlice queue);
/frameworks/hardware/interfaces/sensorservice/1.0/
H A DISensorManager.hal107 * 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 DBufferQueueScheduler.h30 #include <queue>
76 std::queue<BufferEvent> mBufferEvents;

Completed in 547 milliseconds

123456