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

12345

/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);
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...]
H A DAMPEG4ElementaryAssembler.cpp208 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 Dsensor.cpp87 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 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/volley/src/test/java/com/android/volley/
H A DRequestQueueIntegrationTest.java84 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 DRequestQueueTest.java49 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 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/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/vulkan/include/vulkan/
H A Dvk_android_native_buffer.h51 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 DVolley.java65 RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network);
66 queue.start();
68 return queue;
/frameworks/base/core/java/android/hardware/
H A DSystemSensorManager.java152 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 Dsensor.h378 * 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 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/native/vulkan/libvulkan/
H A Dapi.h50 inline DeviceData& GetData(VkQueue queue) { argument
51 return driver::GetData(queue).opaque_api_data;
/frameworks/base/tests/CoreTests/android/core/
H A DHeapTest.java230 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...]

Completed in 680 milliseconds

12345