/frameworks/av/media/libstagefright/rtsp/ |
H A D | AMPEG2TSAssembler.cpp | 55 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 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 | 55 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 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(); 368 queue->erase(queue [all...] |
H A D | AAVCAssembler.h | 52 AssemblyStatus addFragmentedNALUnit(List<sp<ABuffer> > *queue);
|
/frameworks/base/native/android/ |
H A D | sensor.cpp | 91 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 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/volley/src/test/java/com/android/volley/ |
H A D | RequestQueueIntegrationTest.java | 84 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 D | RequestQueueTest.java | 49 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 D | RequestHandlerThread.java | 28 * 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 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/base/core/jni/ |
H A D | android_view_InputQueue.cpp | 204 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 D | sensor.h | 238 * 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 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/rs/api/ |
H A D | rs_io.spec | 30 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 D | Volley.java | 65 RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network); 66 queue.start(); 68 return queue;
|
/frameworks/base/core/java/android/hardware/ |
H A D | SystemSensorManager.java | 123 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 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/media/java/android/media/session/ |
H A D | ISessionControllerCallback.aidl | 35 void onQueueChanged(in ParceledListSlice queue);
|
/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/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 626 enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) argument [all...] |
/frameworks/base/tools/aapt2/ |
H A D | SourceXmlPullParser.h | 24 #include <queue> 81 std::queue<EventData> mEventQueue;
|