Home
last modified time | relevance | path

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

12345

/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 …]
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()
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 …]
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.cpp488 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
490 if (queue->empty()) { in addPacket()
495 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
496 while (it != queue->end()) { in addPacket()
501 it = queue->erase(it); in addPacket()
504 if (queue->empty()) { in addPacket()
509 sp<ABuffer> buffer = *queue->begin(); in addPacket()
532 queue->erase(queue->begin()); in addPacket()
/frameworks/base/native/android/
Dsensor.cpp78 sp<SensorEventQueue> queue = in ASensorManager_createEventQueue() local
80 if (queue != 0) { in ASensorManager_createEventQueue()
81 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data); in ASensorManager_createEventQueue()
82 queue->looper = looper; in ASensorManager_createEventQueue()
83 queue->incStrong(manager); in ASensorManager_createEventQueue()
85 return static_cast<ASensorEventQueue*>(queue.get()); in ASensorManager_createEventQueue()
91 sp<SensorEventQueue> queue = static_cast<SensorEventQueue*>(inQueue); in ASensorManager_destroyEventQueue() local
92 ALooper_removeFd(queue->looper, queue->getFd()); in ASensorManager_destroyEventQueue()
93 queue->decStrong(manager); in ASensorManager_destroyEventQueue()
99 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor) in ASensorEventQueue_enableSensor() 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/base/core/java/android/hardware/
DSystemSensorManager.java116 SensorEventQueue queue = mSensorListeners.get(listener); in registerListenerImpl() local
117 if (queue == null) { in registerListenerImpl()
119 queue = new SensorEventQueue(listener, looper, this); in registerListenerImpl()
120 if (!queue.addSensor(sensor, delayUs, maxBatchReportLatencyUs, reservedFlags)) { in registerListenerImpl()
121 queue.dispose(); in registerListenerImpl()
124 mSensorListeners.put(listener, queue); in registerListenerImpl()
127 return queue.addSensor(sensor, delayUs, maxBatchReportLatencyUs, reservedFlags); in registerListenerImpl()
141 SensorEventQueue queue = mSensorListeners.get(listener); in unregisterListenerImpl() local
142 if (queue != null) { in unregisterListenerImpl()
145 result = queue.removeAllSensors(); in unregisterListenerImpl()
[all …]
/frameworks/volley/tests/src/com/android/volley/
DRequestQueueTest.java73 RequestQueue queue = new RequestQueue(new NoCache(), network, 1, mDelivery); in testAdd_requestProcessedInCorrectOrder() local
76 queue.add(request); in testAdd_requestProcessedInCorrectOrder()
80 queue.start(); in testAdd_requestProcessedInCorrectOrder()
82 queue.stop(); in testAdd_requestProcessedInCorrectOrder()
101 RequestQueue queue = new RequestQueue(new NoCache(), network, 3, mDelivery); in testAdd_dedupeByCacheKey() local
102 queue.add(req1); in testAdd_dedupeByCacheKey()
103 queue.add(req2); in testAdd_dedupeByCacheKey()
104 queue.start(); in testAdd_dedupeByCacheKey()
106 queue.stop(); in testAdd_dedupeByCacheKey()
111 RequestQueue queue = new RequestQueue(new NoCache(), network, 3, mDelivery); in testCancelAll_onlyCorrectTag() local
[all …]
/frameworks/base/core/jni/
Dandroid_view_InputQueue.cpp202 sp<InputQueue> queue = InputQueue::createQueue(queueWeak, messageQueue->getLooper()); in nativeInit() local
203 if (!queue.get()) { in nativeInit()
207 queue->incStrong(&gInputQueueClassInfo); in nativeInit()
208 return reinterpret_cast<jlong>(queue.get()); in nativeInit()
212 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); in nativeDispose() local
213 queue->detachLooper(); in nativeDispose()
214 queue->decStrong(&gInputQueueClassInfo); in nativeDispose()
219 InputQueue* queue = reinterpret_cast<InputQueue*>(ptr); in nativeSendKeyEvent() local
220 KeyEvent* event = queue->createKeyEvent(); in nativeSendKeyEvent()
223 queue->recycleInputEvent(event); in nativeSendKeyEvent()
[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.h233 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue);
241 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor);
246 int ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor);
255 int ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec);
262 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue);
277 ssize_t ASensorEventQueue_getEvents(ASensorEventQueue* queue,
Dinput.h809 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper,
815 void AInputQueue_detachLooper(AInputQueue* queue);
822 int32_t AInputQueue_hasEvents(AInputQueue* queue);
828 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent);
838 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event);
844 void AInputQueue_finishEvent(AInputQueue* queue, AInputEvent* event, int handled);
/frameworks/av/media/libstagefright/include/
DTimedEventQueue.h46 virtual void fire(TimedEventQueue *queue, int64_t now_us) = 0;
63 PMDeathRecipient(TimedEventQueue *queue) : mQueue(queue) {} in PMDeathRecipient()
125 virtual void fire(TimedEventQueue *queue, int64_t /* now_us */) { in fire()
126 queue->mStopped = true; in fire()
/frameworks/base/core/java/android/os/
DHandler.java593 MessageQueue queue = mQueue; in sendMessageAtTime() local
594 if (queue == null) { in sendMessageAtTime()
600 return enqueueMessage(queue, msg, uptimeMillis); in sendMessageAtTime()
616 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue() local
617 if (queue == null) { in sendMessageAtFrontOfQueue()
623 return enqueueMessage(queue, msg, 0); in sendMessageAtFrontOfQueue()
626 private boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) { in enqueueMessage() argument
631 return queue.enqueueMessage(msg, uptimeMillis); in enqueueMessage()
/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/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/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/core/java/android/app/
DNativeActivity.java94 private native long loadNativeCode(String path, String funcname, MessageQueue queue, in loadNativeCode() argument
291 public void onInputQueueCreated(InputQueue queue) { in onInputQueueCreated() argument
293 mCurInputQueue = queue; in onInputQueueCreated()
294 onInputQueueCreatedNative(mNativeHandle, queue.getNativePtr()); in onInputQueueCreated()
298 public void onInputQueueDestroyed(InputQueue queue) { in onInputQueueDestroyed() argument
300 onInputQueueDestroyedNative(mNativeHandle, queue.getNativePtr()); in onInputQueueDestroyed()
/frameworks/native/libs/gui/
DSensorManager.cpp143 sp<SensorEventQueue> queue; in createEventQueue() local
154 queue = new SensorEventQueue(connection); in createEventQueue()
157 return queue; in createEventQueue()
/frameworks/base/docs/html/training/multiple-threads/
Dcreate-threadpool.jd40 {@link java.util.concurrent.ThreadPoolExecutor}, which runs a task from a queue when a thread
41 in its pool becomes free. To run a task, all you have to do is add it to the queue.
102 Define a method in the thread pool class that adds a task to a thread pool's queue. For
187 A queue of tasks
190 The incoming queue from which {@link java.util.concurrent.ThreadPoolExecutor} takes
192 {@link java.lang.Runnable} object from a first-in, first-out queue and attaches it to the
193 thread. You provide this queue object when you create the thread pool, using any queue class
195 requirements of your app, you can choose from the available queue implementations; to learn
203 // A queue of Runnables
206 // Instantiates the queue of Runnables as a LinkedBlockingQueue
/frameworks/support/v7/palette/src/android/support/v7/graphics/
DColorCutQuantizer.java149 private void splitBoxes(final PriorityQueue<Vbox> queue, final int maxSize) { in splitBoxes() argument
150 while (queue.size() < maxSize) { in splitBoxes()
151 final Vbox vbox = queue.poll(); in splitBoxes()
155 queue.offer(vbox.splitBox()); in splitBoxes()
157 queue.offer(vbox); in splitBoxes()
/frameworks/native/services/surfaceflinger/
DMessageQueue.h72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } in Handler() argument

12345