Home
last modified time | relevance | path

Searched refs:queue2 (Results 1 – 16 of 16) sorted by relevance

/external/webrtc/rtc_base/
Dbuffer_queue_unittest.cc25 BufferQueue queue2(2, kSize); in TEST() local
59 EXPECT_TRUE(queue2.WriteBack(in, kSize / 2, &bytes)); in TEST()
60 EXPECT_EQ(1u, queue2.size()); in TEST()
61 EXPECT_TRUE(queue2.WriteBack(in + kSize / 2, kSize / 2, &bytes)); in TEST()
62 EXPECT_EQ(2u, queue2.size()); in TEST()
63 EXPECT_TRUE(queue2.ReadFront(out, kSize, &bytes)); in TEST()
66 EXPECT_EQ(1u, queue2.size()); in TEST()
67 EXPECT_TRUE(queue2.ReadFront(out, kSize, &bytes)); in TEST()
70 EXPECT_EQ(0u, queue2.size()); in TEST()
73 EXPECT_TRUE(queue2.WriteBack(in, kSize / 2, &bytes)); in TEST()
[all …]
/external/libchrome/base/task/sequence_manager/
Dwork_queue_sets_unittest.cc126 WorkQueue* queue2 = NewTaskQueue("queue2"); in TEST_F() local
129 queue2->Push(FakeTaskWithEnqueueOrder(5)); in TEST_F()
133 work_queue_sets_->ChangeSetIndex(queue2, set); in TEST_F()
143 WorkQueue* queue2 = NewTaskQueue("queue2"); in TEST_F() local
146 queue2->Push(FakeTaskWithEnqueueOrder(1)); in TEST_F()
147 queue2->Push(FakeTaskWithEnqueueOrder(3)); in TEST_F()
151 work_queue_sets_->ChangeSetIndex(queue2, set); in TEST_F()
156 EXPECT_EQ(queue2, selected_work_queue); in TEST_F()
158 queue2->PopTaskForTesting(); in TEST_F()
159 work_queue_sets_->OnPopQueue(queue2); in TEST_F()
[all …]
Dsequence_manager_impl_unittest.cc969 scoped_refptr<TestTaskQueue> queue2 = runners_[1]; in TEST_P() local
991 queue2->PostTask(FROM_HERE, BindOnce(&RecordTimeAndQueueTask, &run_times, in TEST_P()
992 queue2, GetTickClock())); in TEST_P()
1001 queue2, start_time_ + TimeDelta::FromMilliseconds(300)))); in TEST_P()
1313 scoped_refptr<TaskQueue> queue2 = CreateTaskQueue(); in TEST_P() local
1327 queue2->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
1531 scoped_refptr<TaskQueue> queue2 = CreateTaskQueue(); in TEST_P() local
1534 ASSERT_NE(queue1, queue2); in TEST_P()
1536 ASSERT_NE(queue2, queue3); in TEST_P()
1540 queue2->PostTask(FROM_HERE, BindOnce(&TestTask, 2, &run_order)); in TEST_P()
[all …]
/external/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_open/
D11-1.c34 mqd_t queue, queue2; in main() local
56 queue2 = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL); in main()
57 if (queue2 == (mqd_t) - 1) { in main()
65 if (mq_send(queue2, msgptr, strlen(msgptr), 1) != 0) { in main()
69 mq_close(queue2); in main()
75 mq_close(queue2); in main()
D15-1.c28 mqd_t queue, queue2; in main() local
42 queue2 = mq_open(qname, O_CREAT | O_EXCL | O_RDWR, in main()
44 if (queue2 != (mqd_t) - 1) { in main()
49 mq_close(queue2); in main()
D23-1.c29 mqd_t queue, queue2; in main() local
43 queue2 = mq_open(qname, O_CREAT | O_EXCL | O_RDWR, in main()
45 if (queue2 != (mqd_t) - 1) { in main()
50 mq_close(queue2); in main()
/external/tensorflow/tensorflow/core/kernels/batching_util/
Dserial_device_batch_scheduler_test.cc122 std::unique_ptr<BatchScheduler<FakeTask>> queue2; in TEST() local
125 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue2)); in TEST()
129 TF_ASSERT_OK(ScheduleTask(100, queue2.get())); in TEST()
236 std::unique_ptr<BatchScheduler<FakeTask>> queue2; in TEST() local
241 TF_ASSERT_OK(scheduler->AddQueue(queue_options, queue_callback, &queue2)); in TEST()
248 TF_ASSERT_OK(ScheduleTask(1000, queue2.get())); in TEST()
371 std::unique_ptr<BatchScheduler<FakeTask>> queue2; in TEST() local
373 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue2)); in TEST()
377 TF_ASSERT_OK(ScheduleTask(100, queue2.get())); in TEST()
379 EXPECT_EQ(queue2->NumEnqueuedTasks(), 1); in TEST()
[all …]
Dadaptive_shared_batch_scheduler_test.cc245 std::unique_ptr<BatchScheduler<FakeTask>> queue2; in TEST() local
249 TF_ASSERT_OK(scheduler->AddQueue(queue_options, queue_callback, &queue2)); in TEST()
261 TF_ASSERT_OK(ScheduleTask(50, queue2.get())); in TEST()
/external/perfetto/test/trace_processor/graphics/
Dgpu_render_stages_interned_spec.out4 "queue2","queue2 description",300,10,"render",0,"description","render graphics",0,0,"[NULL]",0,"[NU…
Dgpu_render_stages_interned_spec.textproto60 name: "queue2"
61 description: "queue2 description"
/external/webrtc/rtc_base/synchronization/
Dsequence_checker_unittest.cc127 TaskQueueForTest queue2; in TEST() local
128 queue2.SendTask( in TEST()
/external/compiler-rt/test/tsan/Darwin/
Dgcd-serial-queue-norace.mm15 dispatch_queue_t q2 = dispatch_queue_create("my.queue2", DISPATCH_QUEUE_SERIAL);
Dgcd-sync-race.mm16 dispatch_queue_t q2 = dispatch_queue_create("my.queue2", DISPATCH_QUEUE_CONCURRENT);
/external/llvm-project/lldb/test/API/functionalities/tsan/multiple/
Dmain.m60 dispatch_queue_t q = dispatch_queue_create("my.queue2", DISPATCH_QUEUE_CONCURRENT);
/external/OpenCL-CTS/test_conformance/buffers/
Dtest_sub_buffers.cpp435 clCommandQueueWrapper queue2 = clCreateCommandQueue( testingContext, otherDevice, 0, &error ); in test_sub_buffers_read_write_dual_devices() local
457 …return test_sub_buffers_read_write_core( testingContext, queue1, queue2, maxBuffer1, addressAlign1… in test_sub_buffers_read_write_dual_devices()
/external/deqp/external/vulkancts/modules/vulkan/api/
DvktApiDeviceInitializationTests.cpp1250 const VkQueue queue2 = getDeviceQueue2(deviceDriver, *device, &deviceQueueInfo2); in createDeviceQueue2Test() local
1252 VK_CHECK(deviceDriver.queueWaitIdle(queue2)); in createDeviceQueue2Test()
1341 const VkQueue queue2 = getDeviceQueue2(deviceDriver, *device, &deviceQueueInfo2); in createDeviceQueue2UnmatchedFlagsTest() local
1343 if (queue2 != DE_NULL) in createDeviceQueue2UnmatchedFlagsTest()