Searched defs:queue (Results 1 - 25 of 30) sorted by relevance

12

/frameworks/base/core/java/android/view/
H A DInputQueue.java20 * An input queue provides a mechanism for an application to receive incoming
33 void onInputQueueCreated(InputQueue queue); argument
39 void onInputQueueDestroyed(InputQueue queue); argument
/frameworks/av/media/libstagefright/rtsp/
H A DARTPSource.h44 List<sp<ABuffer> > *queue() { return &mQueue; } function in struct:android::ARTPSource
H A DAMPEG2TSAssembler.cpp53 List<sp<ABuffer> > *queue = source->queue(); local
55 if (queue->empty()) {
60 List<sp<ABuffer> >::iterator it = queue->begin();
61 while (it != queue->end()) {
66 it = queue->erase(it);
69 if (queue->empty()) {
74 sp<ABuffer> buffer = *queue->begin();
88 queue->erase(queue
[all...]
H A DAH263Assembler.cpp51 List<sp<ABuffer> > *queue = source->queue(); local
53 if (queue->empty()) {
58 List<sp<ABuffer> >::iterator it = queue->begin();
59 while (it != queue->end()) {
64 it = queue->erase(it);
67 if (queue->empty()) {
72 sp<ABuffer> buffer = *queue->begin();
96 queue->erase(queue
[all...]
H A DARawAudioAssembler.cpp53 List<sp<ABuffer> > *queue = source->queue(); local
55 if (queue->empty()) {
60 List<sp<ABuffer> >::iterator it = queue->begin();
61 while (it != queue->end()) {
66 it = queue->erase(it);
69 if (queue->empty()) {
74 sp<ABuffer> buffer = *queue->begin();
88 queue->erase(queue
[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 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
173 addFragmentedNALUnit( List<sp<ABuffer> > *queue) argument
[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();
359 queue->erase(queue
[all...]
H A DAMPEG4AudioAssembler.cpp480 List<sp<ABuffer> > *queue = source->queue(); local
482 if (queue->empty()) {
487 List<sp<ABuffer> >::iterator it = queue->begin();
488 while (it != queue->end()) {
493 it = queue->erase(it);
496 if (queue->empty()) {
501 sp<ABuffer> buffer = *queue->begin();
524 queue->erase(queue
[all...]
/frameworks/support/volley/src/com/android/volley/
H A DNetworkDispatcher.java24 * Provides a thread for performing network dispatch from a queue of requests.
26 * Requests added to the specified queue are processed from the network via a
33 /** The queue of requests to service. */
48 * @param queue Queue of incoming requests for triage
53 public NetworkDispatcher(BlockingQueue<Request> queue, argument
56 mQueue = queue;
64 * the queue, they are not guaranteed to be processed.
77 // Take a request from the queue.
88 request.addMarker("network-queue-take");
/frameworks/av/media/libstagefright/include/
H A DTimedEventQueue.h45 virtual void fire(TimedEventQueue *queue, int64_t now_us) = 0;
67 // events are discarded, otherwise the queue will stop (and this call
71 // Posts an event to the front of the queue (after all events that
84 // Returns true iff event is currently in the queue and has been
86 // removed from the queue and won't fire.
106 virtual void fire(TimedEventQueue *queue, int64_t now_us) { argument
107 queue->mStopped = true;
/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.cpp132 sp<SensorEventQueue> queue; local
143 queue = new SensorEventQueue(connection);
146 return queue;
/frameworks/native/services/surfaceflinger/
H A DMessageQueue.h71 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } argument
H A DMessageQueue.cpp163 MessageQueue* queue = reinterpret_cast<MessageQueue *>(data); local
164 return queue->eventReceiver(fd, events);
/frameworks/base/core/java/android/hardware/usb/
H A DUsbRequest.java29 * or asynchronously via {@link #queue} and {@link UsbDeviceConnection#requestWait}.
44 // for temporarily saving current buffer across queue and dequeue
100 * maintaining state between calls to {@link #queue} and
113 * maintaining state between calls to {@link #queue} and
135 public boolean queue(ByteBuffer buffer, int length) { method in class:UsbRequest
169 * Cancels a pending queue operation.
/frameworks/base/native/android/
H A Dsensor.cpp65 sp<SensorEventQueue> queue = local
67 if (queue != 0) {
68 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data);
69 queue->looper = looper;
70 queue->incStrong(manager);
72 return static_cast<ASensorEventQueue*>(queue.get());
78 sp<SensorEventQueue> queue = static_cast<SensorEventQueue*>(inQueue); local
79 ALooper_removeFd(queue->looper, queue->getFd());
80 queue
86 ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor) argument
92 ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor) argument
98 ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec) argument
105 ASensorEventQueue_hasEvents(ASensorEventQueue* queue) argument
123 ASensorEventQueue_getEvents(ASensorEventQueue* queue, ASensorEvent* events, size_t count) argument
[all...]
H A Dinput.cpp270 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper, argument
272 queue->attachLooper(looper, ident, callback, data);
275 void AInputQueue_detachLooper(AInputQueue* queue) { argument
276 queue->detachLooper();
279 int32_t AInputQueue_hasEvents(AInputQueue* queue) { argument
280 return queue->hasEvents();
283 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent) { argument
284 return queue->getEvent(outEvent);
287 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event) { argument
288 return queue
291 AInputQueue_finishEvent(AInputQueue* queue, AInputEvent* event, int handled) argument
[all...]
/frameworks/av/media/libmediaplayerservice/nuplayer/
H A DNuPlayerRenderer.cpp234 ALOGV("audio queue has %d frames left to play",
455 // EOS signalled on either queue.
529 // two queues has data, we may starve that queue by not requesting
532 // corresponding discontinuity on the other queue.
558 void NuPlayer::Renderer::flushQueue(List<QueueEntry> *queue) { argument
559 while (!queue->empty()) {
560 QueueEntry *entry = &*queue->begin();
566 queue->erase(queue->begin());
647 ALOGV("now paused audio queue ha
[all...]
/frameworks/base/core/java/android/hardware/
H A DSystemSensorManager.java395 static native void sensors_destroy_queue(int queue); argument
396 static native boolean sensors_enable_sensor(int queue, String name, int sensor, int enable); argument
397 static native int sensors_data_poll(int queue, float[] values, int[] status, long[] timestamp); argument
/frameworks/base/services/java/com/android/server/am/
H A DBroadcastRecord.java63 BroadcastQueue queue; // the outbound queue handling this broadcast field in class:BroadcastRecord
172 queue = _queue;
/frameworks/base/tests/touchlag/
H A Dtouchlag.cpp251 Queue queue; local
277 queue.push(x, y);
278 queue.get(lag, &lag_x, &lag_y);
/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.
311 * Causes the Runnable r to be added to the message queue.
318 * message queue
613 enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) argument
[all...]
/frameworks/base/core/java/android/app/
H A DNativeActivity.java85 private native int loadNativeCode(String path, String funcname, MessageQueue queue, argument
310 public void onInputQueueCreated(InputQueue queue) { argument
312 mCurInputQueue = queue;
313 onInputChannelCreatedNative(mNativeHandle, queue.getInputChannel());
317 public void onInputQueueDestroyed(InputQueue queue) { argument
320 onInputChannelDestroyedNative(mNativeHandle, queue.getInputChannel());
/frameworks/av/libvideoeditor/lvpp/
H A DPreviewPlayer.cpp66 virtual void fire(TimedEventQueue *queue, int64_t /* now_us */) { argument
1752 // track's queue are played out.

Completed in 5871 milliseconds

12