| /external/chromium/base/ |
| thread_collision_warner_unittest.cc | 151 explicit QueueUser(NonThreadSafeQueue& queue)
152 : queue_(queue) {}
165 NonThreadSafeQueue queue(local_reporter);
167 QueueUser queue_user_a(queue);
168 QueueUser queue_user_b(queue);
183 // Queue with a 5 seconds push execution time, hopefuly the two used threads
209 explicit QueueUser(NonThreadSafeQueue& queue)
210 : queue_(queue) {}
223 NonThreadSafeQueue queue(local_reporter);
225 QueueUser queue_user_a(queue);
[all...] |
| worker_pool_linux.h | 13 // task queue, it does not own the worker threads. The worker threads ask the
27 #include <queue>
77 std::queue<Task*> tasks_;
|
| /external/chromium/net/ftp/ |
| ftp_ctrl_response_buffer.h | 8 #include <queue>
83 std::queue<ParsedLine> lines_;
96 // As we read full responses (possibly multiline), we add them to the queue.
97 std::queue<FtpCtrlResponse> responses_;
|
| /external/webkit/WebKitTools/QueueStatusServer/handlers/ |
| recentstatus.py | 44 # We could change "/" to just redirect to /queue-status/commit-queue in the future
46 def get(self, queue_name="commit-queue"):
48 for queue in queues:
49 statuses = QueueStatus.all().filter("queue_name =", queue).order("-date").fetch(6)
52 queue_status[queue] = statuses
|
| /frameworks/base/media/libstagefright/rtsp/ |
| AH263Assembler.cpp | 51 List<sp<ABuffer> > *queue = source->queue(); local
53 if (queue->empty()) {
58 List<sp<ABuffer> >::iterator it = queue->begin();
59 while (it != queue->end()) {
64 it = queue->erase(it);
67 if (queue->empty()) {
72 sp<ABuffer> buffer = *queue->begin();
96 queue->erase(queue->begin())
[all...] |
| AAMRAssembler.cpp | 99 List<sp<ABuffer> > *queue = source->queue(); local
101 if (queue->empty()) {
106 List<sp<ABuffer> >::iterator it = queue->begin();
107 while (it != queue->end()) {
112 it = queue->erase(it);
115 if (queue->empty()) {
120 sp<ABuffer> buffer = *queue->begin();
134 queue->erase(queue->begin())
[all...] |
| /development/ndk/platforms/android-9/include/android/ |
| sensor.h | 166 * Creates a new sensor event queue and associate it with a looper.
172 * Destroys the event queue and free all resources associated to it.
174 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);
200 * sensor queue. Returns 1 if the queue has events; 0 if
203 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue);
206 * Returns the next available events from the queue. Returns a negativ
[all...] |
| /frameworks/base/native/include/android/ |
| sensor.h | 166 * Creates a new sensor event queue and associate it with a looper.
172 * Destroys the event queue and free all resources associated to it.
174 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);
200 * sensor queue. Returns 1 if the queue has events; 0 if
203 int ASensorEventQueue_hasEvents(ASensorEventQueue* queue);
206 * Returns the next available events from the queue. Returns a negativ
[all...] |
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| BasicPoolEntryRef.java | 56 * @param queue the reference queue, or <code>null</code>
59 ReferenceQueue<Object> queue) {
60 super(entry, queue);
|
| BasicPoolEntry.java | 60 * @param queue the reference queue for tracking GC of this entry,
65 ReferenceQueue<Object> queue) {
70 this.reference = new BasicPoolEntryRef(this, queue);
|
| /prebuilt/linux-x86/toolchain/i686-linux-glibc2.7-4.4.3/i686-linux/include/c++/4.4.3/bits/ |
| stl_queue.h | 0 // Queue implementation -*- C++ -*-
77 * wrapper is what enforces strict first-in-first-out %queue behavior.
86 * @c pop, which are standard %queue/FIFO operations.
89 class queue class
100 operator==(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&);
104 operator<(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&);
130 queue(const _Sequence& __c = _Sequence()) function in class:queue
134 queue(const _Sequence& __c function in class:queue
138 queue(_Sequence&& __c = _Sequence()) function in class:queue
141 queue(queue&& __q) function in class:queue
[all...] |
| /external/stlport/stlport/ |
| queue | 42 # include_next <queue>
44 # include _STLP_NATIVE_HEADER(queue)
|
| /libcore/luni/src/main/java/java/lang/ref/ |
| PhantomReference.java | 39 * on the corresponding queue, but its referent is not cleared. That is, the
40 * reference queue of the phantom reference must explicitly be processed by some
42 * registered with any reference queue does not make any sense.
52 * reference queue. The reference queue may be {@code null}, but this case
57 * @param q the queue to register the phantom reference object with
62 queue = q;
|
| SoftReference.java | 91 * reference is not registered with any reference queue.
102 * reference is registered with the given reference queue.
105 * @param q the queue to register to the reference object with. A null value
107 * queue.
112 queue = q;
|
| WeakReference.java | 90 * reference is not registered with any reference queue.
101 * reference is registered with the given reference queue.
104 * @param q the queue to register to the reference object with. A null value
106 * queue.
111 queue = q;
|
| /ndk/sources/cxx-stl/stlport/stlport/ |
| queue | 42 # include_next <queue>
44 # include _STLP_NATIVE_HEADER(queue)
|
| /frameworks/base/core/jni/ |
| android_hardware_SensorManager.cpp | 89 sp<SensorEventQueue> queue(mgr.createEventQueue());
90 queue->incStrong(clazz);
91 return reinterpret_cast<int>(queue.get());
97 sp<SensorEventQueue> queue(reinterpret_cast<SensorEventQueue *>(nativeQueue));
98 if (queue != 0) {
99 queue->decStrong(clazz);
107 sp<SensorEventQueue> queue(reinterpret_cast<SensorEventQueue *>(nativeQueue));
108 if (queue == 0) return JNI_FALSE;
111 res = queue->enableSensor(sensor, delay);
113 res = queue->disableSensor(sensor)
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ScheduledThreadPoolExecutor.java | 35 * automatically removed from the work queue until its delay
50 * {@code corePoolSize} threads and an unbounded queue, adjustments
107 * 2. Using a custom queue (DelayedWorkQueue), a variant of
136 * True if ScheduledFutureTask.cancel should remove from queue
174 * Index into delay queue, to support faster cancellation.
289 * is shut down, rejects the task. Otherwise adds task to queue
329 * Cancels and clears the queue of all tasks that should not be run
426 * because the thread bounds and queue capacities are reached
445 * because the thread bounds and queue capacities are reached
473 * Constrains the values of all delays in the queue to be withi
805 private RunnableScheduledFuture[] queue = field in class:ScheduledThreadPoolExecutor.DelayedWorkQueue
[all...] |
| /libcore/luni/src/test/java/libcore/java/util/ |
| OldPriorityQueueTest.java | 44 PriorityQueue<Object> queue = new PriorityQueue<Object>(100); local
45 assertNotNull(queue);
46 assertEquals(0, queue.size());
47 assertNull(queue.comparator());
68 PriorityQueue<String> queue = new PriorityQueue<String>(10, local
72 queue.offer(array[i]);
74 assertFalse(queue.contains("BB"));
77 assertFalse(queue.remove("BB"));
78 assertTrue(queue.remove("AA"));
|
| /external/stlport/stlport/stl/ |
| _queue.h | 59 class queue class in inherits:__stlport_class
62 : public __stlport_class<queue<_Tp> >
64 : public __stlport_class<queue<_Tp, _Sequence> >
70 typedef queue<_Tp> _Self;
72 typedef queue<_Tp, _Sequence> _Self;
86 queue() : c() {} function in class:queue
87 explicit queue(const _Sequence& __c) : c(__c) {} function in class:queue
90 queue(__move_source<_Self> src) function in class:queue
122 operator==(const queue<_STLP_QUEUE_ARGS >& __x, const queue<_STLP_QUEUE_ARGS >& __y)
[all...] |
| /ndk/sources/cxx-stl/stlport/stlport/stl/ |
| _queue.h | 59 class queue class in inherits:__stlport_class
62 : public __stlport_class<queue<_Tp> >
64 : public __stlport_class<queue<_Tp, _Sequence> >
70 typedef queue<_Tp> _Self;
72 typedef queue<_Tp, _Sequence> _Self;
86 queue() : c() {} function in class:queue
87 explicit queue(const _Sequence& __c) : c(__c) {} function in class:queue
90 queue(__move_source<_Self> src) function in class:queue
122 operator==(const queue<_STLP_QUEUE_ARGS >& __x, const queue<_STLP_QUEUE_ARGS >& __y)
[all...] |
| /external/qemu/telephony/ |
| sysdeps_posix.c | 29 /** QUEUE
41 sys_queue_reset( SysQueue queue )
43 queue->start = queue->end = 0;
47 sys_queue_add( SysQueue queue, void* item )
49 assert( queue->end - queue->start < SYS_MAX_QUEUE );
50 assert( queue->start == 0 );
52 queue->pending[ queue->end++ ] = item
[all...] |
| /external/v8/benchmarks/ |
| richards.js | 51 var queue = new Packet(null, ID_WORKER, KIND_WORK);
52 queue = new Packet(queue, ID_WORKER, KIND_WORK);
53 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
55 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE);
56 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
57 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
58 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
[all...] |
| /external/webkit/SunSpider/tests/v8-v4/ |
| v8-richards.js | 46 var queue = new Packet(null, ID_WORKER, KIND_WORK);
47 queue = new Packet(queue, ID_WORKER, KIND_WORK);
48 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
50 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE);
51 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
52 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
53 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
[all...] |
| /external/stlport/test/unit/ |
| queue_test.cpp | 5 #include <queue>
51 queue<int, list<int> > q;
|
