| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| vktSynchronizationBasicEventTests.cpp | 84 const VkQueue queue = context.getUniversalQueue(); local
106 VK_CHECK(vk.queueSubmit(queue, 1u, &submitInfo, DE_NULL));
107 VK_CHECK(vk.queueWaitIdle(queue));
116 VK_CHECK(vk.queueSubmit(queue, 1u, &submitInfo, DE_NULL));
117 VK_CHECK(vk.queueWaitIdle(queue));
129 const VkQueue queue = context.getUniversalQueue(); local
158 VK_CHECK(vk.queueSubmit(queue, 1u, &submitInfo, *fence));
160 return tcu::TestStatus::fail("Queue should not end execution");
166 return tcu::TestStatus::fail("Queue should end execution");
176 const VkQueue queue = context.getUniversalQueue() local
216 const VkQueue queue = context.getUniversalQueue(); local
276 const VkQueue queue = context.getUniversalQueue(); local
[all...] |
| vktSynchronizationBasicSemaphoreTests.cpp | 50 const VkQueue queue = context.getUniversalQueue(); local
92 VK_CHECK(vk.queueSubmit(queue, 2u, submitInfo, *fence));
95 return tcu::TestStatus::fail("Basic semaphore tests with one queue failed");
97 return tcu::TestStatus::pass("Basic semaphore tests with one queue passed");
107 VkQueue queue; member in struct:vkt::synchronization::__anon17952::Queues
193 vk.getDeviceQueue(*logicalDevice, queues[queueReqNdx].queueFamilyIndex, queueReqNdx, &queues[queueReqNdx].queue);
195 vk.getDeviceQueue(*logicalDevice, queues[queueReqNdx].queueFamilyIndex, 0u, &queues[queueReqNdx].queue);
232 VK_CHECK(vk.queueSubmit(queues[FIRST].queue, 1u, &submitInfo[FIRST], *fence[FIRST]));
233 VK_CHECK(vk.queueSubmit(queues[SECOND].queue, 1u, &submitInfo[SECOND], *fence[SECOND]));
236 return tcu::TestStatus::fail("Basic semaphore tests with multi queue failed")
[all...] |
| /external/dhcpcd-6.8.2/ |
| eloop.h | 60 int queue; member in struct:eloop_timeout
98 int eloop_q_timeout_add_sec(struct eloop_ctx *, int queue,
100 int eloop_q_timeout_add_tv(struct eloop_ctx *, int queue,
|
| /external/guava/guava/src/com/google/common/base/internal/ |
| Finalizer.java | 63 * @param queue a reference queue that the thread will poll.
70 ReferenceQueue<Object> queue,
85 Finalizer finalizer = new Finalizer(finalizableReferenceClass, queue, frqReference);
104 private final ReferenceQueue<Object> queue; field in class:Finalizer
112 ReferenceQueue<Object> queue,
114 this.queue = queue;
124 * Loops continuously, pulling references off the queue and cleaning them up.
131 if (!cleanUp(queue.remove()))
[all...] |
| /external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/ |
| ICUNotifier.java | 96 * Queue a notification on the notification thread for the current
108 notifyThread.queue(listeners.toArray(new EventListener[listeners.size()]));
118 private final List<EventListener[]> queue = new ArrayList<EventListener[]>(); field in class:ICUNotifier.NotifyThread
125 * Queue the notification on the thread.
127 public void queue(EventListener[] list) { method in class:ICUNotifier.NotifyThread
129 queue.add(list);
144 while (queue.isEmpty()) {
147 list = queue.remove(0);
|
| /external/ims/rcs/presencepolling/src/com/android/service/ims/presence/ |
| CapabilityPolling.java | 549 PollingsQueue queue = PollingsQueue.getInstance(mContext); local
550 if (queue != null) {
551 queue.setCapabilityPolling(this);
552 queue.add(type, list);
657 PollingsQueue queue = PollingsQueue.getInstance(null); local
658 if (queue != null) {
659 queue.clear();
[all...] |
| /external/libnl/lib/netfilter/ |
| queue_obj.c | 2 * lib/netfilter/queue_obj.c Netfilter Queue
14 * @defgroup queue Queue
21 #include <netlink/netfilter/queue.h>
33 struct nfnl_queue *queue = (struct nfnl_queue *) a; local
38 if (queue->ce_mask & QUEUE_ATTR_GROUP)
39 nl_dump(p, "group=%u ", queue->queue_group);
41 if (queue->ce_mask & QUEUE_ATTR_MAXLEN)
42 nl_dump(p, "maxlen=%u ", queue->queue_maxlen);
44 if (queue->ce_mask & QUEUE_ATTR_COPY_MODE
[all...] |
| /external/linux-kselftest/tools/testing/selftests/mqueue/ |
| mq_open_tests.c | 18 * open a posix message queue and then reports whether or not they
40 " path Path name of the message queue to create\n"
56 mqd_t queue = -1; variable
87 if (queue != -1)
88 if (mq_close(queue))
155 printf("Current rlimit value for POSIX message queue bytes is "
166 printf("Temporarily lowering default queue parameters "
178 printf("Temporarily lowering maximum queue parameters "
182 "queue parameters to the maximum queue "
[all...] |
| /external/mesa3d/src/gallium/drivers/svga/ |
| svga_state_rss.c | 52 svga_queue_rs( &queue, SVGA3D_RS_##token, value ); \
62 svga_queue_rs( &queue, SVGA3D_RS_##token, value ); \
87 struct rs_queue queue; local
90 queue.rs_count = 0;
279 if (queue.rs_count) {
284 queue.rs_count ) != PIPE_OK)
288 queue.rs,
289 queue.rs_count * sizeof queue.rs[0]);
|
| svga_state_tss.c | 80 struct bind_queue *queue)
128 queue->bind[queue->bind_count].unit = unit;
129 queue->bind[queue->bind_count].view = view;
130 queue->bind_count++;
149 struct bind_queue queue; local
154 queue.bind_count = 0;
162 &queue);
175 &queue);
232 struct bind_queue queue; local
386 struct ts_queue queue; local
[all...] |