Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 33) sorted by relevance

12

/frameworks/base/native/android/
Dsensor.cpp65 sp<SensorEventQueue> queue = in ASensorManager_createEventQueue() local
67 if (queue != 0) { in ASensorManager_createEventQueue()
68 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data); in ASensorManager_createEventQueue()
69 queue->looper = looper; in ASensorManager_createEventQueue()
70 queue->incStrong(manager); in ASensorManager_createEventQueue()
72 return static_cast<ASensorEventQueue*>(queue.get()); in ASensorManager_createEventQueue()
78 sp<SensorEventQueue> queue = static_cast<SensorEventQueue*>(inQueue); in ASensorManager_destroyEventQueue() local
79 ALooper_removeFd(queue->looper, queue->getFd()); in ASensorManager_destroyEventQueue()
80 queue->decStrong(manager); in ASensorManager_destroyEventQueue()
86 int ASensorEventQueue_enableSensor(ASensorEventQueue* queue, ASensor const* sensor) in ASensorEventQueue_enableSensor() argument
[all …]
Dinput.cpp252 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper, in AInputQueue_attachLooper() argument
254 queue->attachLooper(looper, ident, callback, data); in AInputQueue_attachLooper()
257 void AInputQueue_detachLooper(AInputQueue* queue) { in AInputQueue_detachLooper() argument
258 queue->detachLooper(); in AInputQueue_detachLooper()
261 int32_t AInputQueue_hasEvents(AInputQueue* queue) { in AInputQueue_hasEvents() argument
262 return queue->hasEvents(); in AInputQueue_hasEvents()
265 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent) { in AInputQueue_getEvent() argument
266 return queue->getEvent(outEvent); in AInputQueue_getEvent()
269 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event) { in AInputQueue_preDispatchEvent() argument
270 return queue->preDispatchEvent(event) ? 1 : 0; in AInputQueue_preDispatchEvent()
[all …]
/frameworks/base/media/libstagefright/rtsp/
DAAVCAssembler.cpp48 List<sp<ABuffer> > *queue = source->queue(); in addNALUnit() local
50 if (queue->empty()) { in addNALUnit()
55 List<sp<ABuffer> >::iterator it = queue->begin(); in addNALUnit()
56 while (it != queue->end()) { in addNALUnit()
61 it = queue->erase(it); in addNALUnit()
64 if (queue->empty()) { in addNALUnit()
69 sp<ABuffer> buffer = *queue->begin(); in addNALUnit()
87 queue->erase(queue->begin()); in addNALUnit()
96 queue->erase(queue->begin()); in addNALUnit()
101 return addFragmentedNALUnit(queue); in addNALUnit()
[all …]
DAAMRAssembler.cpp99 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
101 if (queue->empty()) { in addPacket()
106 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
107 while (it != queue->end()) { in addPacket()
112 it = queue->erase(it); in addPacket()
115 if (queue->empty()) { in addPacket()
120 sp<ABuffer> buffer = *queue->begin(); in addPacket()
134 queue->erase(queue->begin()); in addPacket()
152 queue->erase(queue->begin()); in addPacket()
166 queue->erase(queue->begin()); in addPacket()
[all …]
DAH263Assembler.cpp51 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
53 if (queue->empty()) { in addPacket()
58 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
59 while (it != queue->end()) { in addPacket()
64 it = queue->erase(it); in addPacket()
67 if (queue->empty()) { in addPacket()
72 sp<ABuffer> buffer = *queue->begin(); in addPacket()
96 queue->erase(queue->begin()); in addPacket()
118 queue->erase(queue->begin()); in addPacket()
DAMPEG4ElementaryAssembler.cpp179 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
181 if (queue->empty()) { in addPacket()
186 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
187 while (it != queue->end()) { in addPacket()
192 it = queue->erase(it); in addPacket()
195 if (queue->empty()) { in addPacket()
200 sp<ABuffer> buffer = *queue->begin(); in addPacket()
330 queue->erase(queue->begin()); in addPacket()
DAMPEG4AudioAssembler.cpp415 List<sp<ABuffer> > *queue = source->queue(); in addPacket() local
417 if (queue->empty()) { in addPacket()
422 List<sp<ABuffer> >::iterator it = queue->begin(); in addPacket()
423 while (it != queue->end()) { in addPacket()
428 it = queue->erase(it); in addPacket()
431 if (queue->empty()) { in addPacket()
436 sp<ABuffer> buffer = *queue->begin(); in addPacket()
459 queue->erase(queue->begin()); in addPacket()
DAAVCAssembler.h52 AssemblyStatus addFragmentedNALUnit(List<sp<ABuffer> > *queue);
DARTPSource.h44 List<sp<ABuffer> > *queue() { return &mQueue; } in queue() function
/frameworks/base/core/jni/
Dandroid_hardware_SensorManager.cpp89 sp<SensorEventQueue> queue(mgr.createEventQueue()); in sensors_create_queue() local
90 queue->incStrong(clazz); in sensors_create_queue()
91 return reinterpret_cast<int>(queue.get()); in sensors_create_queue()
97 sp<SensorEventQueue> queue(reinterpret_cast<SensorEventQueue *>(nativeQueue)); in sensors_destroy_queue() local
98 if (queue != 0) { in sensors_destroy_queue()
99 queue->decStrong(clazz); in sensors_destroy_queue()
107 sp<SensorEventQueue> queue(reinterpret_cast<SensorEventQueue *>(nativeQueue)); in sensors_enable_sensor() local
108 if (queue == 0) return JNI_FALSE; in sensors_enable_sensor()
111 res = queue->enableSensor(sensor, delay); in sensors_enable_sensor()
113 res = queue->disableSensor(sensor); in sensors_enable_sensor()
[all …]
/frameworks/base/native/include/android/
Dsensor.h174 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);
203 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue);
218 ssize_t ASensorEventQueue_getEvents(ASensorEventQueue* queue,
Dinput.h645 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper,
651 void AInputQueue_detachLooper(AInputQueue* queue);
658 int32_t AInputQueue_hasEvents(AInputQueue* queue);
664 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent);
674 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event);
680 void AInputQueue_finishEvent(AInputQueue* queue, AInputEvent* event, int handled);
Dnative_activity.h185 void (*onInputQueueCreated)(ANativeActivity* activity, AInputQueue* queue);
192 void (*onInputQueueDestroyed)(ANativeActivity* activity, AInputQueue* queue);
/frameworks/base/libs/surfaceflinger_client/tests/SharedBufferStack/
DSharedBufferStackTest.cpp48 c.queue(b); in main()
106 err = c.queue(b[i]); in test0()
124 err = c.queue(b[num-1]); in test0()
155 err = c.queue(u[i]); in test0()
172 err = c.queue(b[num-1]); in test0()
198 err = c.queue(b[i]); in test0()
215 err = c.queue(u[num-1]); in test0()
252 err = c.queue(b[i]); in test0()
269 err = c.queue(u[num-1]); in test0()
/frameworks/base/media/libstagefright/include/
DTimedEventQueue.h45 virtual void fire(TimedEventQueue *queue, int64_t now_us) = 0;
106 virtual void fire(TimedEventQueue *queue, int64_t now_us) { in fire()
107 queue->mStopped = true; in fire()
/frameworks/base/core/java/android/os/
DHandler.java454 MessageQueue queue = mQueue; in sendMessageAtTime() local
455 if (queue != null) { in sendMessageAtTime()
457 sent = queue.enqueueMessage(msg, uptimeMillis); in sendMessageAtTime()
482 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue() local
483 if (queue != null) { in sendMessageAtFrontOfQueue()
485 sent = queue.enqueueMessage(msg, 0); in sendMessageAtFrontOfQueue()
DLooper.java109 MessageQueue queue = me.mQueue; in loop() local
117 Message msg = queue.next(); // might block in loop()
DStrictMode.java801 MessageQueue queue = Looper.myQueue(); in handleViolationWithTimingAttempt() local
815 queue.addIdleHandler(new MessageQueue.IdleHandler() { in handleViolationWithTimingAttempt()
/frameworks/base/tests/CoreTests/android/core/
DHeapTest.java297 ReferenceQueue<Object> queue) { in makeRefs() argument
300 refs[i] = new PhantomReference<Object>(objects[i], queue); in makeRefs()
305 ReferenceQueue<T> queue) { in checkRefs() argument
329 while ((ref = (PhantomReference<T>) queue.poll()) != null) { in checkRefs()
383 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in testPhantomRefs() local
388 makeRefs(objects, refs, queue); in testPhantomRefs()
390 checkRefs(objects, refs, queue); in testPhantomRefs()
400 checkRefs(objects, refs, queue); in testPhantomRefs()
410 checkRefs(objects, refs, queue); in testPhantomRefs()
/frameworks/base/core/java/android/app/
DNativeActivity.java86 private native int loadNativeCode(String path, String funcname, MessageQueue queue, in loadNativeCode() argument
316 public void onInputQueueCreated(InputQueue queue) { in onInputQueueCreated() argument
318 mCurInputQueue = queue; in onInputQueueCreated()
319 onInputChannelCreatedNative(mNativeHandle, queue.getInputChannel()); in onInputQueueCreated()
323 public void onInputQueueDestroyed(InputQueue queue) { in onInputQueueDestroyed() argument
326 onInputChannelDestroyedNative(mNativeHandle, queue.getInputChannel()); in onInputQueueDestroyed()
/frameworks/base/core/java/android/view/
DInputQueue.java40 void onInputQueueCreated(InputQueue queue); in onInputQueueCreated() argument
46 void onInputQueueDestroyed(InputQueue queue); in onInputQueueDestroyed() argument
/frameworks/base/services/java/com/android/server/
DBackupManagerService.java289 ArrayList<BackupRequest> queue = new ArrayList<BackupRequest>(); in handleMessage() local
297 queue.add(b); in handleMessage()
308 if (queue.size() > 0) { in handleMessage()
314 (new PerformBackupTask(transport, queue, oldJournal)).run(); in handleMessage()
344 HashSet<String> queue; in handleMessage() local
348 queue = new HashSet<String>(mPendingInits); in handleMessage()
352 (new PerformInitializeTask(queue)).run(); in handleMessage()
1239 public PerformBackupTask(IBackupTransport transport, ArrayList<BackupRequest> queue, in PerformBackupTask() argument
1242 mQueue = queue; in PerformBackupTask()
/frameworks/base/docs/html/resources/articles/
Dtts.jd129 <p>The TTS engine manages a global queue of all the entries to synthesize, which
131 manage its own queue in order to control which utterance will interrupt the
133 request would interrupt whatever was currently being synthesized: the queue is
135 queue. The second utterance is queued and will be played after
/frameworks/base/include/private/surfaceflinger/
DSharedBufferStack.h206 status_t queue(int buf);
/frameworks/base/core/java/android/hardware/
DSensorManager.java2045 static native void sensors_destroy_queue(int queue); in sensors_destroy_queue() argument
2046 static native boolean sensors_enable_sensor(int queue, String name, int sensor, int enable); in sensors_enable_sensor() argument
2047 static native int sensors_data_poll(int queue, float[] values, int[] status, long[] timestamp); in sensors_data_poll() argument

12