Home
last modified time | relevance | path

Searched refs:_queue (Results 1 – 22 of 22) sorted by relevance

/external/jetty/src/java/org/eclipse/jetty/server/
DAsyncNCSARequestLog.java38 private final BlockingQueue<String> _queue; field in AsyncNCSARequestLog
62 _queue=queue; in AsyncNCSARequestLog()
79 String log = _queue.poll(10,TimeUnit.SECONDS); in run()
83 while(!_queue.isEmpty()) in run()
85 log=_queue.poll(); in run()
122 if (!_queue.offer(log)) in write()
/external/opencv3/3rdparty/jinja2/
Dutils.py304 self._queue = deque()
309 self._popleft = self._queue.popleft
310 self._pop = self._queue.pop
311 self._remove = self._queue.remove
313 self._append = self._queue.append
319 '_queue': self._queue
333 rv._queue = deque(self._queue)
362 self._queue.clear()
389 if self._queue[-1] != key:
434 result = [(key, self._mapping[key]) for key in list(self._queue)]
[all …]
/external/jetty/src/java/org/eclipse/jetty/servlets/
DQoSFilter.java98 private Queue<Continuation>[] _queue; field in QoSFilter
113 _queue=new Queue[max_priority+1]; in init()
115 for (int p=0;p<_queue.length;p++) in init()
117 _queue[p]=new ConcurrentLinkedQueue<Continuation>(); in init()
127 _queue[priority].remove(continuation); in init()
178 _queue[priority].add(continuation); in doFilter()
226 for (int p=_queue.length;p-->0;) in doFilter()
228 Continuation continutaion=_queue[p].poll(); in doFilter()
DDoSFilter.java178 private Queue<Continuation>[] _queue; field in DoSFilter
191 _queue = new Queue[getMaxPriority() + 1]; in init()
193 for (int p = 0; p < _queue.length; p++) in init()
195 _queue[p] = new ConcurrentLinkedQueue<Continuation>(); in init()
206 _queue[priority].remove(continuation); in init()
413 _queue[priority].add(continuation); in doFilter()
447 for (int p = _queue.length; p-- > 0; ) in doFilter()
449 Continuation continuation = _queue[p].poll(); in doFilter()
/external/dhcpcd-6.8.2/
Dconfigure707 cat <<EOF >_queue.c
716 if $XCC _queue.c -o _queue 2>&3; then
723 rm -f _queue.c _queue
728 cat <<EOF >_queue.c
737 if $XCC _queue.c -o _queue 2>&3; then
744 rm -f _queue.c _queue
749 cat <<EOF >_queue.c
758 if $XCC _queue.c -o _queue 2>&3; then
764 rm -f _queue.c _queue
/external/icu/android_icu4j/src/main/java/android/icu/impl/locale/
DLocaleObjectCache.java19 private ReferenceQueue<V> _queue = new ReferenceQueue<V>(); field in LocaleObjectCache
45 CacheEntry<K, V> newEntry = new CacheEntry<K, V>(key, newVal, _queue); in get()
64 while ((entry = (CacheEntry<K, V>)_queue.poll()) != null) { in cleanStaleEntries()
/external/icu/icu4j/eclipse-build/plugins.template/com.ibm.icu.base/src/com/ibm/icu/impl/locale/
DLocaleObjectCache.java15 private ReferenceQueue<V> _queue = new ReferenceQueue<V>(); field in LocaleObjectCache
41 CacheEntry<K, V> newEntry = new CacheEntry<K, V>(key, newVal, _queue); in get()
60 while ((entry = (CacheEntry<K, V>)_queue.poll()) != null) { in cleanStaleEntries()
/external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/locale/
DLocaleObjectCache.java15 private ReferenceQueue<V> _queue = new ReferenceQueue<V>(); field in LocaleObjectCache
41 CacheEntry<K, V> newEntry = new CacheEntry<K, V>(key, newVal, _queue); in get()
60 while ((entry = (CacheEntry<K, V>)_queue.poll()) != null) { in cleanStaleEntries()
/external/autotest/site_utils/
Dgs_offloader_unittest.py908 self._queue = Queue.Queue()
920 self._job.enqueue_offload(self._queue, days_old)
921 self._job.enqueue_offload(self._queue, days_old)
922 self.assertTrue(self._queue.empty())
935 self._job.enqueue_offload(self._queue, days_old)
937 self.assertFalse(self._queue.empty())
938 v = self._queue.get_nowait()
939 self.assertTrue(self._queue.empty())
/external/chromium-trace/catapult/dashboard/dashboard/
Dtask_runner.py66 _queue=_TASK_QUEUE_NAME)
Dbench_find_anomalies.py374 deferred.defer(_AddCreateTestBenchTasks, _queue=_TASK_QUEUE_NAME)
434 deferred.defer(_CreateTestBench, test.key, _queue=_TASK_QUEUE_NAME)
/external/blktrace/doc/
Dblktrace.tex750 BLK\_TA\_QUEUE & (RQ) Command queued to request\_queue. \\
757 BLK\_TA\_ISSUE & Command set to driver for request\_queue. \\ \hline
774 \item[blk\_add\_trace\_rq(struct request\_queue *q, struct request\_queue
777 request\_queue. The \emph{what} parameter describes the change in
778 the request\_queue state, and is one of the request queue action
782 \item[blk\_add\_trace\_bio(struct request\_queue *q, struct bio *bio,
788 \item[blk\_add\_trace\_generic(struct request\_queue *q, struct bio *bio,
795 \item[blk\_add\_trace\_pdu\_int(struct request\_queue *q, u32 what,
802 \item[blk\_add\_trace\_remap(struct request\_queue *q, struct bio *bio,
807 \item[blk\_add\_trace\_msg(struct request\_queue *q, char *fmt, ...)]
/external/jetty/lib/
Djetty-util-6.1.26.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/mortbay/ org/ ...
/external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/
Dorg.mortbay.jetty.util_6.1.23.v201004211559.jarMETA-INF/MANIFEST.MF META-INF/ECLIPSEF.SF META-INF/ECLIPSEF ...
/external/guice/extensions/struts2/lib/
Djetty-util-6.1.0.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/mortbay/ org/ ...
/external/guice/extensions/persist/lib/
Ddb4o-6.4.14.8131-java5.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/db4o/ com/ ...
/external/robolectric/v3/runtime/
Dandroid-all-4.1.2_r1-robolectric-0.jarMETA-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/ ...
Dandroid-all-4.2.2_r1.2-robolectric-0.jarMETA-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/ ...
Dandroid-all-4.3_r2-robolectric-0.jarMETA-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/ ...
Dandroid-all-5.1.1_r9-robolectric-1.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/ ...
Dandroid-all-5.0.0_r2-robolectric-1.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/ ...
Dandroid-all-4.4_r1-robolectric-1.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/ ...