| /external/smack/src/org/jivesoftware/smack/util/collections/ |
| AbstractReferenceMap.java | 119 private transient ReferenceQueue queue; field in class:AbstractReferenceMap
155 queue = new ReferenceQueue();
278 while (queue.poll() != null) {
279 } // drain the queue
359 Reference ref = queue.poll();
362 ref = queue.poll();
675 * The reference is registered with the queue for later purging.
686 return new SoftRef<T>(hash, referent, parent.queue);
688 return new WeakRef<T>(hash, referent, parent.queue);
[all...] |
| /frameworks/base/core/jni/ |
| android_app_NativeActivity.cpp | 573 AInputQueue* queue = reinterpret_cast<AInputQueue*>(queuePtr); local
574 code->callbacks.onInputQueueCreated(code, queue);
586 AInputQueue* queue = reinterpret_cast<AInputQueue*>(queuePtr); local
587 code->callbacks.onInputQueueDestroyed(code, queue);
|
| /hardware/libhardware/modules/sensors/ |
| multihal.cpp | 134 SensorEventQueue* queue; member in struct:TaskContext
141 SensorEventQueue* queue = ctx->queue; local
146 if (queue->waitForSpace(&queue_mutex)) {
149 int bufferSize = queue->getWritableRegion(SENSOR_EVENT_QUEUE_CAPACITY, &buffer);
160 queue->markAsWritten(eventsPolled);
214 SensorEventQueue *queue = new SensorEventQueue(SENSOR_EVENT_QUEUE_CAPACITY); local
215 this->queues.push_back(queue);
219 taskContext->queue = queue;
340 SensorEventQueue* queue = this->queues.at(this->nextReadIndex); local
[all...] |
| /libcore/libart/src/main/java/java/lang/ |
| Daemons.java | 28 * Calls Object.finalize() on objects in the finalizer reference queue. The VM
123 * pending list to the managed reference queue.
166 private final ReferenceQueue<Object> queue = FinalizerReference.queue; field in class:Daemons.FinalizerDaemon
174 doFinalize((FinalizerReference<?>) queue.remove());
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| PriorityBlockingQueue.java | 18 * An unbounded {@linkplain BlockingQueue blocking queue} that uses
20 * blocking retrieval operations. While this queue is logically
23 * {@code null} elements. A priority queue relying on {@linkplain
104 * Priority queue represented as a balanced binary heap: the two
105 * children of queue[n] are queue[2*n+1] and queue[2*(n+1)]. The
106 * priority queue is ordered by comparator, or by the elements'
109 * lowest value is in queue[0], assuming the queue is nonempty
111 private transient Object[] queue; field in class:PriorityBlockingQueue
[all...] |
| ScheduledThreadPoolExecutor.java | 34 * automatically removed from the work queue until its delay
49 * {@code corePoolSize} threads and an unbounded queue, adjustments
106 * 2. Using a custom queue (DelayedWorkQueue), a variant of
135 * True if ScheduledFutureTask.cancel should remove from queue
173 * Index into delay queue, to support faster cancellation.
287 * is shut down, rejects the task. Otherwise adds task to queue
327 * Cancels and clears the queue of all tasks that should not be run
428 * because the thread bounds and queue capacities are reached
447 * because the thread bounds and queue capacities are reached
475 * Constrains the values of all delays in the queue to be withi
803 private RunnableScheduledFuture<?>[] queue = field in class:ScheduledThreadPoolExecutor.DelayedWorkQueue
[all...] |
| /packages/services/Mms/src/com/android/mms/service/ |
| MmsService.java | 65 import java.util.Queue;
93 // requests will stay in this queue until that SIM finishes its current requests in
96 // blocked in the queue. And a later request for SIM1 will be appended to the queue, ordered
97 // after the request for SIM2, instead of being put into the running queue.
99 private final Queue<MmsRequest> mPendingSimRequestQueue = new ArrayDeque<>();
112 * A thread-based request queue for executing the MMS requests in serial order
363 // Running request queues, one thread per queue
364 // 0: send queue
365 // 1: download queue
422 final int queue = request.getQueueType(); local
[all...] |
| /external/nanohttpd/core/src/main/java/fi/iki/elonen/ |
| NanoHTTPD.java | 1373 private ArrayList<Cookie> queue = new ArrayList<Cookie>(); field in class:NanoHTTPD.CookieHandler
[all...] |
| /development/ndk/platforms/android-3/include/linux/raid/ |
| md_k.h | 155 request_queue_t *queue; member in struct:mddev_s
|
| /external/chromium_org/cc/trees/ |
| thread_proxy.cc | 415 // The texture upload queue may reference textures that were just purged,
416 // clear them from the queue.
808 scoped_ptr<ResourceUpdateQueue> queue = local
811 bool updated = layer_tree_host()->UpdateLayers(queue.get());
865 queue.release()));
898 scoped_ptr<ResourceUpdateQueue> queue(raw_queue);
913 queue->ClearUploadsToEvictedResources();
926 queue.Pass(),
[all...] |
| /external/chromium_org/third_party/skia/experimental/Intersection/ |
| EdgeWalker_TestUtility.cpp | 479 State4* State4::queue = NULL; member in class:State4
515 while (!State4::queue) {
519 statePtr = State4::queue;
527 State4::queue = NULL; member in class:State4
530 State4::queue = &threadState[index]; member in class:State4
535 State4::queue ? State4::queue->index : -1);
709 State4::queue = &state; member in class:State4
728 while (!State4::queue) {
732 while (State4::queue) {
746 State4::queue = next; member in class:State4
[all...] |
| /external/doclava/src/com/google/doclava/ |
| MethodInfo.java | 47 private static void addInterfaces(ArrayList<ClassInfo> ifaces, ArrayList<ClassInfo> queue) {
49 queue.add(i);
52 addInterfaces(i.interfaces(), queue); local
67 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); local
68 addInterfaces(containingClass().interfaces(), queue); local
69 for (ClassInfo iface : queue) {
80 private static void addRealInterfaces(ArrayList<ClassInfo> ifaces, ArrayList<ClassInfo> queue) {
82 queue.add(i);
84 queue.add(i.superclass());
88 addInterfaces(i.realInterfaces(), queue); local
101 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); local
106 addInterfaces(containingClass().realInterfaces(), queue); local
134 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); local
139 addInterfaces(containingClass().realInterfaces(), queue); local
160 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); local
165 addInterfaces(containingClass().realInterfaces(), queue); local
[all...] |
| /external/guava/guava/src/com/google/common/collect/ |
| MinMaxPriorityQueue.java | 39 import java.util.Queue;
42 * A double-ended priority queue, which provides constant-time access to both
43 * its least element and its greatest element, as determined by the queue's
47 * <p>As a {@link Queue} it functions exactly as a {@link PriorityQueue}: its
50 * the queue according to the queue's comparator. But unlike a regular priority
51 * queue, the methods {@link #peekLast}, {@link #pollLast} and
53 * in the queue instead.
55 * <p>A min-max priority queue can be configured with a maximum size. If so,
56 * each time the size of the queue exceeds that value, the queue automaticall
205 MinMaxPriorityQueue<T> queue = new MinMaxPriorityQueue<T>( local
222 private Object[] queue; field in class:MinMaxPriorityQueue
[all...] |
| /external/linux-tools-perf/perf-3.12.0/tools/perf/util/ |
| annotate.c | 642 int max_lines, struct disasm_line *queue)
685 if (queue != NULL) {
686 list_for_each_entry_from(queue, ¬es->src->source, node) {
687 if (queue == dl)
689 disasm_line__print(queue, sym, start, evsel, len,
728 if (queue)
1222 struct disasm_line *pos, *queue = NULL; local
1254 if (context && queue == NULL) {
1255 queue = pos;
1261 queue)) {
[all...] |
| /external/qemu/distrib/mini-glib/src/ |
| glib-mini.c | 705 GQueue* queue = g_new0(GQueue, 1); local
706 return queue;
709 void g_queue_free(GQueue* queue) {
710 GQueueNode* node = queue->head;
716 queue->head = queue->tail = NULL;
717 queue->length = 0;
718 g_free(queue);
721 gboolean g_queue_is_empty(GQueue* queue) {
722 return queue->head == NULL
[all...] |
| /external/skia/experimental/Intersection/ |
| EdgeWalker_TestUtility.cpp | 479 State4* State4::queue = NULL; member in class:State4
515 while (!State4::queue) {
519 statePtr = State4::queue;
527 State4::queue = NULL; member in class:State4
530 State4::queue = &threadState[index]; member in class:State4
535 State4::queue ? State4::queue->index : -1);
709 State4::queue = &state; member in class:State4
728 while (!State4::queue) {
732 while (State4::queue) {
746 State4::queue = next; member in class:State4
[all...] |
| /external/smack/src/org/jivesoftware/smackx/workgroup/agent/ |
| AgentSession.java | 436 * Removes a user from the workgroup queue. This is an administrative action that the
548 * @param queueName the name of the queue
549 * @return an instance of WorkgroupQueue for the argument queue name, or null if none exists
657 private void fireQueueUsersEvent(WorkgroupQueue queue, WorkgroupQueue.Status status,
662 listener.statusUpdated(queue, status);
665 listener.averageWaitTimeUpdated(queue, averageWaitTime);
668 listener.oldestEntryUpdated(queue, oldestEntry);
671 listener.usersUpdated(queue, users);
702 WorkgroupQueue queue = queues.get(queueName);
local
703 // If there isn't already an entry for the queue, create a new one.
[all...] |
| /external/wpa_supplicant_8/hostapd/ |
| config_file.c | 874 struct hostapd_tx_queue_params *queue; local
897 queue = &conf->tx_queue[num];
900 queue->aifs = atoi(val);
901 if (queue->aifs < 0 || queue->aifs > 255) {
903 queue->aifs);
907 queue->cwmin = atoi(val);
908 if (!valid_cw(queue->cwmin)) {
910 queue->cwmin);
914 queue->cwmax = atoi(val)
[all...] |
| /frameworks/av/services/camera/libcameraservice/device2/ |
| Camera2Device.cpp | 103 ALOGE("%s: Camera %d: Unable to connect request queue to device: %s (%d)",
110 ALOGE("%s: Camera %d: Unable to connect frame queue to device: %s (%d)",
174 result = " Request queue contents:\n";
178 result = " Frame queue contents:\n";
708 ALOGVV("%s: Streaming %d frames to queue", __FUNCTION__,
842 // Clear request queue
855 result.append(" (Unable to lock queue mutex)\n");
874 result = " Main queue is empty\n";
877 result = String8::format(" Main queue has %zu entries:\n",
882 result = String8::format(" Queue entry %d:\n", i)
940 MetadataQueue *queue = getInstance(q); local
948 MetadataQueue *queue = getInstance(q); local
957 MetadataQueue *queue = getInstance(q); local
989 MetadataQueue *queue = getInstance(q); local
[all...] |
| /frameworks/base/media/java/android/media/session/ |
| MediaController.java | 172 * Get the current play queue for this session if one is set. If you only
175 * @return The current play queue or null.
179 ParceledListSlice queue = mSessionBinder.getQueue(); local
180 if (queue != null) {
181 return queue.getList();
190 * Get the queue title for this session.
547 * Override to handle changes to items in the queue.
549 * @param queue A list of items in the current play queue. It should
554 public void onQueueChanged(@Nullable List<MediaSession.QueueItem> queue) {
923 List<MediaSession.QueueItem> queue = parceledQueue == null ? null : parceledQueue local
[all...] |
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| Filter.java | 689 FrameQueue queue = builder.build(queueName); local
690 outPort.setQueue(queue);
691 inPort.setQueue(queue);
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.11-4.6/sysroot/usr/include/alsa/ |
| seq_event.h | 91 /** Set tick queue position; event data type = #snd_seq_ev_queue_control_t */
93 /** Set real-time queue position; event data type = #snd_seq_ev_queue_control_t */
101 /** Queue timer skew; event data type = #snd_seq_ev_queue_control_t */
268 /** Queue skew values */
274 /** queue timer control */
276 unsigned char queue; /**< affected queue */ member in struct:snd_seq_ev_queue_control
282 snd_seq_queue_skew_t skew; /**< queue skew */
295 unsigned char queue; /**< schedule queue */ member in struct:snd_seq_event
307 snd_seq_ev_queue_control_t queue; \/**< queue control *\/ member in union:snd_seq_event::__anon25402
[all...] |
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.11-4.8/sysroot/usr/include/alsa/ |
| seq_event.h | 91 /** Set tick queue position; event data type = #snd_seq_ev_queue_control_t */
93 /** Set real-time queue position; event data type = #snd_seq_ev_queue_control_t */
101 /** Queue timer skew; event data type = #snd_seq_ev_queue_control_t */
268 /** Queue skew values */
274 /** queue timer control */
276 unsigned char queue; /**< affected queue */ member in struct:snd_seq_ev_queue_control
282 snd_seq_queue_skew_t skew; /**< queue skew */
295 unsigned char queue; /**< schedule queue */ member in struct:snd_seq_event
307 snd_seq_ev_queue_control_t queue; \/**< queue control *\/ member in union:snd_seq_event::__anon27138
[all...] |
| /prebuilts/ndk/4/platforms/android-3/arch-arm/usr/include/linux/raid/ |
| md_k.h | 155 request_queue_t *queue; member in struct:mddev_s
|
| /prebuilts/ndk/4/platforms/android-4/arch-arm/usr/include/linux/raid/ |
| md_k.h | 155 request_queue_t *queue; member in struct:mddev_s
|
