Home
last modified time | relevance | path

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

12345678910>>...110

/external/mesa3d/src/util/
Du_queue.c47 util_queue_kill_threads(struct util_queue *queue, unsigned keep_num_threads,
82 add_to_atexit_list(struct util_queue *queue) in add_to_atexit_list() argument
87 list_add(&queue->head, &queue_list); in add_to_atexit_list()
92 remove_from_atexit_list(struct util_queue *queue) in remove_from_atexit_list() argument
98 if (iter == queue) { in remove_from_atexit_list()
246 struct util_queue *queue; member
253 struct util_queue *queue = ((struct thread_input*)input)->queue; in util_queue_thread_func() local
258 if (queue->flags & UTIL_QUEUE_INIT_SET_FULL_THREAD_AFFINITY) { in util_queue_thread_func()
269 if (queue->flags & UTIL_QUEUE_INIT_USE_MINIMUM_PRIORITY) { in util_queue_thread_func()
275 if (strlen(queue->name) > 0) { in util_queue_thread_func()
[all …]
/external/guava/android/guava-tests/test/com/google/common/collect/
DEvictingQueueTest.java45 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local
46 assertEquals(0, queue.size()); in testCreateWithZeroSize()
48 assertTrue(queue.add("hi")); in testCreateWithZeroSize()
49 assertEquals(0, queue.size()); in testCreateWithZeroSize()
51 assertTrue(queue.offer("hi")); in testCreateWithZeroSize()
52 assertEquals(0, queue.size()); in testCreateWithZeroSize()
54 assertFalse(queue.remove("hi")); in testCreateWithZeroSize()
55 assertEquals(0, queue.size()); in testCreateWithZeroSize()
58 queue.element(); in testCreateWithZeroSize()
63 assertNull(queue.peek()); in testCreateWithZeroSize()
[all …]
/external/guava/guava-tests/test/com/google/common/collect/
DEvictingQueueTest.java45 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local
46 assertEquals(0, queue.size()); in testCreateWithZeroSize()
48 assertTrue(queue.add("hi")); in testCreateWithZeroSize()
49 assertEquals(0, queue.size()); in testCreateWithZeroSize()
51 assertTrue(queue.offer("hi")); in testCreateWithZeroSize()
52 assertEquals(0, queue.size()); in testCreateWithZeroSize()
54 assertFalse(queue.remove("hi")); in testCreateWithZeroSize()
55 assertEquals(0, queue.size()); in testCreateWithZeroSize()
58 queue.element(); in testCreateWithZeroSize()
63 assertNull(queue.peek()); in testCreateWithZeroSize()
[all …]
/external/zstd/contrib/pzstd/utils/test/
DWorkQueueTest.cpp23 WorkQueue<int>* queue; member
29 while (queue->pop(result)) { in operator ()()
38 WorkQueue<int> queue; in TEST() local
41 queue.push(5); in TEST()
42 EXPECT_TRUE(queue.pop(result)); in TEST()
45 queue.push(1); in TEST()
46 queue.push(2); in TEST()
47 EXPECT_TRUE(queue.pop(result)); in TEST()
49 EXPECT_TRUE(queue.pop(result)); in TEST()
52 queue.push(1); in TEST()
[all …]
/external/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/util/
DTimedValueQueueTest.java29 private TimedValueQueue<String> queue; field in TimedValueQueueTest
33 queue = new TimedValueQueue<>(); in setUp()
38 queue.add(0, "a"); in addAndPollValues()
39 queue.add(1, "b"); in addAndPollValues()
40 queue.add(2, "c"); in addAndPollValues()
41 assertThat(queue.poll(0)).isEqualTo("a"); in addAndPollValues()
42 assertThat(queue.poll(1)).isEqualTo("b"); in addAndPollValues()
43 assertThat(queue.poll(2)).isEqualTo("c"); in addAndPollValues()
48 queue = new TimedValueQueue<>(1); in bufferCapacityIncreasesAutomatically()
50 queue.add(i, "" + i); in bufferCapacityIncreasesAutomatically()
[all …]
DIntArrayQueueTest.java32 IntArrayQueue queue = new IntArrayQueue(); in add_willDoubleCapacity() local
33 int capacity = queue.capacity(); in add_willDoubleCapacity()
36 queue.add(i); in add_willDoubleCapacity()
39 assertThat(queue.capacity()).isEqualTo(2 * capacity); in add_willDoubleCapacity()
40 assertThat(queue.size()).isEqualTo(capacity + 1); in add_willDoubleCapacity()
45 IntArrayQueue queue = new IntArrayQueue(); in isEmpty_returnsTrueAfterConstruction() local
47 assertThat(queue.isEmpty()).isTrue(); in isEmpty_returnsTrueAfterConstruction()
52 IntArrayQueue queue = new IntArrayQueue(); in isEmpty_returnsFalseAfterAddition() local
53 queue.add(0); in isEmpty_returnsFalseAfterAddition()
55 assertThat(queue.isEmpty()).isFalse(); in isEmpty_returnsFalseAfterAddition()
[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/OpenCL-CTS/test_conformance/integer_ops/
Dprocs.h33 extern int test_popcount(cl_device_id device, cl_context context, cl_command_queue queue, int num_e…
34 extern int test_integer_clz(cl_device_id deviceID, cl_context context, cl_command_queue queue, int …
35 extern int test_integer_ctz(cl_device_id deviceID, cl_context context, cl_command_queue queue, int …
36 extern int test_integer_hadd(cl_device_id deviceID, cl_context context, cl_command_queue queue, int…
37 extern int test_integer_rhadd(cl_device_id deviceID, cl_context context, cl_command_queue queue, in…
38 extern int test_integer_mul_hi(cl_device_id deviceID, cl_context context, cl_command_queue queue, i…
39 extern int test_integer_rotate(cl_device_id deviceID, cl_context context, cl_command_queue queue, i…
40 extern int test_integer_clamp(cl_device_id deviceID, cl_context context, cl_command_queue queue, in…
41 extern int test_integer_mad_sat(cl_device_id deviceID, cl_context context, cl_command_queue queue, …
42 extern int test_integer_mad_hi(cl_device_id deviceID, cl_context context, cl_command_queue queue, i…
[all …]
/external/OpenCL-CTS/test_conformance/basic/
Dprocs.h25 extern int test_hostptr(cl_device_id deviceID, cl_context context, cl_command_queue queue, int…
26 extern int test_fpmath_float(cl_device_id deviceID, cl_context context, cl_command_queue queue…
27 …fpmath_float2(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
28 …fpmath_float4(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
29 extern int test_intmath_int(cl_device_id deviceID, cl_context context, cl_command_queue queue,…
30 extern int test_intmath_int2(cl_device_id deviceID, cl_context context, cl_command_queue queue…
31 extern int test_intmath_int4(cl_device_id deviceID, cl_context context, cl_command_queue queue…
32 extern int test_intmath_long(cl_device_id deviceID, cl_context context, cl_command_queue queue…
33 …intmath_long2(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
34 …intmath_long4(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
[all …]
/external/OpenCL-CTS/test_conformance/api/
Dprocs.h23 …single_kernel(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
24 …d_two_kernels(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
25 …ernels_in_one(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
26 …nels_manually(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
27 …kernel_names( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
28 …ls_in_program(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
29 …_enqueue_task(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
30 …setup_cleanup(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
32 extern int test_bool_type(cl_device_id deviceID, cl_context context, cl_command_queue queue,…
33 …rm_extensions(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
[all …]
/external/OpenCL-CTS/test_conformance/buffers/
Dprocs.h34 …fer_read_int( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
35 …er_read_uint( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
36 …er_read_long( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
37 …r_read_ulong( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
38 …r_read_short( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
39 …_read_ushort( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
40 …r_read_float( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
41 …er_read_half( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
42 …er_read_char( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
43 …r_read_uchar( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
[all …]
/external/mesa3d/src/gallium/drivers/llvmpipe/
Dlp_scene_queue.c74 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); in lp_scene_queue_create() local
76 if (!queue) in lp_scene_queue_create()
79 (void) mtx_init(&queue->mutex, mtx_plain); in lp_scene_queue_create()
80 cnd_init(&queue->change); in lp_scene_queue_create()
82 return queue; in lp_scene_queue_create()
88 lp_scene_queue_destroy(struct lp_scene_queue *queue) in lp_scene_queue_destroy() argument
90 cnd_destroy(&queue->change); in lp_scene_queue_destroy()
91 mtx_destroy(&queue->mutex); in lp_scene_queue_destroy()
92 FREE(queue); in lp_scene_queue_destroy()
98 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) in lp_scene_dequeue() argument
[all …]
/external/perfetto/src/base/
Dcircular_queue_unittest.cc28 CircularQueue<int> queue(/*initial_capacity=*/1); in TEST() local
29 ASSERT_EQ(queue.size(), 0u); in TEST()
30 queue.emplace_back(101); in TEST()
31 ASSERT_EQ(queue.size(), 1u); in TEST()
32 queue.emplace_back(102); in TEST()
33 queue.emplace_back(103); in TEST()
34 queue.emplace_back(104); in TEST()
35 ASSERT_EQ(queue.size(), 4u); in TEST()
37 auto it = queue.begin(); in TEST()
42 ASSERT_EQ(it, queue.end()); in TEST()
[all …]
/external/antlr/runtime/ObjC/Framework/test/runtime/misc/
DFastQueueTest.m18 FastQueue *queue = [[FastQueue newFastQueue] retain];
19 STAssertNotNil(queue, @"Queue was not created and was nil");
20 [queue release];
25 FastQueue *queue = [[FastQueue newFastQueue] 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/OpenCL-CTS/test_conformance/compiler/
Dprocs.h42 cl_command_queue queue, int num_elements);
45 cl_command_queue queue,
49 cl_command_queue queue,
53 cl_command_queue queue,
57 cl_command_queue queue,
60 cl_device_id deviceID, cl_context context, cl_command_queue queue,
64 cl_command_queue queue,
67 cl_command_queue queue, int num_elements);
70 cl_command_queue queue,
73 cl_command_queue queue, int num_elements);
[all …]
/external/perfetto/test/trace_processor/graphics/
Dgpu_render_stages.out2 "queue 1","queue desc 1",0,5,"render stage(1)",0,"[NULL]","[NULL]",0,0,"[NULL]",0,"[NULL]",0,"[NULL…
3 "queue 0","queue desc 0",0,5,"stage 0",0,"[NULL]","[NULL]",42,0,"[NULL]",0,"[NULL]",0,"[NULL]",0,0,…
4 "queue 1","queue desc 1",10,5,"stage 1",0,"description","stage desc 1",42,0,"[NULL]",0,"[NULL]",0,"…
5 "queue 2","[NULL]",20,5,"stage 2",0,"[NULL]","[NULL]",42,0,"[NULL]",0,"[NULL]",0,"[NULL]",0,2,"[NUL…
6 "queue 0","queue desc 0",30,5,"stage 3",0,"[NULL]","[NULL]",42,0,"[NULL]",0,"[NULL]",0,"[NULL]",0,0…
8 "queue 0","queue desc 0",50,5,"stage 0",0,"key1","value1",42,0,"[NULL]",0,"[NULL]",0,"[NULL]",0,0,"…
9 "queue 0","queue desc 0",60,5,"stage 0",0,"key1","value1",42,0,"[NULL]",0,"[NULL]",0,"[NULL]",0,0,"…
10 "queue 0","queue desc 0",60,5,"stage 0",0,"key2","value2",42,0,"[NULL]",0,"[NULL]",0,"[NULL]",0,0,"…
11 "queue 0","queue desc 0",70,5,"stage 0",0,"key1","[NULL]",42,0,"[NULL]",0,"[NULL]",0,"[NULL]",0,0,"…
12 "queue 0","queue desc 0",80,5,"stage 2",0,"[NULL]","[NULL]",42,0,"[NULL]",0,"[NULL]",0,"[NULL]",0,0…
[all …]
/external/OpenCL-CTS/test_conformance/pipes/
Dprocs.h30 …eadwrite_int( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
31 …adwrite_uint( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
32 …adwrite_long( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
33 …dwrite_ulong( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
34 …dwrite_short( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
35 …write_ushort( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
36 …dwrite_float( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
37 …adwrite_half( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
38 …adwrite_char( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
39 …dwrite_uchar( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
[all …]
/external/libnl/lib/netfilter/
Dqueue_obj.c34 struct nfnl_queue *queue = (struct nfnl_queue *) a; in nfnl_queue_dump() local
39 if (queue->ce_mask & QUEUE_ATTR_GROUP) in nfnl_queue_dump()
40 nl_dump(p, "group=%u ", queue->queue_group); in nfnl_queue_dump()
42 if (queue->ce_mask & QUEUE_ATTR_MAXLEN) in nfnl_queue_dump()
43 nl_dump(p, "maxlen=%u ", queue->queue_maxlen); in nfnl_queue_dump()
45 if (queue->ce_mask & QUEUE_ATTR_COPY_MODE) in nfnl_queue_dump()
47 nfnl_queue_copy_mode2str(queue->queue_copy_mode, in nfnl_queue_dump()
50 if (queue->ce_mask & QUEUE_ATTR_COPY_RANGE) in nfnl_queue_dump()
51 nl_dump(p, "copy_range=%u ", queue->queue_copy_range); in nfnl_queue_dump()
84 void nfnl_queue_get(struct nfnl_queue *queue) in nfnl_queue_get() argument
[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/rtc_base/
Dswap_queue_unittest.cc47 SwapQueue<std::vector<int>> queue(2, i); in TEST() local
49 EXPECT_TRUE(queue.Insert(&i)); in TEST()
51 EXPECT_TRUE(queue.Insert(&i)); in TEST()
53 EXPECT_TRUE(queue.Remove(&i)); in TEST()
55 EXPECT_TRUE(queue.Remove(&i)); in TEST()
60 SwapQueue<int> queue(2); in TEST() local
64 EXPECT_TRUE(queue.Insert(&i)); in TEST()
66 EXPECT_TRUE(queue.Insert(&i)); in TEST()
71 EXPECT_FALSE(queue.Insert(&i)); in TEST()
75 EXPECT_TRUE(queue.Remove(&i)); in TEST()
[all …]
/external/webrtc/test/pc/e2e/analyzer/video/
Dmulti_head_queue_test.cc20 MultiHeadQueue<int> queue = MultiHeadQueue<int>(10); in TEST() local
21 EXPECT_TRUE(queue.IsEmpty(0)); in TEST()
23 EXPECT_FALSE(queue.PopFront(i).has_value()); in TEST()
24 EXPECT_FALSE(queue.Front(i).has_value()); in TEST()
29 MultiHeadQueue<int> queue = MultiHeadQueue<int>(1); in TEST() local
30 queue.PushBack(1); in TEST()
31 EXPECT_EQ(queue.size(), 1lu); in TEST()
32 EXPECT_TRUE(queue.Front(0).has_value()); in TEST()
33 EXPECT_EQ(queue.Front(0).value(), 1); in TEST()
34 absl::optional<int> value = queue.PopFront(0); in TEST()
[all …]
/external/mesa3d/src/gallium/drivers/virgl/
Dvirgl_transfer_queue.c44 typedef void (*list_action_t)(struct virgl_transfer_queue *queue,
140 virgl_transfer_queue_find_overlap(const struct virgl_transfer_queue *queue, in virgl_transfer_queue_find_overlap() argument
147 LIST_FOR_EACH_ENTRY(xfer, &queue->transfer_list, queue_link) { in virgl_transfer_queue_find_overlap()
162 static void remove_transfer(struct virgl_transfer_queue *queue, in remove_transfer() argument
166 virgl_resource_destroy_transfer(queue->vctx, queued); in remove_transfer()
169 static void replace_unmapped_transfer(struct virgl_transfer_queue *queue, in replace_unmapped_transfer() argument
178 remove_transfer(queue, queued); in replace_unmapped_transfer()
179 queue->num_dwords -= (VIRGL_TRANSFER3D_SIZE + 1); in replace_unmapped_transfer()
182 static void transfer_put(struct virgl_transfer_queue *queue, in transfer_put() argument
187 queue->vs->vws->transfer_put(queue->vs->vws, queued->hw_res, in transfer_put()
[all …]
/external/OpenCL-CTS/test_conformance/gl/
Dprocs.h24 cl_command_queue queue, int num_elements );
27 cl_command_queue queue, int numElements );
34 cl_command_queue queue, int num_elements );
37 cl_command_queue queue, int num_elements );
40 cl_command_queue queue, int num_elements );
43 cl_command_queue queue, int num_elements );
46 cl_command_queue queue, int num_elements );
49 cl_command_queue queue, int num_elements );
52 cl_command_queue queue, int num_elements );
55 cl_command_queue queue, int num_elements );
[all …]
/external/perfetto/src/profiling/perf/
Dunwind_queue_unittest.cc27 UnwindQueue<int, kCapacity> queue; in TEST() local
31 WriteView v = queue.BeginWrite(); in TEST()
33 queue.at(v.write_pos) = i; in TEST()
34 queue.CommitWrite(); in TEST()
38 WriteView v = queue.BeginWrite(); in TEST()
43 ReadView v = queue.BeginRead(); in TEST()
49 read_back.push_back(queue.at(pos)); in TEST()
51 queue.CommitNewReadPosition(v.write_pos); in TEST()
56 ASSERT_TRUE(queue.BeginWrite().valid); in TEST()
58 ASSERT_TRUE(queue.BeginRead().read_pos == queue.BeginRead().write_pos); in TEST()
[all …]

12345678910>>...110