| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Job.kt | 84 public interface Job : CoroutineContext.Element { interface
88 public companion object Key : CoroutineContext.Key<Job> {
198 public val children: Sequence<Job> in getCancellationException()
340 public operator fun plus(other: Job) = other in getCancellationException()
361 public fun Job(parent: Job? = null): CompletableJob = JobImpl(parent) in getCancellationException() method
367 public fun Job0(parent: Job? = null): Job = Job(parent) in getCancellationException()
401 public interface ChildJob : Job {
420 public interface ParentJob : Job { in parentCancelled()
464 internal fun Job.disposeOnCompletion(handle: DisposableHandle): DisposableHandle = in childCancelled()
481 public suspend fun Job.cancelAndJoin() { in childCancelled()
[all …]
|
| D | Supervisor.kt | 32 public fun SupervisorJob(parent: Job? = null) : CompletableJob = SupervisorJobImpl(parent) in <lambda>()
38 public fun SupervisorJob0(parent: Job? = null) : Job = SupervisorJob(parent) in <lambda>()
56 private class SupervisorJobImpl(parent: Job?) : JobImpl(parent) {
|
| D | CoroutineScope.kt | 110 get() = coroutineContext[Job]?.isActive ?: true in plus()
192 ContextScope(if (context[Job] != null) context else context + Job()) in CoroutineScope()
201 …val job = coroutineContext[Job] ?: error("Scope cannot be cancelled because it does not have a job… in CoroutineScope()
|
| D | Await.kt | 48 public suspend fun joinAll(vararg jobs: Job): Unit = jobs.forEach { it.join() } in <lambda>()
57 public suspend fun Collection<Job>.joinAll(): Unit = forEach { it.join() } in <lambda>()
94 …AllNode(private val continuation: CancellableContinuation<List<T>>, job: Job) : JobNode<Job>(job) { in toString()
|
| D | NonCancellable.kt | 22 public object NonCancellable : AbstractCoroutineContextElement(Job), Job {
109 override val children: Sequence<Job> in cancel()
|
| D | JobSupport.kt | 27 public open class JobSupport constructor(active: Boolean) : Job, ChildJob, ParentJob, SelectClause0… in <lambda>()
28 final override val key: CoroutineContext.Key<*> get() = Job in <lambda>()
140 internal fun initParentJobInternal(parent: Job?) { in <lambda>()
895 public final override val children: Sequence<Job> get() = sequence { in <lambda>()
1089 ) : JobNode<Job>(child.childJob) { in <lambda>()
1101 override fun getContinuationCancellationCause(parent: Job): Throwable { in <lambda>()
1246 internal open class JobImpl(parent: Job?) : JobSupport(true), CompletableJob {
1281 internal abstract class JobNode<out J : Job>(
1317 job: Job, in toString()
1319 ) : JobNode<Job>(job) { in toString()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | JobExceptionHandlingTest.kt | 24 val job = Job() in <lambda>()
40 val parent = Job() in <lambda>()
61 val parent = Job() in <lambda>()
85 val job = Job() in <lambda>()
109 val job = Job() in <lambda>()
145 val job = Job() in <lambda>()
173 val job = Job() in <lambda>()
209 val job = Job() in <lambda>()
251 val job = Job() in <lambda>()
281 val job = Job() in <lambda>()
[all …]
|
| D | ProduceExceptionsTest.kt | 17 val producer = produce<Int>(Job()) { in <lambda>()
37 val produce = produce<Int>(Job()) { in <lambda>()
123 val job = Job() in <lambda>()
147 val job = Job() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | JobTest.kt | 14 val job = Job() in <lambda>()
22 val job = Job() in <lambda>()
39 val job = Job() in <lambda>()
57 val job = Job() in <lambda>()
81 val job = Job() in <lambda>()
96 val job = Job() in <lambda>()
114 val parent = Job() in <lambda>()
117 val child = Job(parent) in <lambda>()
123 val job = Job() in <lambda>()
133 val job = Job() in <lambda>()
[all …]
|
| D | WithContextTest.kt | 86 val job = Job() in <lambda>()
117 val job = Job() in <lambda>()
139 val job = Job() in <lambda>()
149 var job: Job? = null in <lambda>()
174 var job: Job? = null in <lambda>()
203 var job: Job? = null in <lambda>()
204 job = launch(Job()) { in <lambda>()
232 var job: Job? = null in <lambda>()
233 job = launch(Job()) { in <lambda>()
314 lateinit var ctxJob: Job in <lambda>()
[all …]
|
| D | ExperimentalDispatchModeTest.kt | 12 val parent = Job() in <lambda>()
26 val parent = Job() in <lambda>()
43 val parent = Job() in <lambda>()
60 val parent = Job() in <lambda>()
76 val parent = Job() in <lambda>()
92 val parent = Job() in <lambda>()
|
| D | CompletableJobTest.kt | 12 val job = Job() in testComplete()
24 val job = Job() in testCompleteWithException()
37 val parent = Job() in testCompleteWithChildren()
38 val child = Job(parent) in testCompleteWithChildren()
|
| D | EnsureActiveTest.kt | 11 private val job = Job() in <lambda>()
20 coroutineContext[Job]!!.ensureActive() in <lambda>()
39 coroutineContext[Job]!!.ensureActive() in <lambda>()
59 coroutineContext[Job]!!.ensureActive() in <lambda>()
|
| /external/v8/src/compiler-dispatcher/ |
| D | compiler-dispatcher.h | 119 struct Job { struct
120 explicit Job(BackgroundCompileTask* task_arg);
121 ~Job();
138 using JobMap = std::map<JobId, std::unique_ptr<Job>>; argument
141 void WaitForJobIfRunningOnBackground(Job* job);
148 JobMap::const_iterator InsertJob(std::unique_ptr<Job> job);
185 std::unordered_set<Job*> pending_background_jobs_;
188 std::unordered_set<Job*> running_background_jobs_;
192 Job* main_thread_blocking_on_job_;
|
| D | compiler-dispatcher.cc | 22 CompilerDispatcher::Job::Job(BackgroundCompileTask* task_arg) in Job() function in v8::internal::CompilerDispatcher::Job
25 CompilerDispatcher::Job::~Job() = default;
67 std::unique_ptr<Job> job = std::make_unique<Job>(new BackgroundCompileTask( in Enqueue()
116 Job* job = job_it->second.get(); in RegisterSharedFunctionInfo()
129 void CompilerDispatcher::WaitForJobIfRunningOnBackground(Job* job) { in WaitForJobIfRunningOnBackground()
162 Job* job = it->second.get(); in FinishNow()
185 Job* job = job_it->second.get(); in AbortJob()
258 Job* job = nullptr; in DoBackgroundWork()
339 Job* job = it->second.get(); in DoIdleWork()
356 std::unique_ptr<Job> job) { in InsertJob()
[all …]
|
| /external/autotest/frontend/afe/ |
| D | shard_heartbeat_unittest.py | 34 assigned = models.Job.assign_to_shard(shard, [])
45 assigned = models.Job.assign_to_shard(shard, [])
54 assigned_jobs = models.Job.assign_to_shard(shard, [known_job.id])
65 assigned = models.Job.assign_to_shard(shard, [])
75 assigned = models.Job.assign_to_shard(shard, [])
81 old = models.Job.SKIP_JOBS_CREATED_BEFORE
83 models.Job.SKIP_JOBS_CREATED_BEFORE = value
86 models.Job.SKIP_JOBS_CREATED_BEFORE = old
96 job = models.Job.objects.create(
115 job = models.Job.objects.create(
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | SafeCollector.kt | 40 if (key !== Job) { in <lambda>()
45 val collectJob = collectElement as Job? in <lambda>()
46 val emissionParentJob = (element as Job).transitiveCoroutineParent(collectJob) in <lambda>()
105 private tailrec fun Job?.transitiveCoroutineParent(collectJob: Job?): Job? { in <lambda>()
|
| /external/mksh/src/ |
| D | jobs.c | 89 typedef struct job Job; typedef
91 Job *next; /* next job in list */
128 static Job *job_list; /* job list */
129 static Job *last_job;
130 static Job *async_job;
152 static void j_set_async(Job *);
153 static void j_startjob(Job *);
154 static int j_waitj(Job *, int, const char *);
156 static void j_print(Job *, int, struct shf *);
157 static Job *j_lookup(const char *, int *);
[all …]
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-swing/test/ |
| D | SwingTest.kt | 40 fun testLaunch(): Job = launch { in <lambda>()
44 fun testFailure(): Job = launch { in <lambda>()
48 fun testCancellation() : Job = launch(start = CoroutineStart.ATOMIC) { in <lambda>()
61 component.coroutineContext[Job]!!.join() in <lambda>()
84 component.coroutineContext[Job]!!.join() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | FlowContextOptimizationsTest.kt | 27 assertEquals(collectContext.minusKey(Job), currentContext.minusKey(Job)) in <lambda>()
44 .flowOn(currentContext.minusKey(Job)) in <lambda>()
61 .flowOn(currentContext.minusKey(Job)) in <lambda>()
63 .flowOn(currentContext.minusKey(Job)) in <lambda>()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/test/future/ |
| D | AsFutureTest.kt | 30 val job = Job().apply { complete() } in <lambda>()
50 val job = Job() in testWaitForJobAsCompletableFuture()
75 val job = Job() in testJobAsCompletableFutureThrowable()
91 val job = Job() in testJobAsCompletableFutureCancellation()
106 val job = Job() in testJobCancellation()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/src/ |
| D | DebugProbes.kt | 75 public fun jobToString(job: Job): String = DebugProbesImpl.hierarchyToString(job)
82 jobToString(scope.coroutineContext[Job] ?: error("Job is not present in the scope"))
87 public fun printJob(job: Job, out: PrintStream = System.out): Unit =
95 printJob(scope.coroutineContext[Job] ?: error("Job is not present in the scope"), out)
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Future.kt | 22 public fun Job.cancelFutureOnCompletion(future: Future<*>): DisposableHandle = in cancelFutureOnCompletion()
36 job: Job, in cancelFutureOnCompletion()
38 ) : JobNode<Job>(job) { in cancelFutureOnCompletion()
|
| /external/perfetto/src/trace_processor/importers/ninja/ |
| D | ninja_log_parser.h | 56 struct Job { struct
57 Job(uint32_t b, int64_t s, int64_t e, uint64_t h, const std::string& n) in Job() argument
74 std::vector<Job> jobs_; argument
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/src/ |
| D | TestBuilders.kt | 63 private fun CoroutineContext.activeJobs(): Set<Job> { in activeJobs()
64 return checkNotNull(this[Job]).children.filter { it.isActive }.toSet() in activeJobs()
94 val job = get(Job) ?: SupervisorJob() in runBlockingTest()
|