/frameworks/base/native/android/ |
H A D | sensor.cpp | 65 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 D | input.cpp | 273 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/av/media/libstagefright/rtsp/ |
H A D | AMPEG2TSAssembler.cpp | 53 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 D | AH263Assembler.cpp | 54 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 D | ARawAudioAssembler.cpp | 53 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 D | AAVCAssembler.cpp | 48 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 D | AAMRAssembler.cpp | 103 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 D | AMPEG4ElementaryAssembler.cpp | 208 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 D | AAVCAssembler.h | 52 AssemblyStatus addFragmentedNALUnit(List<sp<ABuffer> > *queue);
|
/frameworks/base/core/java/android/hardware/ |
H A D | SystemSensorManager.java | 116 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 D | FrameQueue.java | 38 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 D | OutputPort.java | 63 * 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 D | RequestQueueTest.java | 73 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 D | android_view_InputQueue.cpp | 202 sp<InputQueue> queue = InputQueue::createQueue(queueWeak, messageQueue->getLooper()); local 203 if (!queue.get()) { 207 queue->incStrong(&gInputQueueClassInfo); 208 return reinterpret_cast<jint>(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 D | sensor.h | 199 * Creates a new sensor event queue and associate it with a looper. 205 * Destroys the event queue and free all resources associated to it. 207 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue); 215 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor); 220 int ASensorEventQueue_disableSensor(ASensorEventQueue* queue, ASensor const* sensor); 229 int ASensorEventQueue_setEventRate(ASensorEventQueue* queue, ASensor const* sensor, int32_t usec); 233 * sensor queue. Returns 1 if the queue has events; 0 if 236 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue); 239 * Returns the next available events from the queue [all...] |
H A D | native_activity.h | 196 * 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 D | LoaderTestCase.java | 56 // 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 D | Volley.java | 65 RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network); 66 queue.start(); 68 return queue;
|
/frameworks/av/media/libstagefright/include/ |
H A D | TimedEventQueue.h | 46 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/tests/CoreTests/android/core/ |
H A D | HeapTest.java | 230 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 D | SensorManager.cpp | 132 sp<SensorEventQueue> queue; local 143 queue = new SensorEventQueue(connection); 146 return queue;
|
/frameworks/base/core/java/android/os/ |
H A D | Handler.java | 28 * 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 621 enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) argument [all...] |
/frameworks/native/services/surfaceflinger/ |
H A D | MessageQueue.h | 72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } argument
|
/frameworks/volley/src/com/android/volley/ |
H A D | NetworkDispatcher.java | 26 * Provides a thread for performing network dispatch from a queue of requests. 28 * 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. 79 // Take a request from the queue. 90 request.addMarker("network-queue-take");
|
/frameworks/base/core/java/android/app/ |
H A D | NativeActivity.java | 94 private native int loadNativeCode(String path, String funcname, MessageQueue queue, argument 292 public void onInputQueueCreated(InputQueue queue) { argument 294 mCurInputQueue = queue; 295 onInputQueueCreatedNative(mNativeHandle, queue.getNativePtr()); 299 public void onInputQueueDestroyed(InputQueue queue) { argument 301 onInputQueueDestroyedNative(mNativeHandle, queue.getNativePtr());
|