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

123

/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.cpp78 sp<SensorEventQueue> queue = local
80 if (queue != 0) {
81 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data);
82 queue->looper = looper;
83 queue->incStrong(manager);
85 return static_cast<ASensorEventQueue*>(queue.get());
91 sp<SensorEventQueue> queue = static_cast<SensorEventQueue*>(inQueue); local
92 ALooper_removeFd(queue->looper, queue->getFd());
93 queue
99 ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor) argument
105 ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor) argument
111 ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec) argument
118 ASensorEventQueue_hasEvents(ASensorEventQueue* queue) argument
136 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/
H A DSystemSensorManager.java116 SensorEventQueue queue = mSensorListeners.get(listener);
117 if (queue == null) {
119 queue = new SensorEventQueue(listener, looper, this);
120 if (!queue.addSensor(sensor, delayUs, maxBatchReportLatencyUs, reservedFlags)) {
121 queue.dispose();
124 mSensorListeners.put(listener, queue);
127 return queue.addSensor(sensor, delayUs, maxBatchReportLatencyUs, reservedFlags);
141 SensorEventQueue queue = mSensorListeners.get(listener);
142 if (queue != null) {
145 result = queue
[all...]
/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/volley/tests/src/com/android/volley/
H A DRequestQueueTest.java73 RequestQueue queue = new RequestQueue(new NoCache(), network, 1, mDelivery);
76 queue.add(request);
80 queue.start();
82 queue.stop();
101 RequestQueue queue = new RequestQueue(new NoCache(), network, 3, mDelivery);
102 queue.add(req1);
103 queue.add(req2);
104 queue.start();
106 queue.stop();
111 RequestQueue queue
[all...]
/frameworks/base/core/jni/
H A Dandroid_view_InputQueue.cpp202 sp<InputQueue> queue = InputQueue::createQueue(queueWeak, messageQueue->getLooper()); local
203 if (!queue.get()) {
207 queue->incStrong(&gInputQueueClassInfo);
208 return reinterpret_cast<jlong>(queue.get());
212 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); local
213 queue->detachLooper();
214 queue->decStrong(&gInputQueueClassInfo);
219 InputQueue* queue = reinterpret_cast<InputQueue*>(ptr); local
220 KeyEvent* event = queue->createKeyEvent();
223 queue
237 sp<InputQueue> queue = reinterpret_cast<InputQueue*>(ptr); local
[all...]
/frameworks/native/include/android/
H A Dsensor.h225 * Creates a new sensor event queue and associate it with a looper.
231 * Destroys the event queue and free all resources associated to it.
233 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);
259 * sensor queue. Returns 1 if the queue has events; 0 if
262 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue);
265 * Returns the next available events from the queue
[all...]
H A Dnative_activity.h196 * The input queue for this native activity's window has been created.
197 * You can use the given input queue to start retrieving input events.
199 void (*onInputQueueCreated)(ANativeActivity* activity, AInputQueue* queue);
202 * The input queue for this native activity's window is being destroyed.
206 void (*onInputQueueDestroyed)(ANativeActivity* activity, AInputQueue* queue);
/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/volley/src/com/android/volley/toolbox/
H A DVolley.java65 RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network);
66 queue.start();
68 return queue;
/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/native/libs/gui/
H A DSensorManager.cpp143 sp<SensorEventQueue> queue; local
154 queue = new SensorEventQueue(connection);
157 return queue;
/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/native/services/surfaceflinger/
H A DMessageQueue.h72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } argument
/frameworks/volley/src/com/android/volley/
H A DNetworkDispatcher.java27 * Provides a thread for performing network dispatch from a queue of requests.
29 * Requests added to the specified queue are processed from the network via a
35 /** The queue of requests to service. */
50 * @param queue Queue of incoming requests for triage
55 public NetworkDispatcher(BlockingQueue<Request<?>> queue, argument
58 mQueue = queue;
66 * the queue, they are not guaranteed to be processed.
87 // Take a request from the queue.
98 request.addMarker("network-queue-take");

Completed in 426 milliseconds

123