Home
last modified time | relevance | path

Searched refs:_queue (Results 1 - 25 of 39) sorted by relevance

12

/third_party/python/Lib/asyncio/
H A Dqueues.py48 self._queue = collections.deque()
51 return self._queue.popleft()
54 self._queue.append(item)
76 if getattr(self, '_queue', None):
77 result += f' _queue={list(self._queue)!r}'
88 return len(self._queue)
97 return not self._queue
225 self._queue = []
228 heappush(self._queue, ite
[all...]
/third_party/python/Lib/
H A 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
162 # Use heapq to sort the queue rather than using 'sorted(self._queue)'.
166 events = self._queue[:]
H A 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/jinja2/
H A 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
[all...]
/third_party/node/deps/v8/third_party/jinja2/
H A 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
[all...]
/third_party/node/tools/inspector_protocol/jinja2/
H A 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
[all...]
/third_party/skia/third_party/externals/jinja2/
H A 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
[all...]
/third_party/mesa3d/src/vulkan/runtime/
H A Dvk_debug_utils.c240 VkQueue _queue, in vk_common_QueueBeginDebugUtilsLabelEXT()
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()
275 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueInsertDebugUtilsLabelEXT()
239 vk_common_QueueBeginDebugUtilsLabelEXT( VkQueue _queue, const VkDebugUtilsLabelEXT *pLabelInfo) vk_common_QueueBeginDebugUtilsLabelEXT() argument
271 vk_common_QueueInsertDebugUtilsLabelEXT( VkQueue _queue, const VkDebugUtilsLabelEXT *pLabelInfo) vk_common_QueueInsertDebugUtilsLabelEXT() argument
H A 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()
H A Dvk_synchronization2.c285 VkQueue _queue, in vk_common_QueueSubmit()
290 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueSubmit()
416 VkResult result = device->dispatch_table.QueueSubmit2KHR(_queue, in vk_common_QueueSubmit()
284 vk_common_QueueSubmit( VkQueue _queue, uint32_t submitCount, const VkSubmitInfo* pSubmits, VkFence fence) vk_common_QueueSubmit() argument
H A Dvk_queue.c1126 vk_common_QueueSubmit2KHR(VkQueue _queue, in vk_common_QueueSubmit2KHR() argument
1131 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueSubmit2KHR()
1165 vk_common_QueueBindSparse(VkQueue _queue, in vk_common_QueueBindSparse() argument
1170 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueBindSparse()
1284 vk_common_QueueWaitIdle(VkQueue _queue) in vk_common_QueueWaitIdle() argument
1286 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueWaitIdle()
/third_party/mesa3d/src/imagination/vulkan/
H A 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()
H A 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/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/locale/
H A 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/icu/ohos_icu4j/src/main/java/ohos/global/icu/impl/locale/
H A 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/mesa3d/src/intel/vulkan/
H A Danv_wsi.c91 VkQueue _queue, in anv_QueuePresentKHR()
94 ANV_FROM_HANDLE(anv_queue, queue, _queue); in anv_QueuePresentKHR()
112 _queue, 0, in anv_QueuePresentKHR()
90 anv_QueuePresentKHR( VkQueue _queue, const VkPresentInfoKHR* pPresentInfo) anv_QueuePresentKHR() argument
/third_party/mesa3d/src/amd/vulkan/
H A 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/skia/tools/skpbench/
H A 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/node/deps/npm/node_modules/graceful-fs/
H A Dlegacy-streams.js110 this._queue = [];
114 this._queue.push([this._open, this.path, this.flags, this.mode, undefined]);
/third_party/mesa3d/src/virtio/vulkan/
H A 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()
H A 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/
H A Devent.cpp133 _queue(q), _command(command), _fence(NULL) {
165 return &_queue(); in queue()
/third_party/mesa3d/src/freedreno/vulkan/
H A 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()
/third_party/node/benchmark/
H A Dcommon.js44 this.queue = this._queue(this.options);
120 _queue(options) {
/third_party/mesa3d/src/amd/vulkan/layers/
H A Dradv_sqtt_layer.c338 radv_handle_thread_trace(VkQueue _queue) in radv_handle_thread_trace() argument
340 RADV_FROM_HANDLE(radv_queue, queue, _queue); in radv_handle_thread_trace()
352 queue->device->vk.dispatch_table.QueueWaitIdle(_queue); in radv_handle_thread_trace()
403 sqtt_QueuePresentKHR(VkQueue _queue, const VkPresentInfoKHR *pPresentInfo) in sqtt_QueuePresentKHR() argument
407 result = radv_QueuePresentKHR(_queue, pPresentInfo); in sqtt_QueuePresentKHR()
411 radv_handle_thread_trace(_queue); in sqtt_QueuePresentKHR()

Completed in 18 milliseconds

12