Home
last modified time | relevance | path

Searched refs:newContext (Results 1 – 25 of 69) sorted by relevance

123

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/
DBuilders.common.kt52 val newContext = newCoroutineContext(context) in <lambda>() constant
54 LazyStandaloneCoroutine(newContext, block) else in <lambda>()
55 StandaloneCoroutine(newContext, active = true) in <lambda>()
87 val newContext = newCoroutineContext(context) in async() constant
89 LazyDeferredCoroutine(newContext, block) else in async()
90 DeferredCoroutine<T>(newContext, active = true) in async()
147 val newContext = oldContext + context in withContext() constant
149 newContext.checkCompletion() in withContext()
151 if (newContext === oldContext) { in withContext()
152 val coroutine = ScopeCoroutine(newContext, uCont) in withContext()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
DChannelFlow.kt76 val newContext = context + this.context in dropChannelOperators() constant
101 …if (newContext == this.context && newCapacity == this.capacity && newOverflow == this.onBufferOver… in dropChannelOperators()
103 return create(newContext, newCapacity, newOverflow) in dropChannelOperators()
161 …private suspend fun collectWithContextUndispatched(collector: FlowCollector<T>, newContext: Corout… in flowCollect()
164 …return withContextUndispatched(newContext, block = { flowCollect(it) }, value = originalContextCol… in flowCollect()
176 val newContext = collectContext + context // compute resulting collect context in collectTo() constant
178 if (newContext == collectContext) in collectTo()
181 if (newContext[ContinuationInterceptor] == collectContext[ContinuationInterceptor]) in collectTo()
182 return collectWithContextUndispatched(collector, newContext) in collectTo()
232 newContext: CoroutineContext, in emit()
[all …]
DFlowCoroutine.kt60 val newContext = newCoroutineContext(context) in flowProduce() constant
61 val coroutine = FlowProduceCoroutine(newContext, channel) in flowProduce()
/external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/
DBuilders.kt36 var newContext: CoroutineContext = context // todo: kludge for data flow analysis error in runBlocking() variable
40 newContext = GlobalScope.newCoroutineContext(context + eventLoop) in runBlocking()
46 newContext = GlobalScope.newCoroutineContext(context) in runBlocking()
48 val coroutine = BlockingCoroutine<T>(newContext, eventLoop) in runBlocking()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/
DBuilders.kt45 val newContext: CoroutineContext in runBlocking() constant
49 newContext = GlobalScope.newCoroutineContext(context + eventLoop) in runBlocking()
55 newContext = GlobalScope.newCoroutineContext(context) in runBlocking()
57 val coroutine = BlockingCoroutine<T>(newContext, currentThread, eventLoop) in runBlocking()
/external/angle/src/libANGLE/renderer/gl/egl/android/
DDisplayAndroid.cpp335 EGLContext newContext = EGL_NO_CONTEXT; in makeCurrent() local
339 newContext = contextEGL->getContext(); in makeCurrent()
350 currentContext.context = newContext; in makeCurrent()
360 ASSERT(currentContext.context == newContext); in makeCurrent()
362 ASSERT(newContext != EGL_NO_CONTEXT); in makeCurrent()
371 ASSERT(newContext == EGL_NO_CONTEXT); in makeCurrent()
384 if (mVirtualizedContexts && newContext != EGL_NO_CONTEXT) in makeCurrent()
386 ASSERT(currentContext.context == EGL_NO_CONTEXT || newContext == currentContext.context); in makeCurrent()
388 newContext = mRenderer->getContext(); in makeCurrent()
407 if (newSurface != currentContext.surface || newContext != currentContext.context) in makeCurrent()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/
DActor.kt116 val newContext = newCoroutineContext(context) in actor() constant
119 LazyActorCoroutine(newContext, channel, block) else in actor()
120 ActorCoroutine(newContext, channel, active = true) in actor()
/external/conscrypt/openjdk/src/test/java/org/conscrypt/
DClientSessionContextTest.java33 ClientSessionContext newContext() { in newContext() method in ClientSessionContextTest
58 ClientSessionContext context = newContext(); in testNoMixingOfSingleAndMultiUseSessions()
96 ClientSessionContext context = newContext(); in testCanRetrieveMultipleSingleUseSessions()
/external/conscrypt/repackaged/openjdk/src/test/java/com/android/org/conscrypt/
DClientSessionContextTest.java37 ClientSessionContext newContext() { in newContext() method in ClientSessionContextTest
62 ClientSessionContext context = newContext(); in testNoMixingOfSingleAndMultiUseSessions()
100 ClientSessionContext context = newContext(); in testCanRetrieveMultipleSingleUseSessions()
/external/conscrypt/benchmark-jmh/src/jmh/java/org/conscrypt/
DOpenJdkEngineFactory.java55 private final SSLContext clientContext = initClientSslContext(newContext());
56 private final SSLContext serverContext = initServerSslContext(newContext());
74 private SSLContext newContext() { in newContext() method
104 private SSLContext newContext() { in newContext() method
137 private SSLContext newContext() { in newContext() method
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DBroadcast.kt116 val newContext = newCoroutineContext(context) in broadcast() constant
119 LazyBroadcastCoroutine(newContext, channel, block) else in broadcast()
120 BroadcastCoroutine(newContext, channel, active = true) in broadcast()
DProduce.kt133 val newContext = newCoroutineContext(context) in produce() constant
134 val coroutine = ProducerCoroutine(newContext, channel) in produce()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/
DRxCompletable.kt33 val newContext = scope.newCoroutineContext(context) in rxCompletableInternal() constant
34 val coroutine = RxCompletableCoroutine(newContext, subscriber) in rxCompletableInternal()
DRxMaybe.kt34 val newContext = scope.newCoroutineContext(context) in rxMaybeInternal() constant
35 val coroutine = RxMaybeCoroutine(newContext, subscriber) in rxMaybeInternal()
DRxSingle.kt33 val newContext = scope.newCoroutineContext(context) in rxSingleInternal() constant
34 val coroutine = RxSingleCoroutine(newContext, subscriber) in rxSingleInternal()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxCompletable.kt47 val newContext = scope.newCoroutineContext(context) in rxCompletable() constant
48 val coroutine = RxCompletableCoroutine(newContext, subscriber) in rxCompletable()
DRxMaybe.kt48 val newContext = scope.newCoroutineContext(context) in rxMaybe() constant
49 val coroutine = RxMaybeCoroutine(newContext, subscriber) in rxMaybe()
DRxSingle.kt47 val newContext = scope.newCoroutineContext(context) in rxSingle() constant
48 val coroutine = RxSingleCoroutine(newContext, subscriber) in rxSingle()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/
DMono.kt52 val newContext = scope.newCoroutineContext(context + reactorContext) in mono() constant
53 val coroutine = MonoCoroutine(newContext, sink) in mono()
DFlux.kt68 val newContext = scope.newCoroutineContext(context + reactorContext) in flux() constant
69 val coroutine = PublisherCoroutine(newContext, subscriber, REACTOR_HANDLER) in flux()
/external/icu/icu4j/main/classes/charset/src/com/ibm/icu/charset/
DCharsetEncoderICU.java182 …al void setFromUCallback(CoderResult err, CharsetCallback.Encoder newCallback, Object newContext) { in setFromUCallback() argument
191 if (fromUContext == null || !fromUContext.equals(newContext)) { in setFromUCallback()
192 setFromUContext(newContext); in setFromUCallback()
203 public final void setFromUContext(Object newContext) { in setFromUContext() argument
204 fromUContext = newContext; in setFromUContext()
/external/escapevelocity/src/main/java/com/google/escapevelocity/
DMacro.java63 EvaluationContext newContext = new MacroEvaluationContext(parameterThunks, context); in evaluate() local
64 return body.evaluate(newContext); in evaluate()
/external/icu/icu4c/source/test/cintltst/
Dtracetst.c234 const void *newContext = (const char *)originalTContext + 1; in TestTraceAPI() local
240 utrace_setFunctions(newContext, testTraceEntry, testTraceExit, testTraceData); in TestTraceAPI()
245 TEST_ASSERT(context == newContext); in TestTraceAPI()
/external/icu/libandroidicu/static_shim/
Dshim.cpp217 …llback_android(UBiDi * pBiDi, UBiDiClassCallback * newFn, const void * newContext, UBiDiClassCallb… in ubidi_setClassCallback_android() argument
218 ubidi_setClassCallback(pBiDi, newFn, newContext, oldFn, oldContext, pErrorCode); in ubidi_setClassCallback_android()
268 …Converter * converter, UConverterFromUCallback newAction, const void * newContext, UConverterFromU… in ucnv_setFromUCallBack_android() argument
269 ucnv_setFromUCallBack(converter, newAction, newContext, oldAction, oldContext, err); in ucnv_setFromUCallBack_android()
271 …(UConverter * converter, UConverterToUCallback newAction, const void * newContext, UConverterToUCa… in ucnv_setToUCallBack_android() argument
272 ucnv_setToUCallBack(converter, newAction, newContext, oldAction, oldContext, err); in ucnv_setToUCallBack_android()
/external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/src/future/
DFuture.kt40 val newContext = this.newCoroutineContext(context) in <lambda>() constant
42 val coroutine = CompletableFutureCoroutine(newContext, future) in <lambda>()

123