Searched refs:queue (Results 1 - 25 of 43) 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/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/libstagefright/rtsp/
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 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 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 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 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();
359 queue->erase(queue
[all...]
H A DAAVCAssembler.h52 AssemblyStatus addFragmentedNALUnit(List<sp<ABuffer> > *queue);
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/native/include/android/
H A Dsensor.h166 * Creates a new sensor event queue and associate it with a looper.
172 * Destroys the event queue and free all resources associated to it.
174 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue);
182 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor);
187 int ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor);
196 int ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec);
200 * sensor queue. Returns 1 if the queue has events; 0 if
203 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue);
206 * 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);
H A Dinput.h795 * Input queue
797 * An input queue is the facility through which you retrieve input
804 * Add this input queue to a looper for processing. See
807 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper,
811 * Remove the input queue from the looper it is currently attached to.
813 void AInputQueue_detachLooper(AInputQueue* queue);
817 * input queue. Returns 1 if the queue has events; 0 if
820 int32_t AInputQueue_hasEvents(AInputQueue* queue);
823 * Returns the next available event from the queue
[all...]
/frameworks/base/core/jni/
H A Dandroid_hardware_SensorManager.cpp89 sp<SensorEventQueue> queue(mgr.createEventQueue());
90 queue->incStrong(clazz);
91 return reinterpret_cast<int>(queue.get());
97 sp<SensorEventQueue> queue(reinterpret_cast<SensorEventQueue *>(nativeQueue));
98 if (queue != 0) {
99 queue->decStrong(clazz);
107 sp<SensorEventQueue> queue(reinterpret_cast<SensorEventQueue *>(nativeQueue));
108 if (queue == 0) return JNI_FALSE;
111 res = queue->enableSensor(sensor, delay);
113 res = queue
[all...]
/frameworks/support/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/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/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/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...]
H A DLooper.java108 * Run the message queue in this thread. Be sure to call
116 final MessageQueue queue = me.mQueue;
124 Message msg = queue.next(); // might block
126 // No message indicates that the message queue is quitting.
204 * Posts a synchronization barrier to the Looper's message queue.
206 * Message processing occurs as usual until the message queue encounters the
208 * later synchronous messages in the queue are stalled (prevented from being executed)
218 * the same token to ensure that the message queue resumes normal operation.
/frameworks/native/services/surfaceflinger/
H A DMessageQueue.h71 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } argument
/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/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());

Completed in 2583 milliseconds

12