| /external/rust/crates/crossbeam-epoch/src/ |
| D | deferred.rs | 19 pub(crate) struct Deferred { struct
25 impl fmt::Debug for Deferred { argument
31 impl Deferred { implementation
56 Deferred { in new()
73 Deferred { in new()
94 use super::Deferred;
102 let d = Deferred::new(move || { in on_stack()
117 let d = Deferred::new(move || { in on_heap()
130 let d = Deferred::new(move || assert_eq!(a, "hello")); in string()
137 let d = Deferred::new(move || assert_eq!(*a, [2, 3, 5, 7])); in boxed_slice_i32()
[all …]
|
| D | internal.rs | 51 use crate::deferred::Deferred;
67 deferreds: [Deferred; MAX_OBJECTS],
93 pub(crate) unsafe fn try_push(&mut self, deferred: Deferred) -> Result<(), Deferred> { in try_push() argument
113 deferreds: [Deferred::NO_OP; MAX_OBJECTS], in default()
122 let no_op = Deferred::NO_OP; in drop()
361 pub(crate) unsafe fn defer(&self, mut deferred: Deferred, guard: &Guard) { in defer() argument
569 let d = Deferred::new(set); in check_defer()
586 assert!(unsafe { bag.try_push(Deferred::new(incr)).is_ok() }); in check_bag()
591 let result = unsafe { bag.try_push(Deferred::new(incr)) }; in check_bag()
|
| /external/perfetto/src/tracing/ipc/consumer/ |
| D | consumer_ipc_client_impl.cc | 89 ipc::Deferred<protos::gen::EnableTracingResponse> async_response; in EnableTracing()
110 ipc::Deferred<protos::gen::ChangeTraceConfigResponse> async_response; in ChangeTraceConfig()
127 ipc::Deferred<protos::gen::StartTracingResponse> async_response; in StartTracing()
143 ipc::Deferred<protos::gen::DisableTracingResponse> async_response; in DisableTracing()
159 ipc::Deferred<protos::gen::ReadBuffersResponse> async_response; in ReadBuffers()
215 ipc::Deferred<protos::gen::FreeBuffersResponse> async_response; in FreeBuffers()
232 ipc::Deferred<protos::gen::FlushResponse> async_response; in Flush()
248 ipc::Deferred<protos::gen::DetachResponse> async_response; in Detach()
268 ipc::Deferred<protos::gen::AttachResponse> async_response; in Attach()
285 ipc::Deferred<protos::gen::EnableTracingResponse> enable_resp; in Attach()
[all …]
|
| /external/perfetto/src/ipc/ |
| D | deferred_unittest.cc | 37 Deferred<TestMessage> deferred; in TEST()
64 Deferred<TestMessage> deferred; in TEST()
86 Deferred<TestMessage> deferred; in TEST()
100 Deferred<TestMessage> deferred; in TEST()
128 Deferred<TestMessage> deferred; in TEST()
150 Deferred<TestMessage> deferred_moved(std::move(deferred)); in TEST()
175 { Deferred<TestMessage> scoped_deferred(std::move(deferred)); } in TEST()
184 Deferred<TestMessage> deferred; in TEST()
207 Deferred<TestMessage> deferred_moved(std::move(deferred)); in TEST()
227 Deferred<TestMessage> deferred; in TEST()
[all …]
|
| /external/perfetto/include/perfetto/ext/ipc/ |
| D | deferred.h | 66 class Deferred; variable
74 explicit DeferredBase(Deferred<T> other) in DeferredBase()
87 friend class Deferred;
94 class Deferred : public DeferredBase {
96 explicit Deferred(std::function<void(AsyncResult<T>)> callback = nullptr) {
103 explicit Deferred(DeferredBase&& other) { in Deferred() function
|
| D | codegen_helpers.h | 45 void (TSvc::*Method)(const TReq&, ::perfetto::ipc::Deferred<TReply>)>
51 ::perfetto::ipc::Deferred<TReply>(::std::move(reply))); in _IPC_Invoker()
|
| /external/perfetto/ui/src/base/ |
| D | deferred_unittest.ts | 15 import {defer, Deferred} from './deferred';
18 const deferred: Deferred<void> = defer<void>();
30 const deferred: Deferred<string> = defer<string>();
36 const deferred: Deferred<string> = defer<string>();
|
| D | deferred.ts | 16 export interface Deferred<T> extends Promise<T> { interface
22 export function defer<T>(): Deferred<T> {
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | SanitizedProbesTest.kt | 119 private fun CoroutineScope.createActiveDeferred(): Deferred<*> = async { in <lambda>()
128 private fun CoroutineScope.createDeferred(): Deferred<*> = createDeferredNested() in createDeferred()
130 private fun CoroutineScope.createDeferredNested(): Deferred<*> = async(NonCancellable) { in createDeferred()
134 private suspend fun nestedMethod(deferred: Deferred<*>, traces: List<String>) { in nestedMethod()
139 private suspend fun oneMoreNestedMethod(deferred: Deferred<*>, traces: List<String>) { in oneMoreNestedMethod()
|
| D | DebugProbesTest.kt | 14 private fun CoroutineScope.createDeferred(): Deferred<*> = async(NonCancellable) { in createDeferred()
91 private suspend fun nestedMethod(deferred: Deferred<*>, traces: List<String>) { in nestedMethod()
96 private suspend fun oneMoreNestedMethod(deferred: Deferred<*>, traces: List<String>) { in oneMoreNestedMethod()
|
| D | Example.kt | 10 suspend fun combineResults(one: Deferred<String>, two: Deferred<String>): String = in combineResults()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-play-services/src/ |
| D | Tasks.kt | 19 public fun <T> Deferred<T>.asTask(): Task<T> { in <lambda>()
46 public fun <T> Task<T>.asDeferred(): Deferred<T> = asDeferredImpl(null) in asDeferred()
58 public fun <T> Task<T>.asDeferred(cancellationTokenSource: CancellationTokenSource): Deferred<T> = in asDeferred()
61 private fun <T> Task<T>.asDeferredImpl(cancellationTokenSource: CancellationTokenSource?): Deferred… in asDeferred()
94 return object : Deferred<T> by deferred {} in asDeferred()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryTest.kt | 24 fun createDeferred(depth: Int): Deferred<*> { in <lambda>()
71 private suspend fun nestedMethod(deferred: Deferred<*>, vararg traces: String) { in <lambda>()
76 private suspend fun oneMoreNestedMethod(deferred: Deferred<*>, vararg traces: String) { in <lambda>()
105 private suspend fun outerMethod(deferred: Deferred<*>, vararg traces: String) { in <lambda>()
113 private suspend fun innerMethod(deferred: Deferred<*>, vararg traces: String) { in <lambda>()
170 …private suspend fun outerScopedMethod(deferred: Deferred<*>, vararg traces: String) = coroutineSco… in <lambda>()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-play-services/test/ |
| D | TaskTest.kt | 78 val deferred: Deferred<Int> = Tasks.call { in <lambda>()
135 val deferred: Deferred<Int> = Tasks.call { in <lambda>()
251 val deferred: Deferred<Int> = Tasks.call { in <lambda>()
282 val deferred: Deferred<Int> = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
298 val deferred: Deferred<Int> = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
313 val deferred: Deferred<Int> = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
336 val deferred: Deferred<Int> = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
360 val deferred: Deferred<Int> = async(start = CoroutineStart.LAZY) { in <lambda>()
381 val deferred: Deferred<Int> = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>()
403 val deferred: Deferred<Int> = async(start = CoroutineStart.LAZY) { in <lambda>()
|
| /external/perfetto/src/tracing/ipc/producer/ |
| D | producer_ipc_client_impl.cc | 153 ipc::Deferred<protos::gen::InitializeConnectionResponse> on_init; in OnConnect()
197 ipc::Deferred<protos::gen::GetAsyncCommandResponse> on_cmd; in OnConnect()
386 ipc::Deferred<protos::gen::RegisterDataSourceResponse> async_response; in RegisterDataSource()
404 ipc::Deferred<protos::gen::UpdateDataSourceResponse> async_response; in UpdateDataSource()
423 req, ipc::Deferred<protos::gen::UnregisterDataSourceResponse>()); in UnregisterDataSource()
438 req, ipc::Deferred<protos::gen::RegisterTraceWriterResponse>()); in RegisterTraceWriter()
451 req, ipc::Deferred<protos::gen::UnregisterTraceWriterResponse>()); in UnregisterTraceWriter()
461 ipc::Deferred<protos::gen::CommitDataResponse> async_response; in CommitData()
487 req, ipc::Deferred<protos::gen::NotifyDataSourceStartedResponse>()); in NotifyDataSourceStarted()
500 req, ipc::Deferred<protos::gen::NotifyDataSourceStoppedResponse>()); in NotifyDataSourceStopped()
[all …]
|
| /external/cronet/third_party/boringssl/src/util/fipstools/acvp/acvptool/subprocess/ |
| D | kdf.go | 45 Deferred bool `json:"deferred"`
97 if test.Deferred {
116 if test.Deferred {
122 if !test.Deferred && !bytes.Equal(resp[0], key) {
|
| /external/boringssl/src/util/fipstools/acvp/acvptool/subprocess/ |
| D | kdf.go | 45 Deferred bool `json:"deferred"`
97 if test.Deferred {
116 if test.Deferred {
122 if !test.Deferred && !bytes.Equal(resp[0], key) {
|
| /external/perfetto/src/ipc/test/ |
| D | ipc_integrationtest.cc | 31 using ::perfetto::ipc::Deferred;
114 Deferred<GreeterReplyMsg> deferred_reply( in TEST_F()
124 Deferred<GreeterReplyMsg>* host_reply) { in TEST_F()
137 Deferred<GreeterReplyMsg> deferred_reply( in TEST_F()
147 Deferred<GreeterReplyMsg>* host_reply) { in TEST_F()
|
| /external/dagger2/javatests/dagger/functional/producers/monitoring/ |
| D | ThreadModule.java | 20 import dagger.functional.producers.monitoring.ThreadQualifiers.Deferred;
30 @Deferred
38 ListenableFuture<Object> required(@Deferred Producer<Object> o, ThreadAccumulator acc) { in required()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | LimitingCoroutineDispatcherStressTest.kt | 27 val tasks = ArrayList<Deferred<*>>(iterations * 2) in <lambda>()
38 val tasks = ArrayList<Deferred<*>>(iterations * 2) in <lambda>()
47 … private fun task(ctx: CoroutineContext, maxLimit: Int): Deferred<Unit> = GlobalScope.async(ctx) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-select-05.kt | 12 fun CoroutineScope.switchMapDeferreds(input: ReceiveChannel<Deferred<String>>) = produce<String> { in <lambda>()
15 … val next = select<Deferred<String>?> { // return next deferred value from this select or null in <lambda>()
39 val chan = Channel<Deferred<String>>() // the channel for test in <lambda>()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-play-services/api/ |
| D | kotlinx-coroutines-play-services.api | 2 …blic static final fun asDeferred (Lcom/google/android/gms/tasks/Task;)Lkotlinx/coroutines/Deferred;
3 …gms/tasks/Task;Lcom/google/android/gms/tasks/CancellationTokenSource;)Lkotlinx/coroutines/Deferred;
4 public static final fun asTask (Lkotlinx/coroutines/Deferred;)Lcom/google/android/gms/tasks/Task;
|
| /external/python/pyee/pyee/ |
| D | twisted.py | 5 from twisted.internet.defer import Deferred, ensureDeferred
67 d: Deferred[Any] = ensureDeferred(result)
68 elif isinstance(result, Deferred):
|
| /external/perfetto/ui/src/common/ |
| D | engine.ts | 15 import {defer, Deferred} from '../base/deferred';
84 private pendingParses = new Array<Deferred<void>>();
85 private pendingEOFs = new Array<Deferred<void>>();
86 private pendingResetTraceProcessors = new Array<Deferred<void>>();
88 private pendingRestoreTables = new Array<Deferred<void>>();
89 private pendingComputeMetrics = new Array<Deferred<ComputeMetricResult>>();
90 private pendingReadMetatrace?: Deferred<DisableAndReadMetatraceResult>;
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Await.kt | 24 public suspend fun <T> awaitAll(vararg deferreds: Deferred<T>): List<T> = in <lambda>()
41 public suspend fun <T> Collection<Deferred<T>>.awaitAll(): List<T> = in <lambda>()
68 private class AwaitAll<T>(private val deferreds: Array<out Deferred<T>>) {
|