| /external/webrtc/rtc_base/ |
| D | buffer_queue_unittest.cc | 24 BufferQueue queue1(1, kSize); in TEST() local
28 EXPECT_EQ(0u, queue1.size()); in TEST()
29 EXPECT_FALSE(queue1.ReadFront(out, kSize, &bytes)); in TEST()
32 EXPECT_TRUE(queue1.WriteBack(in, kSize, &bytes)); in TEST()
34 EXPECT_EQ(1u, queue1.size()); in TEST()
37 EXPECT_FALSE(queue1.WriteBack(in, kSize, &bytes)); in TEST()
38 EXPECT_EQ(1u, queue1.size()); in TEST()
41 EXPECT_TRUE(queue1.ReadFront(out, kSize, &bytes)); in TEST()
46 EXPECT_FALSE(queue1.ReadFront(out, kSize, &bytes)); in TEST()
47 EXPECT_EQ(0u, queue1.size()); in TEST()
[all …]
|
| /external/libchrome/base/task/sequence_manager/ |
| D | work_queue_sets_unittest.cc | 125 WorkQueue* queue1 = NewTaskQueue("queue1"); in TEST_F() local
128 queue1->Push(FakeTaskWithEnqueueOrder(6)); in TEST_F()
132 work_queue_sets_->ChangeSetIndex(queue1, set); in TEST_F()
142 WorkQueue* queue1 = NewTaskQueue("queue1"); in TEST_F() local
145 queue1->Push(FakeTaskWithEnqueueOrder(6)); in TEST_F()
150 work_queue_sets_->ChangeSetIndex(queue1, set); in TEST_F()
166 WorkQueue* queue1 = NewTaskQueue("queue1"); in TEST_F() local
169 queue1->Push(FakeTaskWithEnqueueOrder(6)); in TEST_F()
173 work_queue_sets_->ChangeSetIndex(queue1, set); in TEST_F()
190 WorkQueue* queue1 = NewTaskQueue("queue1"); in TEST_F() local
[all …]
|
| D | sequence_manager_impl_unittest.cc | 968 scoped_refptr<TestTaskQueue> queue1 = runners_[0]; in TEST_P() local
974 queue1->InsertFenceAt(GetTickClock()->NowTicks() + in TEST_P()
979 queue1->PostTask(FROM_HERE, BindOnce(&RecordTimeAndQueueTask, &run_times, in TEST_P()
980 queue1, GetTickClock())); in TEST_P()
983 queue1->GetTaskQueueImpl()->ReloadImmediateWorkQueueIfEmpty(); in TEST_P()
988 queue1->PostTask(FROM_HERE, BindOnce(&RecordTimeAndQueueTask, &run_times, in TEST_P()
989 queue1, GetTickClock())); in TEST_P()
999 queue1, start_time_ + TimeDelta::FromMilliseconds(300)), in TEST_P()
1311 scoped_refptr<TaskQueue> queue1 = in TEST_P() local
1322 queue1->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | serial_device_batch_scheduler_test.cc | 121 std::unique_ptr<BatchScheduler<FakeTask>> queue1; in TEST() local
124 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue1)); in TEST()
128 TF_ASSERT_OK(ScheduleTask(100, queue1.get())); in TEST()
235 std::unique_ptr<BatchScheduler<FakeTask>> queue1; in TEST() local
239 TF_ASSERT_OK(scheduler->AddQueue(queue_options, queue_callback, &queue1)); in TEST()
245 TF_ASSERT_OK(ScheduleTask(100, queue1.get())); in TEST()
370 std::unique_ptr<BatchScheduler<FakeTask>> queue1; in TEST() local
372 TF_ASSERT_OK(scheduler->AddQueue({}, queue_callback, &queue1)); in TEST()
376 TF_ASSERT_OK(ScheduleTask(800, queue1.get())); in TEST()
|
| D | adaptive_shared_batch_scheduler_test.cc | 244 std::unique_ptr<BatchScheduler<FakeTask>> queue1; in TEST() local
247 TF_ASSERT_OK(scheduler->AddQueue(queue_options, queue_callback, &queue1)); in TEST()
252 TF_ASSERT_OK(ScheduleTask(100, queue1.get())); in TEST()
253 while (queue1->NumEnqueuedTasks() > 0) { in TEST()
256 TF_ASSERT_OK(ScheduleTask(100, queue1.get())); in TEST()
258 TF_ASSERT_OK(ScheduleTask(100, queue1.get())); in TEST()
264 TF_ASSERT_OK(ScheduleTask(900, queue1.get())); in TEST()
|
| /external/webrtc/rtc_base/synchronization/ |
| D | sequence_checker_unittest.cc | 121 TaskQueueForTest queue1; in TEST() local
122 queue1.SendTask([&] { EXPECT_TRUE(sequence_checker.IsCurrent()); }, in TEST()
|
| /external/compiler-rt/test/tsan/Darwin/ |
| D | gcd-serial-queue-norace.mm | 14 dispatch_queue_t q1 = dispatch_queue_create("my.queue1", DISPATCH_QUEUE_CONCURRENT);
|
| D | gcd-sync-race.mm | 15 dispatch_queue_t q1 = dispatch_queue_create("my.queue1", DISPATCH_QUEUE_CONCURRENT);
|
| /external/OpenCL-CTS/test_conformance/buffers/ |
| D | test_sub_buffers.cpp | 432 clCommandQueueWrapper queue1 = clCreateCommandQueue( testingContext, deviceID, 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/grpc-grpc/src/objective-c/tests/ |
| D | GRPCClientTests.m | 460 NSString *queue_label = @"test.queue1";
|