Home
last modified time | relevance | path

Searched refs:transaction_with_task_source (Results 1 – 7 of 7) sorted by relevance

/aosp_15_r20/external/cronet/base/task/thread_pool/
H A Dthread_group.cc134 RegisteredTaskSourceAndTransaction transaction_with_task_source, in SchedulePushTaskSourceAndWakeUpWorkers() argument
140 std::move(transaction_with_task_source)); in SchedulePushTaskSourceAndWakeUpWorkers()
274 RegisteredTaskSourceAndTransaction transaction_with_task_source) { in ReEnqueueTaskSourceLockRequired() argument
277 transaction_with_task_source.transaction.traits()); in ReEnqueueTaskSourceLockRequired()
280 transaction_with_task_source.task_source.WillReEnqueue( in ReEnqueueTaskSourceLockRequired()
281 TimeTicks::Now(), &transaction_with_task_source.transaction); in ReEnqueueTaskSourceLockRequired()
287 if (transaction_with_task_source.task_source->immediate_heap_handle() in ReEnqueueTaskSourceLockRequired()
290 std::move(transaction_with_task_source.task_source)); in ReEnqueueTaskSourceLockRequired()
295 auto sort_key = transaction_with_task_source.task_source->GetSortKey(); in ReEnqueueTaskSourceLockRequired()
300 transaction_with_task_source.transaction.Release(); in ReEnqueueTaskSourceLockRequired()
[all …]
H A Dthread_group_semaphore.cc169 RegisteredTaskSourceAndTransaction transaction_with_task_source) { in PushTaskSourceAndWakeUpWorkers() argument
172 std::move(transaction_with_task_source)); in PushTaskSourceAndWakeUpWorkers()
286 transaction_with_task_source; in SwapProcessedTask() local
288 transaction_with_task_source.emplace( in SwapProcessedTask()
321 if (transaction_with_task_source) { in SwapProcessedTask()
327 std::move(transaction_with_task_source.value())); in SwapProcessedTask()
H A Dthread_group_impl.cc164 RegisteredTaskSourceAndTransaction transaction_with_task_source) { in PushTaskSourceAndWakeUpWorkers() argument
167 std::move(transaction_with_task_source)); in PushTaskSourceAndWakeUpWorkers()
284 transaction_with_task_source; in SwapProcessedTask() local
286 transaction_with_task_source.emplace( in SwapProcessedTask()
326 if (transaction_with_task_source) { in SwapProcessedTask()
329 std::move(transaction_with_task_source.value())); in SwapProcessedTask()
H A Dthread_group.h125 RegisteredTaskSourceAndTransaction transaction_with_task_source) = 0;
267 RegisteredTaskSourceAndTransaction transaction_with_task_source,
311 RegisteredTaskSourceAndTransaction transaction_with_task_source)
326 RegisteredTaskSourceAndTransaction transaction_with_task_source);
H A Dpooled_single_thread_task_runner_manager.cc261 RegisteredTaskSourceAndTransaction transaction_with_task_source) in EnqueueTaskSourceLockRequired() argument
263 auto sort_key = transaction_with_task_source.task_source->GetSortKey(); in EnqueueTaskSourceLockRequired()
268 transaction_with_task_source.transaction.Release(); in EnqueueTaskSourceLockRequired()
269 priority_queue_.Push(std::move(transaction_with_task_source.task_source), in EnqueueTaskSourceLockRequired()
H A Dthread_group_semaphore.h81 RegisteredTaskSourceAndTransaction transaction_with_task_source) override;
H A Dthread_group_impl.h97 RegisteredTaskSourceAndTransaction transaction_with_task_source) override;