Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 1263) sorted by relevance

12345678910>>...51

/external/mesa3d/src/gallium/auxiliary/util/
Du_queue.c32 static void util_queue_killall_and_wait(struct util_queue *queue);
66 add_to_atexit_list(struct util_queue *queue) in add_to_atexit_list() argument
71 LIST_ADD(&queue->head, &queue_list); in add_to_atexit_list()
76 remove_from_atexit_list(struct util_queue *queue) in remove_from_atexit_list() argument
82 if (iter == queue) { in remove_from_atexit_list()
113 struct util_queue *queue; member
119 struct util_queue *queue = ((struct thread_input*)input)->queue; in PIPE_THREAD_ROUTINE() local
124 if (queue->name) { in PIPE_THREAD_ROUTINE()
126 util_snprintf(name, sizeof(name), "%s:%i", queue->name, thread_index); in PIPE_THREAD_ROUTINE()
133 pipe_mutex_lock(queue->lock); in PIPE_THREAD_ROUTINE()
[all …]
/external/guava/guava-tests/test/com/google/common/collect/
DEvictingQueueTest.java44 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local
45 assertEquals(0, queue.size()); in testCreateWithZeroSize()
47 assertTrue(queue.add("hi")); in testCreateWithZeroSize()
48 assertEquals(0, queue.size()); in testCreateWithZeroSize()
50 assertTrue(queue.offer("hi")); in testCreateWithZeroSize()
51 assertEquals(0, queue.size()); in testCreateWithZeroSize()
53 assertFalse(queue.remove("hi")); in testCreateWithZeroSize()
54 assertEquals(0, queue.size()); in testCreateWithZeroSize()
57 queue.element(); in testCreateWithZeroSize()
61 assertNull(queue.peek()); in testCreateWithZeroSize()
[all …]
/external/libchrome/base/synchronization/
Dcondition_variable_unittest.cc259 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F() local
266 base::AutoLock auto_lock(*queue.lock()); in TEST_F()
267 while (!queue.EveryIdWasAllocated()) in TEST_F()
268 queue.all_threads_have_ids()->Wait(); in TEST_F()
273 queue.SpinUntilAllThreadsAreWaiting(); in TEST_F()
277 base::AutoLock auto_lock(*queue.lock()); in TEST_F()
278 EXPECT_EQ(0, queue.GetNumThreadsTakingAssignments()); in TEST_F()
279 EXPECT_EQ(0, queue.GetNumThreadsCompletingTasks()); in TEST_F()
280 EXPECT_EQ(0, queue.task_count()); in TEST_F()
281 EXPECT_EQ(0, queue.GetMaxCompletionsByWorkerThread()); in TEST_F()
[all …]
/external/squashfs-tools/squashfs-tools/
Dcaches-queues-lists.c39 struct queue *queue_init(int size) in queue_init()
41 struct queue *queue = malloc(sizeof(struct queue)); in queue_init() local
43 if(queue == NULL) in queue_init()
50 queue->data = malloc(sizeof(void *) * (size + 1)); in queue_init()
51 if(queue->data == NULL) in queue_init()
54 queue->size = size + 1; in queue_init()
55 queue->readp = queue->writep = 0; in queue_init()
56 pthread_mutex_init(&queue->mutex, NULL); in queue_init()
57 pthread_cond_init(&queue->empty, NULL); in queue_init()
58 pthread_cond_init(&queue->full, NULL); in queue_init()
[all …]
/external/antlr/antlr-3.4/runtime/ObjC/Framework/test/runtime/misc/
DANTLRFastQueueTest.m18 ANTLRFastQueue *queue = [[ANTLRFastQueue newANTLRFastQueue] retain];
19 STAssertNotNil(queue, @"Queue was not created and was nil");
20 [queue release];
25 ANTLRFastQueue *queue = [[ANTLRFastQueue newANTLRFastQueue] retain];
26 STAssertNotNil(queue, @"Queue was not created and was nil");
27 [queue addObject:@"My String"];
28 …STAssertTrue([[queue objectAtIndex:0] isKindOfClass:[NSString class]], @"First object is not a NSS…
29 STAssertEquals([queue objectAtIndex:0], @"My String", @"Object at index zero is invalid");
30 STAssertTrue([queue size] == 1, @"Queue is the wrong size: %d", [queue size]);
31 [queue release];
[all …]
/external/libnl/lib/netfilter/
Dqueue_obj.c33 struct nfnl_queue *queue = (struct nfnl_queue *) a; in nfnl_queue_dump() local
38 if (queue->ce_mask & QUEUE_ATTR_GROUP) in nfnl_queue_dump()
39 nl_dump(p, "group=%u ", queue->queue_group); in nfnl_queue_dump()
41 if (queue->ce_mask & QUEUE_ATTR_MAXLEN) in nfnl_queue_dump()
42 nl_dump(p, "maxlen=%u ", queue->queue_maxlen); in nfnl_queue_dump()
44 if (queue->ce_mask & QUEUE_ATTR_COPY_MODE) in nfnl_queue_dump()
46 nfnl_queue_copy_mode2str(queue->queue_copy_mode, in nfnl_queue_dump()
49 if (queue->ce_mask & QUEUE_ATTR_COPY_RANGE) in nfnl_queue_dump()
50 nl_dump(p, "copy_range=%u ", queue->queue_copy_range); in nfnl_queue_dump()
83 void nfnl_queue_get(struct nfnl_queue *queue) in nfnl_queue_get() argument
[all …]
Dqueue.c111 static int nfnl_queue_build_request(const struct nfnl_queue *queue, in nfnl_queue_build_request() argument
116 if (!nfnl_queue_test_group(queue)) in nfnl_queue_build_request()
120 0, nfnl_queue_get_group(queue)); in nfnl_queue_build_request()
124 if (nfnl_queue_test_maxlen(queue) && in nfnl_queue_build_request()
126 htonl(nfnl_queue_get_maxlen(queue))) < 0) in nfnl_queue_build_request()
132 if (nfnl_queue_test_copy_mode(queue)) { in nfnl_queue_build_request()
135 switch (nfnl_queue_get_copy_mode(queue)) { in nfnl_queue_build_request()
146 params.copy_range = htonl(nfnl_queue_get_copy_range(queue)); in nfnl_queue_build_request()
160 int nfnl_queue_build_create_request(const struct nfnl_queue *queue, in nfnl_queue_build_create_request() argument
166 if ((err = nfnl_queue_build_request(queue, result)) < 0) in nfnl_queue_build_create_request()
[all …]
/external/webrtc/webrtc/common_audio/
Dswap_queue_unittest.cc46 SwapQueue<std::vector<int>> queue(2, i); in TEST() local
48 EXPECT_TRUE(queue.Insert(&i)); in TEST()
50 EXPECT_TRUE(queue.Insert(&i)); in TEST()
52 EXPECT_TRUE(queue.Remove(&i)); in TEST()
54 EXPECT_TRUE(queue.Remove(&i)); in TEST()
59 SwapQueue<int> queue(2); in TEST() local
63 EXPECT_TRUE(queue.Insert(&i)); in TEST()
65 EXPECT_TRUE(queue.Insert(&i)); in TEST()
70 EXPECT_FALSE(queue.Insert(&i)); in TEST()
74 EXPECT_TRUE(queue.Remove(&i)); in TEST()
[all …]
/external/iptables/extensions/
Dlibxt_NFQUEUE.t3 -j NFQUEUE --queue-num 0;=;OK
4 -j NFQUEUE --queue-num 65535;=;OK
5 -j NFQUEUE --queue-num 65536;;FAIL
6 -j NFQUEUE --queue-num -1;;FAIL
8 # ERROR: cannot load: iptables -A INPUT -j NFQUEUE --queue-balance 0:65535
9 # -j NFQUEUE --queue-balance 0:65535;=;OK
10 -j NFQUEUE --queue-balance 0:65536;;FAIL
11 -j NFQUEUE --queue-balance -1:65535;;FAIL
12 -j NFQUEUE --queue-num 10 --queue-bypass;=;OK
13 -j NFQUEUE --queue-balance 0:6 --queue-cpu-fanout --queue-bypass;-j NFQUEUE --queue-balance 0:6 --q…
[all …]
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DListenerCallQueueTest.java43 ListenerCallQueue<Object> queue = in testAddAndExecute() local
47 queue.add(incrementingCallback(counter, 1)); in testAddAndExecute()
48 queue.add(incrementingCallback(counter, 2)); in testAddAndExecute()
49 queue.add(incrementingCallback(counter, 3)); in testAddAndExecute()
50 queue.add(incrementingCallback(counter, 4)); in testAddAndExecute()
52 queue.execute(); in testAddAndExecute()
58 ListenerCallQueue<Object> queue = in testAddAndExecute_withExceptions() local
62 queue.add(incrementingCallback(counter, 1)); in testAddAndExecute_withExceptions()
63 queue.add(THROWING_CALLBACK); in testAddAndExecute_withExceptions()
64 queue.add(incrementingCallback(counter, 2)); in testAddAndExecute_withExceptions()
[all …]
/external/v8/benchmarks/
Drichards.js51 var queue = new Packet(null, ID_WORKER, KIND_WORK);
52 queue = new Packet(queue, ID_WORKER, KIND_WORK);
53 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
55 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE);
56 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
57 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
58 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
60 queue = new Packet(null, ID_DEVICE_B, KIND_DEVICE);
61 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
62 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
[all …]
/external/mesa3d/src/vulkan/wsi/
Dwsi_common_queue.h38 wsi_queue_init(struct wsi_queue *queue, int length) in wsi_queue_init() argument
46 ret = u_vector_init(&queue->vector, sizeof(uint32_t), in wsi_queue_init()
60 ret = pthread_cond_init(&queue->cond, &condattr); in wsi_queue_init()
64 ret = pthread_mutex_init(&queue->mutex, NULL); in wsi_queue_init()
72 pthread_cond_destroy(&queue->cond); in wsi_queue_init()
76 u_vector_finish(&queue->vector); in wsi_queue_init()
82 wsi_queue_destroy(struct wsi_queue *queue) in wsi_queue_destroy() argument
84 u_vector_finish(&queue->vector); in wsi_queue_destroy()
85 pthread_mutex_destroy(&queue->mutex); in wsi_queue_destroy()
86 pthread_cond_destroy(&queue->cond); in wsi_queue_destroy()
[all …]
/external/mesa3d/src/gallium/drivers/svga/
Dsvga_state_tss.c80 struct bind_queue *queue) in emit_tex_binding_unit() argument
128 queue->bind[queue->bind_count].unit = unit; in emit_tex_binding_unit()
129 queue->bind[queue->bind_count].view = view; in emit_tex_binding_unit()
130 queue->bind_count++; in emit_tex_binding_unit()
149 struct bind_queue queue; in update_tss_binding() local
154 queue.bind_count = 0; in update_tss_binding()
162 &queue); in update_tss_binding()
175 &queue); in update_tss_binding()
178 if (queue.bind_count) { in update_tss_binding()
183 queue.bind_count ) != PIPE_OK) in update_tss_binding()
[all …]
/external/volley/src/test/java/com/android/volley/
DRequestQueueIntegrationTest.java87 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestProcessedInCorrectOrder() local
88 queue.addRequestFinishedListener(mMockListener); in add_requestProcessedInCorrectOrder()
89 queue.add(lowerPriorityReq); in add_requestProcessedInCorrectOrder()
90 queue.add(higherPriorityReq); in add_requestProcessedInCorrectOrder()
91 queue.start(); in add_requestProcessedInCorrectOrder()
99 queue.stop(); in add_requestProcessedInCorrectOrder()
119 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 3, mDelivery); in add_dedupeByCacheKey() local
120 queue.addRequestFinishedListener(mMockListener); in add_dedupeByCacheKey()
121 queue.add(req1); in add_dedupeByCacheKey()
122 queue.add(req2); in add_dedupeByCacheKey()
[all …]
/external/mesa3d/src/util/
Du_vector.h53 int u_vector_init(struct u_vector *queue, uint32_t element_size, uint32_t size);
54 void *u_vector_add(struct u_vector *queue);
55 void *u_vector_remove(struct u_vector *queue);
58 u_vector_length(struct u_vector *queue) in u_vector_length() argument
60 return (queue->head - queue->tail) / queue->element_size; in u_vector_length()
79 u_vector_finish(struct u_vector *queue) in u_vector_finish() argument
81 free(queue->data); in u_vector_finish()
84 #define u_vector_foreach(elem, queue) \ argument
85 STATIC_ASSERT(__builtin_types_compatible_p(__typeof__(queue), struct u_vector *)); \
86 for (uint32_t __u_vector_offset = (queue)->tail; \
[all …]
/external/tensorflow/tensorflow/contrib/tpu/python/tpu/
Dtpu_function_test.py41 queue = tpu_feed.InfeedQueue(2)
43 tpu_function.check_function_argument_count(func, 1, queue))
45 tpu_function.check_function_argument_count(func, 2, queue))
61 queue = tpu_feed.InfeedQueue(1)
63 tpu_function.check_function_argument_count(func, 2, queue))
65 tpu_function.check_function_argument_count(func, 1, queue))
67 tpu_function.check_function_argument_count(func, 0, queue))
69 tpu_function.check_function_argument_count(func, 4, queue))
85 queue = tpu_feed.InfeedQueue(1)
87 tpu_function.check_function_argument_count(func, 1, queue))
[all …]
/external/mesa3d/src/gallium/drivers/llvmpipe/
Dlp_scene_queue.c62 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); in lp_scene_queue_create() local
63 if (!queue) in lp_scene_queue_create()
66 queue->ring = util_ringbuffer_create( MAX_SCENE_QUEUE * in lp_scene_queue_create()
68 if (queue->ring == NULL) in lp_scene_queue_create()
71 return queue; in lp_scene_queue_create()
74 FREE(queue); in lp_scene_queue_create()
81 lp_scene_queue_destroy(struct lp_scene_queue *queue) in lp_scene_queue_destroy() argument
83 util_ringbuffer_destroy(queue->ring); in lp_scene_queue_destroy()
84 FREE(queue); in lp_scene_queue_destroy()
90 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) in lp_scene_dequeue() argument
[all …]
/external/tensorflow/tensorflow/core/kernels/
Dqueue_ops.cc35 QueueInterface* queue; in ComputeAsync() local
38 ctx, LookupResource(ctx, HandleFromInput(ctx, 0), &queue), callback); in ComputeAsync()
40 OP_REQUIRES_OK_ASYNC(ctx, GetResourceFromContext(ctx, "handle", &queue), in ComputeAsync()
43 ComputeAsync(ctx, queue, [callback, queue]() { in ComputeAsync()
44 queue->Unref(); in ComputeAsync()
50 virtual void ComputeAsync(OpKernelContext* ctx, QueueInterface* queue,
83 void ComputeAsync(OpKernelContext* ctx, QueueInterface* queue, in ComputeAsync() argument
91 for (DataType dt : queue->component_dtypes()) { in ComputeAsync()
105 OP_REQUIRES_OK_ASYNC(ctx, queue->ValidateTuple(tuple), callback); in ComputeAsync()
106 queue->TryEnqueue(tuple, ctx, callback); in ComputeAsync()
[all …]
/external/wayland/tests/
Dqueue-test.c111 struct wl_event_queue *queue; in client_test_multiple_queues() local
119 queue = wl_display_create_queue(state.display); in client_test_multiple_queues()
120 assert(queue); in client_test_multiple_queues()
126 wl_proxy_set_queue((struct wl_proxy *) callback1, queue); in client_test_multiple_queues()
131 wl_proxy_set_queue((struct wl_proxy *) state.callback2, queue); in client_test_multiple_queues()
136 ret = wl_display_dispatch_queue(state.display, queue); in client_test_multiple_queues()
138 wl_event_queue_destroy(queue); in client_test_multiple_queues()
160 struct wl_event_queue *queue; in client_test_queue_roundtrip() local
170 queue = wl_display_create_queue(display); in client_test_queue_roundtrip()
171 assert(queue); in client_test_queue_roundtrip()
[all …]
/external/libcxx/include/
Dqueue2 //===--------------------------- queue ------------------------------------===//
15 queue synopsis
21 class queue
34 queue() = default;
35 ~queue() = default;
37 queue(const queue& q) = default;
38 queue(queue&& q) = default;
40 queue& operator=(const queue& q) = default;
41 queue& operator=(queue&& q) = default;
43 explicit queue(const container_type& c);
[all …]
/external/syslinux/gpxe/src/drivers/net/ath5k/
Dath5k_qcu.c58 unsigned int queue; in ath5k_hw_setup_tx_queue() local
62 queue = 0; in ath5k_hw_setup_tx_queue()
105 const int queue = 0; in ath5k_hw_reset_tx_queue() local
225 AR5K_QUEUE_DFS_RETRY_LIMIT(queue)); in ath5k_hw_reset_tx_queue()
238 AR5K_QUEUE_DFS_LOCAL_IFS(queue)); in ath5k_hw_reset_tx_queue()
244 AR5K_REG_ENABLE_BITS(ah, AR5K_QUEUE_MISC(queue), in ath5k_hw_reset_tx_queue()
248 AR5K_REG_ENABLE_BITS(ah, AR5K_QUEUE_DFS_MISC(queue), in ath5k_hw_reset_tx_queue()
253 AR5K_REG_ENABLE_BITS(ah, AR5K_QUEUE_DFS_MISC(queue), in ath5k_hw_reset_tx_queue()
261 AR5K_QUEUE_CBRCFG(queue)); in ath5k_hw_reset_tx_queue()
262 AR5K_REG_ENABLE_BITS(ah, AR5K_QUEUE_MISC(queue), in ath5k_hw_reset_tx_queue()
[all …]
/external/tensorflow/tensorflow/core/kernels/batching_util/
Dshared_batch_scheduler_test.cc161 std::unique_ptr<BatchScheduler<FakeTask>> queue; in TEST() local
162 TF_ASSERT_OK(scheduler->AddQueue(queue_options, callback, &queue)); in TEST()
165 TF_ASSERT_OK(ScheduleTask(3, queue.get())); in TEST()
166 TF_ASSERT_OK(ScheduleTask(5, queue.get())); in TEST()
169 TF_ASSERT_OK(ScheduleTask(3 /* (3+5) + 3 > 10 */, queue.get())); in TEST()
170 TF_ASSERT_OK(ScheduleTask(1, queue.get())); in TEST()
171 TF_ASSERT_OK(ScheduleTask(6, queue.get())); in TEST()
223 std::unique_ptr<BatchScheduler<FakeTask>> queue; in TEST() local
224 TF_ASSERT_OK(scheduler->AddQueue(queue_options, callback, &queue)); in TEST()
228 TF_ASSERT_OK(ScheduleTask(1, queue.get())); in TEST()
[all …]
/external/strace/
Dunwind.c97 static void queue_print(struct queue_t *queue);
124 tcp->queue = xmalloc(sizeof(*tcp->queue)); in unwind_tcb_init()
125 tcp->queue->head = NULL; in unwind_tcb_init()
126 tcp->queue->tail = NULL; in unwind_tcb_init()
132 queue_print(tcp->queue); in unwind_tcb_fin()
133 free(tcp->queue); in unwind_tcb_fin()
134 tcp->queue = NULL; in unwind_tcb_fin()
493 queue_put(struct queue_t *queue, in queue_put() argument
510 if (!queue->head) { in queue_put()
511 queue->head = call; in queue_put()
[all …]
/external/python/cpython3/Doc/library/
Dasyncio-queue.rst12 asyncio queue API was designed to be close to classes of the :mod:`queue`
13 module (:class:`~queue.Queue`, :class:`~queue.PriorityQueue`,
14 :class:`~queue.LifoQueue`), but it has no *timeout* parameter. The
22 A queue, useful for coordinating producer and consumer coroutines.
24 If *maxsize* is less than or equal to zero, the queue size is infinite. If
26 when the queue reaches *maxsize*, until an item is removed by :meth:`get`.
28 Unlike the standard library :mod:`queue`, you can reliably know this Queue's
40 Return ``True`` if the queue is empty, ``False`` otherwise.
44 Return ``True`` if there are :attr:`maxsize` items in the queue.
53 Remove and return an item from the queue. If queue is empty, wait until
[all …]
/external/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_close/
D2-1.c97 mqd_t queue; in parent_process() local
102 queue = open_queue(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR); in parent_process()
103 if (queue == (mqd_t) - 1) { in parent_process()
110 if (mq_notify(queue, &se)) { in parent_process()
112 mq_close(queue); in parent_process()
119 mq_close(queue); in parent_process()
126 mq_close(queue); in parent_process()
131 rval = mq_close(queue); in parent_process()
157 mqd_t queue; in child_process() local
173 queue = open_queue(qname, O_RDWR, 0); in child_process()
[all …]

12345678910>>...51