| /ndk/tests/device/test-gnustl-full/unit/ |
| queue_test.cpp | 5 #include <queue>
51 queue<int, list<int> > q;
|
| /ndk/tests/device/test-stlport/unit/ |
| queue_test.cpp | 5 #include <queue>
51 queue<int, list<int> > q;
|
| /dalvik/tests/079-phantom/src/ |
| Bitmap.java | 113 ReferenceQueue<PhantomWrapper> queue, int nativeDataPtr)
115 super(wrapper, queue);
129 BitmapWatcher(ReferenceQueue<PhantomWrapper> queue) {
130 mQueue = queue;
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| RefQueueWorker.java | 54 /** The reference queue to monitor. */
71 * @param queue the queue on which to wait for references
74 public RefQueueWorker(ReferenceQueue<?> queue, RefQueueHandler handler) {
75 if (queue == null) {
76 throw new IllegalArgumentException("Queue must not be null.");
82 refQueue = queue;
|
| /frameworks/base/media/libstagefright/include/ |
| TimedEventQueue.h | 45 virtual void fire(TimedEventQueue *queue, int64_t now_us) = 0;
67 // events are discarded, otherwise the queue will stop (and this call
71 // Posts an event to the front of the queue (after all events that
84 // Returns true iff event is currently in the queue and has been
86 // removed from the queue and won't fire.
106 virtual void fire(TimedEventQueue *queue, int64_t now_us) {
107 queue->mStopped = true;
|
| /development/cmds/monkey/src/com/android/commands/monkey/ |
| MonkeySourceNetwork.java | 42 import java.util.Queue;
97 * @param queue the command queue.
100 MonkeyCommandReturn translateCommand(List<String> command, CommandQueue queue);
110 CommandQueue queue) {
114 queue.enqueueEvent(new MonkeyFlipEvent(true));
117 queue.enqueueEvent(new MonkeyFlipEvent(false));
134 CommandQueue queue) {
162 queue.enqueueEvent(new MonkeyMotionEvent(MonkeyEvent.EVENT_TYPE_POINTER,
178 CommandQueue queue) {
[all...] |
| /external/bluetooth/glib/tests/ |
| sequence-test.c | 99 GQueue * queue; member in struct:SequenceInfo
136 g_assert (info->n_items == g_queue_get_length (info->queue));
140 list = info->queue->head;
154 g_assert (info->n_items == g_queue_get_length (info->queue));
244 for (list = info->queue->head; list != NULL; list = list->next)
250 /* Check that the ordering is the same as that of the queue,
283 * beyond the queue
289 return g_queue_link_index (seq->queue, link);
291 return g_queue_get_length (seq->queue);
301 int length = g_queue_get_length (seq->queue);
[all...] |
| queue-test.c | 14 check_integrity (GQueue *queue)
22 g_assert (queue->length < 4000000000u);
24 g_assert (g_queue_get_length (queue) == queue->length);
26 if (!queue->head)
27 g_assert (!queue->tail);
28 if (!queue->tail)
29 g_assert (!queue->head);
33 for (list = queue->head; list != NULL; list = list->next)
39 g_assert (n == queue->length);
219 GQueue *queue; member in struct:QueueInfo
742 GQueue *queue = q; local
[all...] |
| /external/guava/src/com/google/common/base/internal/ |
| Finalizer.java | 84 return finalizer.queue;
89 private final ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); field in class:Finalizer
102 this.frqReference = new PhantomReference<Object>(frq, queue);
119 * Loops continuously, pulling references off the queue and cleaning them up.
127 cleanUp(queue.remove());
163 } while ((reference = queue.poll()) != null);
|
| /external/guava/src/com/google/common/base/ |
| FinalizableReferenceQueue.java | 30 * A reference queue with an associated background thread that dequeues
66 * queue in ReferenceMap, which keeps the Finalizer running, and as a result,
107 * The actual reference queue that our background thread will poll.
109 final ReferenceQueue<Object> queue; field in class:FinalizableReferenceQueue
117 * Constructs a new queue.
122 ReferenceQueue<Object> queue; local
125 queue = (ReferenceQueue<Object>) startFinalizer.invoke(null,
135 queue = new ReferenceQueue<Object>();
138 this.queue = queue;
[all...] |
| /external/apache-http/src/org/apache/commons/logging/impl/ |
| WeakHashtable.java | 125 private ReferenceQueue queue = new ReferenceQueue(); field in class:WeakHashtable
241 Referenced keyRef = new Referenced(key, queue);
321 synchronized (queue) {
323 while ((key = (WeakKey) queue.poll()) != null) {
335 synchronized (queue) {
336 WeakKey key = (WeakKey) queue.poll();
410 private Referenced(Object key, ReferenceQueue queue) {
411 reference = new WeakKey(key, queue, this);
468 ReferenceQueue queue,
470 super(key, queue);
[all...] |
| /external/chromium/net/websockets/ |
| websocket_throttle.cc | 142 // If true, it will be removed from queue and deleted from the SocketStream
215 ConnectingQueue* queue = new ConnectingQueue(); local
216 queue->push_back(state);
217 addr_map_[addrkey] = queue;
234 ConnectingQueue* queue = iter->second; local
235 DCHECK(state == queue->front());
236 queue->pop_front();
237 if (queue->empty()) {
238 delete queue;
269 ConnectingQueue* queue = iter->second local
[all...] |
| /external/webkit/WebKitTools/pywebsocket/test/ |
| test_mock.py | 36 import Queue
75 def __init__(self, conn, queue):
77 self._queue = queue
86 queue = Queue.Queue()
87 reader = LineReader(conn, queue)
88 self.failUnless(queue.empty())
90 read = queue.get()
|
| /libcore/luni/src/main/java/java/util/ |
| ServiceLoader.java | 197 private LinkedList<String> queue = new LinkedList<String>();
209 return (queue != null && !queue.isEmpty());
217 String className = queue.remove();
244 if (!queue.contains(className)) {
245 queue.add(className);
|
| /frameworks/base/native/android/ |
| input.cpp | 252 void AInputQueue_attachLooper(AInputQueue* queue, ALooper* looper,
254 queue->attachLooper(looper, ident, callback, data);
257 void AInputQueue_detachLooper(AInputQueue* queue) {
258 queue->detachLooper();
261 int32_t AInputQueue_hasEvents(AInputQueue* queue) {
262 return queue->hasEvents();
265 int32_t AInputQueue_getEvent(AInputQueue* queue, AInputEvent** outEvent) {
266 return queue->getEvent(outEvent);
269 int32_t AInputQueue_preDispatchEvent(AInputQueue* queue, AInputEvent* event) {
270 return queue->preDispatchEvent(event) ? 1 : 0
[all...] |
| /prebuilt/linux-x86/toolchain/i686-linux-glibc2.7-4.4.3/sysroot/usr/include/alsa/ |
| seqmid.h | 118 ((ev)->queue = SND_SEQ_QUEUE_DIRECT)
121 * \brief set tick-scheduling mode on queue
123 * \param q queue id to schedule
137 (ev)->queue = (q))
140 * \brief set real-time-scheduling mode on queue
142 * \param q queue id to schedule
156 (ev)->queue = (q))
212 * \brief set queue controls
215 * \param q queue id
221 (ev)->data.queue.queue = (q),
[all...] |
| /external/ipsec-tools/src/racoon/ |
| genlist.h | 38 #include <sys/queue.h>
|
| /external/webkit/WebKitTools/QueueStatusServer/model/ |
| attachment.py | 101 for queue in queues:
102 summary[queue] = None
103 status = QueueStatus.all().filter('queue_name =', queue).filter('active_patch_id =', self.id).order('-date').get()
105 summary[self._dash_to_underscore(queue)] = {
|
| /build/tools/droiddoc/src/ |
| MethodInfo.java | 46 private static void addInterfaces(ClassInfo[] ifaces, ArrayList<ClassInfo> queue)
49 queue.add(i);
52 addInterfaces(i.interfaces(), queue); local
68 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); local
69 addInterfaces(containingClass().interfaces(), queue); local
70 for (ClassInfo iface: queue) {
83 private static void addRealInterfaces(ClassInfo[] ifaces, ArrayList<ClassInfo> queue)
86 queue.add(i);
88 queue.add(i.superclass());
92 addInterfaces(i.realInterfaces(), queue); local
105 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); local
110 addInterfaces(containingClass().realInterfaces(), queue); local
140 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); local
145 addInterfaces(containingClass().realInterfaces(), queue); local
167 ArrayList<ClassInfo> queue = new ArrayList<ClassInfo>(); local
172 addInterfaces(containingClass().realInterfaces(), queue); local
[all...] |
| /hardware/ril/mock-ril/src/cpp/ |
| requests.h | 20 #include <queue>
55 * Ril request worker queue.
62 // TODO: Need a thread-safe queue
63 std::queue<Request *> free_list_;
78 * Add a request to the Queue
|
| /development/tools/axl/ |
| chewie.py | 16 class Queue:
18 self.queue = []
21 self.queue.append([url, time])
24 for x in range(len(self.queue)):
25 rec = self.queue[x]
27 del self.queue[x]
30 ## pull out request lag -- queue to start to done
56 queued = Queue()
|
| /frameworks/base/media/libstagefright/rtsp/ |
| AMPEG4ElementaryAssembler.cpp | 179 List<sp<ABuffer> > *queue = source->queue(); local
181 if (queue->empty()) {
186 List<sp<ABuffer> >::iterator it = queue->begin();
187 while (it != queue->end()) {
192 it = queue->erase(it);
195 if (queue->empty()) {
200 sp<ABuffer> buffer = *queue->begin();
330 queue->erase(queue->begin())
[all...] |
| /frameworks/base/libs/surfaceflinger_client/tests/SharedBufferStack/ |
| SharedBufferStackTest.cpp | 48 c.queue(b);
106 err = c.queue(b[i]);
124 err = c.queue(b[num-1]);
155 err = c.queue(u[i]);
172 err = c.queue(b[num-1]);
198 err = c.queue(b[i]);
215 err = c.queue(u[num-1]);
252 err = c.queue(b[i]);
269 err = c.queue(u[num-1]);
|
| /bionic/libc/kernel/common/linux/ |
| msm_adsp.h | 21 uint16_t queue; member in struct:adsp_command_t
|
| /development/ndk/platforms/android-3/include/linux/ |
| msm_adsp.h | 22 uint16_t queue; member in struct:adsp_command_t
|
