Home
last modified time | relevance | path

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

12345678910>>...33

/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/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/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/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/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/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.java84 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 1, mDelivery); in add_requestProcessedInCorrectOrder() local
85 queue.addRequestFinishedListener(listener); in add_requestProcessedInCorrectOrder()
86 queue.add(lowerPriorityReq); in add_requestProcessedInCorrectOrder()
87 queue.add(higherPriorityReq); in add_requestProcessedInCorrectOrder()
88 queue.start(); in add_requestProcessedInCorrectOrder()
97 queue.stop(); in add_requestProcessedInCorrectOrder()
122 RequestQueue queue = new RequestQueue(new NoCache(), mMockNetwork, 3, mDelivery); in add_dedupeByCacheKey() local
123 queue.addRequestFinishedListener(listener); in add_dedupeByCacheKey()
124 queue.add(req1); in add_dedupeByCacheKey()
125 queue.add(req2); in add_dedupeByCacheKey()
[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/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/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_open/
D19-1.c42 mqd_t queue; in main() local
52 queue = mq_open(qname, O_CREAT | O_RDWR | O_NONBLOCK, in main()
54 if (queue == (mqd_t) - 1) { in main()
60 if (mq_receive(queue, msgrcd, BUFFER, &pri) != -1) { in main()
66 if (mq_send(queue, msgptr, strlen(msgptr), 1) == -1) { in main()
70 mq_close(queue); in main()
75 queue = mq_open(qname, O_RDWR | O_NONBLOCK, S_IRUSR | S_IWUSR, NULL); in main()
76 if (queue == (mqd_t) - 1) { in main()
80 mq_close(queue); in main()
85 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1) { in main()
[all …]
/external/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_send/
D3-1.c50 mqd_t queue; in main() local
59 queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr); in main()
60 if (queue == (mqd_t) - 1) { in main()
65 if (mq_send(queue, msgptr3, strlen(msgptr3), PRI3) != 0) { in main()
70 if (mq_send(queue, msgptr1, strlen(msgptr1), PRI1) != 0) { in main()
75 if (mq_send(queue, msgptr4, strlen(msgptr4), PRI4) != 0) { in main()
80 if (mq_send(queue, msgptr2, strlen(msgptr2), PRI2) != 0) { in main()
85 if (mq_send(queue, msgptr5, strlen(msgptr5), PRI5) != 0) { in main()
90 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1) { in main()
100 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1) { in main()
[all …]
D3-2.c52 mqd_t queue; in main() local
61 queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr); in main()
62 if (queue == (mqd_t) - 1) { in main()
67 if (mq_send(queue, msgptr3, strlen(msgptr3), PRI3) != 0) { in main()
73 if (mq_send(queue, msgptr1, strlen(msgptr1), PRI1) != 0) { in main()
79 if (mq_send(queue, msgptr4, strlen(msgptr4), PRI4) != 0) { in main()
85 if (mq_send(queue, msgptr2, strlen(msgptr2), PRI2) != 0) { in main()
91 if (mq_send(queue, msgptr5, strlen(msgptr5), PRI5) != 0) { in main()
97 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1) { in main()
107 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1) { in main()
[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 …]
/external/strace/
Dunwind.c93 static void queue_print(struct queue_t *queue);
118 tcp->queue = xmalloc(sizeof(*tcp->queue)); in unwind_tcb_init()
119 tcp->queue->head = NULL; in unwind_tcb_init()
120 tcp->queue->tail = NULL; in unwind_tcb_init()
126 queue_print(tcp->queue); in unwind_tcb_fin()
127 free(tcp->queue); in unwind_tcb_fin()
128 tcp->queue = NULL; in unwind_tcb_fin()
479 queue_put(struct queue_t *queue, in queue_put() argument
496 if (!queue->head) { in queue_put()
497 queue->head = call; in queue_put()
[all …]
/external/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_timedsend/
D3-1.c54 mqd_t queue; in main() local
62 queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr); in main()
63 if (queue == (mqd_t) - 1) { in main()
70 if (mq_timedsend(queue, msgptr3, strlen(msgptr3), PRI3, &ts) != 0) { in main()
76 if (mq_timedsend(queue, msgptr1, strlen(msgptr1), PRI1, &ts) != 0) { in main()
82 if (mq_timedsend(queue, msgptr4, strlen(msgptr4), PRI4, &ts) != 0) { in main()
88 if (mq_timedsend(queue, msgptr2, strlen(msgptr2), PRI2, &ts) != 0) { in main()
94 if (mq_timedsend(queue, msgptr5, strlen(msgptr5), PRI5, &ts) != 0) { in main()
99 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1) { in main()
109 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1) { in main()
[all …]
D3-2.c55 mqd_t queue; in main() local
64 queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr); in main()
65 if (queue == (mqd_t) - 1) { in main()
72 if (mq_timedsend(queue, msgptr3, strlen(msgptr3), PRI3, &ts) != 0) { in main()
79 if (mq_timedsend(queue, msgptr1, strlen(msgptr1), PRI1, &ts) != 0) { in main()
86 if (mq_timedsend(queue, msgptr4, strlen(msgptr4), PRI4, &ts) != 0) { in main()
93 if (mq_timedsend(queue, msgptr2, strlen(msgptr2), PRI2, &ts) != 0) { in main()
100 if (mq_timedsend(queue, msgptr5, strlen(msgptr5), PRI5, &ts) != 0) { in main()
106 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1) { in main()
116 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1) { in main()
[all …]

12345678910>>...33