/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 | ARTPSource.h | 44 List<sp<ABuffer> > *queue() { return &mQueue; } function in struct:android::ARTPSource
|
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 | 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 | 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 | 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...] |
/frameworks/volley/src/com/android/volley/ |
H A D | NetworkDispatcher.java | 27 * 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");
|
/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 | 143 sp<SensorEventQueue> queue; local 154 queue = new SensorEventQueue(connection); 157 return queue;
|
/frameworks/native/services/surfaceflinger/ |
H A D | MessageQueue.h | 72 Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } argument
|
H A D | MessageQueue.cpp | 178 MessageQueue* queue = reinterpret_cast<MessageQueue *>(data); local 179 return queue->eventReceiver(fd, events);
|
/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/cmds/media/src/com/android/commands/media/ |
H A D | Media.java | 206 public void onQueueChanged(ParceledListSlice queue) throws RemoteException { argument 208 + (queue == null ? "null queue" : " size=" + queue.getList().size()));
|
/frameworks/base/core/java/android/hardware/usb/ |
H A D | UsbRequest.java | 29 * 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/core/java/android/view/ |
H A D | InputQueue.java | 30 * An input queue provides a mechanism for an application to receive incoming 148 void onInputQueueCreated(InputQueue queue); argument 154 void onInputQueueDestroyed(InputQueue queue); argument
|
/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;
|
H A D | InputPort.java | 172 * Note, that this returns a frame owned by the input queue. You must detach the frame if you 291 void setQueue(FrameQueue queue) { argument 292 mQueue = queue;
|
/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<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/base/libs/hwui/renderthread/ |
H A D | RenderThread.cpp | 63 void TaskQueue::queue(RenderTask* task) { function in class:android::uirenderer::renderthread::TaskQueue 66 LOG_ALWAYS_FATAL_IF(task->mNext || mTail == task, "Task is already in the queue!"); 110 "Cannot remove a task that isn't in the queue!"); 218 ATRACE_NAME("queue mFrameCallbackTask"); 265 // Process our queue, if we have anything 300 void RenderThread::queue(RenderTask* task) { function in class:android::uirenderer::renderthread::RenderThread 302 mQueue.queue(task); 317 queue(task);
|
/frameworks/base/native/android/ |
H A D | sensor.cpp | 78 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...] |
/frameworks/base/services/core/java/com/android/server/am/ |
H A D | BroadcastRecord.java | 67 BroadcastQueue queue; // the outbound queue handling this broadcast field in class:BroadcastRecord 182 queue = _queue;
|
/frameworks/base/services/core/java/com/android/server/tv/ |
H A D | TvInputHal.java | 57 private native long nativeOpen(MessageQueue queue); argument
|
/frameworks/base/tests/touchlag/ |
H A D | touchlag.cpp | 251 Queue queue; local 277 queue.push(x, y); 278 queue.get(lag, &lag_x, &lag_y);
|