| /external/cronet/stable/net/third_party/quiche/src/quiche/web_transport/ |
| D | web_transport_priority_scheduler_test.cc | 24 void ScheduleIds(PriorityScheduler& scheduler, absl::Span<const StreamId> ids) { in ScheduleIds()
30 std::vector<StreamId> PopAll(PriorityScheduler& scheduler) { in PopAll()
45 PriorityScheduler scheduler; in TEST() local
62 PriorityScheduler scheduler; in TEST() local
84 PriorityScheduler scheduler; in TEST() local
104 PriorityScheduler scheduler; in TEST() local
126 PriorityScheduler scheduler; in TEST() local
141 PriorityScheduler scheduler; in TEST() local
155 PriorityScheduler scheduler; in TEST() local
169 PriorityScheduler scheduler; in TEST() local
[all …]
|
| D | web_transport_priority_scheduler.cc | 37 PerGroupScheduler& scheduler = scheduler_it->second; in Register() local
65 PerGroupScheduler* scheduler = SchedulerForStream(stream_id); in UpdateSendOrder() local
74 PerGroupScheduler* scheduler = SchedulerForStream(stream_id); in UpdateSendGroup() local
134 PerGroupScheduler& scheduler = it->second; in PopFront() local
159 const PerGroupScheduler* scheduler = SchedulerForStream(stream_id); in IsScheduled() local
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/web_transport/ |
| D | web_transport_priority_scheduler_test.cc | 24 void ScheduleIds(PriorityScheduler& scheduler, absl::Span<const StreamId> ids) { in ScheduleIds()
30 std::vector<StreamId> PopAll(PriorityScheduler& scheduler) { in PopAll()
45 PriorityScheduler scheduler; in TEST() local
62 PriorityScheduler scheduler; in TEST() local
84 PriorityScheduler scheduler; in TEST() local
104 PriorityScheduler scheduler; in TEST() local
126 PriorityScheduler scheduler; in TEST() local
141 PriorityScheduler scheduler; in TEST() local
155 PriorityScheduler scheduler; in TEST() local
169 PriorityScheduler scheduler; in TEST() local
[all …]
|
| D | web_transport_priority_scheduler.cc | 37 PerGroupScheduler& scheduler = scheduler_it->second; in Register() local
65 PerGroupScheduler* scheduler = SchedulerForStream(stream_id); in UpdateSendOrder() local
74 PerGroupScheduler* scheduler = SchedulerForStream(stream_id); in UpdateSendGroup() local
134 PerGroupScheduler& scheduler = it->second; in PopFront() local
159 const PerGroupScheduler* scheduler = SchedulerForStream(stream_id); in IsScheduled() local
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | SchedulerTest.kt | 44 val scheduler = Dispatchers.Default.asScheduler() in <lambda>() constant
158 runSchedulerTest(nThreads = n) { scheduler -> in <lambda>() method
186 val scheduler = dispatcher.asScheduler() in <lambda>() constant
240 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
246 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
264 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
270 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
276 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
282 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
299 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
[all …]
|
| D | SchedulerStressTest.kt | 21 val scheduler = dispatcher.asScheduler() in <lambda>() constant
28 val scheduler = dispatcher.asScheduler() in <lambda>() constant
60 val scheduler = dispatcher.asScheduler() in <lambda>() constant
67 val scheduler = dispatcher.asScheduler() in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | SchedulerTest.kt | 44 val scheduler = Dispatchers.Default.asScheduler() in <lambda>() constant
158 runSchedulerTest(nThreads = n) { scheduler -> in <lambda>() method
186 val scheduler = dispatcher.asScheduler() in <lambda>() constant
240 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
246 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
264 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
270 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
276 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
282 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
299 val scheduler = (currentDispatcher() as CoroutineDispatcher).asScheduler() in <lambda>() constant
[all …]
|
| D | SchedulerStressTest.kt | 21 val scheduler = dispatcher.asScheduler() in <lambda>() constant
28 val scheduler = dispatcher.asScheduler() in <lambda>() constant
60 val scheduler = dispatcher.asScheduler() in <lambda>() constant
67 val scheduler = dispatcher.asScheduler() in <lambda>() constant
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/common/ |
| D | btree_scheduler_test.cc | 25 void ScheduleIds(BTreeScheduler<Id, Priority>& scheduler, in ScheduleIds()
33 std::vector<Id> PopAll(BTreeScheduler<Id, Priority>& scheduler) { in PopAll()
49 BTreeScheduler<int, int> scheduler; in TEST() local
86 BTreeScheduler<int, int> scheduler; in TEST() local
108 BTreeScheduler<int, int> scheduler; in TEST() local
137 BTreeScheduler<int, int> scheduler; in TEST() local
163 BTreeScheduler<int, int> scheduler; in TEST() local
174 BTreeScheduler<int, int> scheduler; in TEST() local
185 BTreeScheduler<int, int> scheduler; in TEST() local
196 BTreeScheduler<int, int> scheduler; in TEST() local
[all …]
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/common/ |
| D | btree_scheduler_test.cc | 25 void ScheduleIds(BTreeScheduler<Id, Priority>& scheduler, in ScheduleIds()
33 std::vector<Id> PopAll(BTreeScheduler<Id, Priority>& scheduler) { in PopAll()
49 BTreeScheduler<int, int> scheduler; in TEST() local
86 BTreeScheduler<int, int> scheduler; in TEST() local
108 BTreeScheduler<int, int> scheduler; in TEST() local
137 BTreeScheduler<int, int> scheduler; in TEST() local
163 BTreeScheduler<int, int> scheduler; in TEST() local
174 BTreeScheduler<int, int> scheduler; in TEST() local
185 BTreeScheduler<int, int> scheduler; in TEST() local
196 BTreeScheduler<int, int> scheduler; in TEST() local
[all …]
|
| /external/webrtc/net/dcsctp/tx/ |
| D | stream_scheduler_test.cc | 50 std::map<StreamID, size_t> GetPacketCounts(StreamScheduler& scheduler, in GetPacketCounts()
74 TestStream(StreamScheduler& scheduler, in TestStream()
95 StreamScheduler scheduler(kMtu); in TEST() local
102 StreamScheduler scheduler(kMtu); in TEST() local
117 StreamScheduler scheduler(kMtu); in TEST() local
134 StreamScheduler scheduler(kMtu); in TEST() local
176 StreamScheduler scheduler(kMtu); in TEST() local
238 StreamScheduler scheduler(kMtu); in TEST() local
262 StreamScheduler scheduler(kMtu); in TEST() local
292 StreamScheduler scheduler(kMtu); in TEST() local
[all …]
|
| /external/swiftshader/third_party/marl/src/ |
| D | scheduler_test.cpp | 25 auto scheduler = std::unique_ptr<marl::Scheduler>( in TEST_F() local
30 auto scheduler = std::unique_ptr<marl::Scheduler>( in TEST_F() local
44 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F() local
57 auto scheduler = marl::Scheduler::get(); in TEST_P() local
86 auto scheduler = marl::Scheduler::get(); in TEST_P() local
129 auto scheduler = marl::Scheduler::get(); in TEST_P() local
163 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F() local
189 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F() local
219 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F() local
|
| D | marl_test.h | 62 auto scheduler = new marl::Scheduler(cfg); in SetUp() local
67 auto scheduler = marl::Scheduler::get(); in TearDown() local
69 delete scheduler; in TearDown() local
|
| /external/webrtc/video/ |
| D | decode_synchronizer_unittest.cc | 101 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST_F() local
129 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST_F() local
153 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST_F() local
175 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST_F() local
214 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST_F() local
243 auto scheduler = decode_synchronizer_.CreateSynchronizedFrameScheduler(); in TEST() local
|
| D | decode_synchronizer.cc | 116 auto scheduler = std::make_unique<SynchronizedFrameDecodeScheduler>(this); in CreateSynchronizedFrameScheduler() local
128 SynchronizedFrameDecodeScheduler* scheduler) { in OnFrameScheduled()
154 SynchronizedFrameDecodeScheduler* scheduler) { in RemoveFrameScheduler()
178 for (auto* scheduler : schedulers_) { in OnTick() local
|
| D | task_queue_frame_decode_scheduler_unittest.cc | 34 TaskQueueFrameDecodeScheduler scheduler(time_controller_.GetClock(), in TEST() local
60 TaskQueueFrameDecodeScheduler scheduler(time_controller_.GetClock(), in TEST() local
80 TaskQueueFrameDecodeScheduler scheduler(time_controller_.GetClock(), in TEST() local
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | adaptive_shared_batch_scheduler_test.cc | 47 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask()
72 std::shared_ptr<Scheduler> scheduler; in TEST() local
124 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
167 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
240 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
315 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
368 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
402 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
430 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
453 std::shared_ptr<AdaptiveSharedBatchScheduler<FakeTask>> scheduler; in TEST() local
[all …]
|
| D | serial_device_batch_scheduler_test.cc | 44 Status ScheduleTask(size_t task_size, BatchScheduler<FakeTask>* scheduler) { in ScheduleTask()
69 std::shared_ptr<Scheduler> scheduler; in TEST() local
118 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
145 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
229 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
277 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
331 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
367 std::shared_ptr<SerialDeviceBatchScheduler<FakeTask>> scheduler; in TEST() local
|
| /external/grpc-grpc/test/core/client_channel/lb_policy/ |
| D | static_stride_scheduler_test.cc | 67 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
82 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
97 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
119 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
141 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
175 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
194 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
212 const absl::optional<StaticStrideScheduler> scheduler = in TEST() local
|
| D | static_stride_scheduler_benchmark.cc | 61 const absl::optional<StaticStrideScheduler> scheduler = in BM_StaticStrideSchedulerPickNonAtomic() local
76 const absl::optional<StaticStrideScheduler> scheduler = in BM_StaticStrideSchedulerPickAtomic() local
92 const absl::optional<StaticStrideScheduler> scheduler = in BM_StaticStrideSchedulerMake() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/jvm/test/migration/ |
| D | TestCoroutineScopeTest.kt | 38 val scheduler = TestCoroutineScheduler() in <lambda>() constant
45 val scheduler = TestCoroutineScheduler() in <lambda>() constant
53 val scheduler = TestCoroutineScheduler() in <lambda>() constant
69 val scheduler = TestCoroutineScheduler() in <lambda>() constant
|
| /external/ComputeLibrary/src/runtime/ |
| D | RuntimeContext.cpp | 36 void RuntimeContext::set_scheduler(IScheduler *scheduler) in set_scheduler()
42 IScheduler *RuntimeContext::scheduler() in scheduler() function in arm_compute::RuntimeContext
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| D | RoboExecutorService.java | 27 private final Scheduler scheduler; field in RoboExecutorService
32 private final Scheduler scheduler; field in RoboExecutorService.AdvancingFutureTask
34 public AdvancingFutureTask(Scheduler scheduler, Callable<V> callable) { in AdvancingFutureTask()
39 public AdvancingFutureTask(Scheduler scheduler, Runnable runnable, V result) { in AdvancingFutureTask()
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | blockingcall.h | 36 auto scheduler = Scheduler::get(); in call() local
61 auto scheduler = Scheduler::get(); in call() local
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/cancellation/ |
| D | CancellationServer.java | 55 ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); in main() local
80 private final ScheduledExecutorService scheduler; field in CancellationServer.SlowEcho
83 public SlowEcho(ScheduledExecutorService scheduler) { in SlowEcho()
|