Home
last modified time | relevance | path

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

123

/third_party/python/Lib/asyncio/
Dqueues.py48 self._queue = collections.deque()
51 return self._queue.popleft()
54 self._queue.append(item)
89 return len(self._queue)
98 return not self._queue
226 self._queue = []
229 heappush(self._queue, item)
232 return heappop(self._queue)
239 self._queue = []
242 self._queue.append(item)
[all …]
/third_party/python/Lib/
Dsched.py56 self._queue = []
75 heapq.heappush(self._queue, event)
95 self._queue.remove(event)
96 heapq.heapify(self._queue)
101 return not self._queue
130 q = self._queue
166 events = self._queue[:]
Dqueue.py9 from _queue import SimpleQueue
17 from _queue import Empty
269 self._queue = deque()
278 self._queue.append(item)
296 return self._queue.popleft()
316 return len(self._queue) == 0
320 return len(self._queue)
/third_party/node/deps/npm/node_modules/fs-minipass/
Dindex.js30 const _queue = Symbol('_queue') constant
211 this[_queue] = []
264 if (!this[_writing] && !this[_queue].length &&
278 if (this[_fd] === null || this[_writing] || this[_queue].length) {
279 this[_queue].push(buf)
300 if (this[_queue].length)
318 if (this[_queue].length === 0) {
321 } else if (this[_queue].length === 1)
322 this[_write](this[_queue].pop())
324 const iovec = this[_queue]
[all …]
/third_party/node/tools/inspector_protocol/jinja2/
Dutils.py316 self._queue = deque()
321 self._popleft = self._queue.popleft
322 self._pop = self._queue.pop
323 self._remove = self._queue.remove
325 self._append = self._queue.append
331 '_queue': self._queue
345 rv._queue = deque(self._queue)
374 self._queue.clear()
401 if self._queue[-1] != key:
446 result = [(key, self._mapping[key]) for key in list(self._queue)]
[all …]
/third_party/skia/third_party/externals/jinja2/
Dutils.py351 self._queue = deque()
356 self._popleft = self._queue.popleft
357 self._pop = self._queue.pop
358 self._remove = self._queue.remove
360 self._append = self._queue.append
366 "_queue": self._queue,
380 rv._queue.extend(self._queue)
405 self._queue.clear()
429 if self._queue[-1] != key:
473 result = [(key, self._mapping[key]) for key in list(self._queue)]
[all …]
/third_party/jinja2/
Dutils.py431 self._queue: "te.Deque[t.Any]" = deque()
436 self._popleft = self._queue.popleft
437 self._pop = self._queue.pop
438 self._remove = self._queue.remove
440 self._append = self._queue.append
446 "_queue": self._queue,
460 rv._queue.extend(self._queue)
484 self._queue.clear()
506 if self._queue[-1] != key:
546 result = [(key, self._mapping[key]) for key in list(self._queue)]
[all …]
/third_party/flutter/flutter/packages/flutter_tools/lib/src/android/
Dandroid_console.dart32 StreamQueue<String> _queue;
36 assert(_queue == null);
38 _queue = StreamQueue<String>(_socket.asyncMap(ascii.decode));
53 _queue = null;
60 final String text = await _queue.next;
/third_party/mesa3d/src/vulkan/runtime/
Dvk_debug_utils.c240 VkQueue _queue, in vk_common_QueueBeginDebugUtilsLabelEXT() argument
243 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueBeginDebugUtilsLabelEXT()
256 vk_common_QueueEndDebugUtilsLabelEXT(VkQueue _queue) in vk_common_QueueEndDebugUtilsLabelEXT() argument
258 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueEndDebugUtilsLabelEXT()
272 VkQueue _queue, in vk_common_QueueInsertDebugUtilsLabelEXT() argument
275 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueInsertDebugUtilsLabelEXT()
Dvk_android.c113 vk_common_QueueSignalReleaseImageANDROID(VkQueue _queue, in vk_common_QueueSignalReleaseImageANDROID() argument
119 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueSignalReleaseImageANDROID()
Dvk_synchronization2.c285 VkQueue _queue, in vk_common_QueueSubmit() argument
290 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueSubmit()
416 VkResult result = device->dispatch_table.QueueSubmit2KHR(_queue, in vk_common_QueueSubmit()
/third_party/mesa3d/src/imagination/vulkan/
Dpvr_wsi.c71 VkResult pvr_QueuePresentKHR(VkQueue _queue, in pvr_QueuePresentKHR() argument
74 PVR_FROM_HANDLE(pvr_queue, queue, _queue); in pvr_QueuePresentKHR()
79 _queue, in pvr_QueuePresentKHR()
Dpvr_queue.c170 VkResult pvr_QueueWaitIdle(VkQueue _queue) in pvr_QueueWaitIdle() argument
172 PVR_FROM_HANDLE(pvr_queue, queue, _queue); in pvr_QueueWaitIdle()
590 VkResult pvr_QueueSubmit(VkQueue _queue, in pvr_QueueSubmit() argument
595 PVR_FROM_HANDLE(pvr_queue, queue, _queue); in pvr_QueueSubmit()
/third_party/flutter/skia/tools/skpbench/
Dskpbench.py114 self._queue = queue
121 self._queue.put(Message(Message.READLINE, line.decode('utf-8').rstrip()))
122 self._queue.put(Message(Message.EXIT))
190 self._queue = Queue()
218 self._monitor = SubprocessMonitor(self._queue, self._proc)
222 message = self._queue.get()
248 Timer(1, lambda: self._queue.put(Message(Message.POLL_HARDWARE)))
/third_party/icu/ohos_icu4j/src/main/java/ohos/global/icu/impl/locale/
DLocaleObjectCache.java21 private ReferenceQueue<V> _queue = new ReferenceQueue<V>(); field in LocaleObjectCache
47 CacheEntry<K, V> newEntry = new CacheEntry<K, V>(key, newVal, _queue); in get()
66 while ((entry = (CacheEntry<K, V>)_queue.poll()) != null) { in cleanStaleEntries()
/third_party/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/locale/
DLocaleObjectCache.java17 private ReferenceQueue<V> _queue = new ReferenceQueue<V>(); field in LocaleObjectCache
43 CacheEntry<K, V> newEntry = new CacheEntry<K, V>(key, newVal, _queue); in get()
62 while ((entry = (CacheEntry<K, V>)_queue.poll()) != null) { in cleanStaleEntries()
/third_party/mesa3d/src/intel/vulkan/
Danv_wsi.c91 VkQueue _queue, in anv_QueuePresentKHR() argument
94 ANV_FROM_HANDLE(anv_queue, queue, _queue); in anv_QueuePresentKHR()
112 _queue, 0, in anv_QueuePresentKHR()
/third_party/skia/tools/skpbench/
Dskpbench.py128 self._queue = queue
135 self._queue.put(Message(Message.READLINE, line.decode('utf-8').rstrip()))
136 self._queue.put(Message(Message.EXIT))
212 self._queue = Queue()
240 self._monitor = SubprocessMonitor(self._queue, self._proc)
244 message = self._queue.get()
270 Timer(1, lambda: self._queue.put(Message(Message.POLL_HARDWARE)))
/third_party/mesa3d/src/amd/vulkan/
Dradv_wsi.c118 radv_QueuePresentKHR(VkQueue _queue, const VkPresentInfoKHR *pPresentInfo) in radv_QueuePresentKHR() argument
120 RADV_FROM_HANDLE(radv_queue, queue, _queue); in radv_QueuePresentKHR()
122 radv_device_to_handle(queue->device), _queue, in radv_QueuePresentKHR()
/third_party/node/deps/npm/node_modules/bluebird/js/release/
Dmap.js24 this._queue = []; property in module.exports.MappingPromiseArray
52 this._queue.push(index);
109 var queue = this._queue;
/third_party/node/deps/npm/node_modules/graceful-fs/
Dlegacy-streams.js110 this._queue = []; property in legacy.WriteStream
114 this._queue.push([this._open, this.path, this.flags, this.mode, undefined]);
/third_party/mesa3d/src/virtio/vulkan/
Dvn_wsi.c269 vn_QueuePresentKHR(VkQueue _queue, const VkPresentInfoKHR *pPresentInfo) in vn_QueuePresentKHR() argument
272 struct vn_queue *queue = vn_queue_from_handle(_queue); in vn_QueuePresentKHR()
276 vn_device_to_handle(queue->device), _queue, in vn_QueuePresentKHR()
Dvn_queue.c348 vn_QueueSubmit(VkQueue _queue, in vn_QueueSubmit() argument
354 struct vn_queue *queue = vn_queue_from_handle(_queue); in vn_QueueSubmit()
364 result = vn_queue_submission_prepare_submit(&submit, _queue, submitCount, in vn_QueueSubmit()
450 vn_QueueBindSparse(VkQueue _queue, in vn_QueueBindSparse() argument
456 struct vn_queue *queue = vn_queue_from_handle(_queue); in vn_QueueBindSparse()
464 &submit, _queue, bindInfoCount, pBindInfo, fence); in vn_QueueBindSparse()
482 vn_QueueWaitIdle(VkQueue _queue) in vn_QueueWaitIdle() argument
485 struct vn_queue *queue = vn_queue_from_handle(_queue); in vn_QueueWaitIdle()
488 VkResult result = vn_QueueSubmit(_queue, 0, NULL, queue->wait_fence); in vn_QueueWaitIdle()
/third_party/mesa3d/src/gallium/frontends/clover/core/
Devent.cpp133 _queue(q), _command(command), _fence(NULL) {
165 return &_queue(); in queue()
/third_party/mesa3d/src/freedreno/vulkan/
Dtu_kgsl.c342 tu_QueueSubmit2(VkQueue _queue, in tu_QueueSubmit2() argument
347 TU_FROM_HANDLE(tu_queue, queue, _queue); in tu_QueueSubmit2()
753 tu_QueueSignalReleaseImageANDROID(VkQueue _queue, in tu_QueueSignalReleaseImageANDROID() argument
759 TU_FROM_HANDLE(tu_queue, queue, _queue); in tu_QueueSignalReleaseImageANDROID()

123