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

1234

/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...]
H A DAAVCAssembler.h52 AssemblyStatus addFragmentedNALUnit(List<sp<ABuffer> > *queue);
/frameworks/base/native/android/
H A Dsensor.cpp91 sp<SensorEventQueue> queue = local
93 if (queue != 0) {
94 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data);
95 queue->looper = looper;
96 queue->incStrong(manager);
98 return static_cast<ASensorEventQueue*>(queue.get());
104 sp<SensorEventQueue> queue = static_cast<SensorEventQueue*>(inQueue); local
105 ALooper_removeFd(queue->looper, queue->getFd());
106 queue
112 ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor) argument
118 ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor) argument
124 ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec) argument
131 ASensorEventQueue_hasEvents(ASensorEventQueue* queue) argument
149 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 "
H A DOutputPort.java63 * frame data, you can push it into the output queue using {@link #pushFrame(Frame)}. Note,
64 * that the Frame returned is owned by the queue. If you wish to hold on to the frame, you
89 * @param frame the frame to push to the output queue.
92 // Some queues allow pushing without fetching, so we need to make sure queue is open
168 void setQueue(FrameQueue queue) { argument
169 mQueue = queue;
/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/native/include/android/
H A Dsensor.h238 * Creates a new sensor event queue and associate it with a looper.
244 * Destroys the event queue and free all resources associated to it.
246 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue);
254 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor);
259 int ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor);
268 int ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec);
272 * sensor queue. Returns 1 if the queue has events; 0 if
275 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue);
278 * Returns the next available events from the 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/rs/api/
H A Drs_io.spec30 summary: Receive new content from the queue
32 Receive a new set of contents from the queue.
41 summary: Send new content to the queue
43 Send the contents of the Allocation to the queue.
55 message queue is full.
77 until there is room on the message queue for this message.
/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.java123 SensorEventQueue queue = mSensorListeners.get(listener);
124 if (queue == null) {
129 queue = new SensorEventQueue(listener, looper, this, fullClassName);
130 if (!queue.addSensor(sensor, delayUs, maxBatchReportLatencyUs)) {
131 queue.dispose();
134 mSensorListeners.put(listener, queue);
137 return queue.addSensor(sensor, delayUs, maxBatchReportLatencyUs);
151 SensorEventQueue queue = mSensorListeners.get(listener);
152 if (queue != null) {
155 result = queue
[all...]
/frameworks/av/media/libstagefright/include/
H A DTimedEventQueue.h46 virtual void fire(TimedEventQueue *queue, int64_t now_us) = 0;
63 PMDeathRecipient(TimedEventQueue *queue) : mQueue(queue) {} argument
83 // events are discarded, otherwise the queue will stop (and this call
87 // Posts an event to the front of the queue (after all events that
100 // Returns true iff event is currently in the queue and has been
102 // removed from the queue and won't fire.
125 virtual void fire(TimedEventQueue *queue, int64_t /* now_us */) { argument
126 queue->mStopped = true;
/frameworks/base/media/java/android/media/session/
H A DISessionControllerCallback.aidl35 void onQueueChanged(in ParceledListSlice queue);
/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...]
/frameworks/base/core/java/android/os/
H A DHandler.java28 * queue. When you create a new Handler, it is bound to the thread /
29 * message queue of the thread that is creating it -- from that point on,
30 * it will deliver messages and runnables to that message queue and execute
31 * them as they come out of the message queue.
42 * you to enqueue Runnable objects to be called by the message queue when
49 * allow the item to be processed as soon as the message queue is ready
56 * running a message queue that takes care of managing the top-level
62 * in the Handler's message queue and processed when appropriate.
314 * Causes the Runnable r to be added to the message queue.
321 * message queue
626 enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) argument
[all...]
/frameworks/base/tools/aapt2/
H A DSourceXmlPullParser.h24 #include <queue>
81 std::queue<EventData> mEventQueue;

Completed in 618 milliseconds

1234