/external/chromium-trace/catapult/devil/devil/utils/ |
D | reraiser_thread_unittest.py | 104 results = reraiser_thread.RunAsync([]) 108 results = reraiser_thread.RunAsync([lambda: 1]) 112 a, b = reraiser_thread.RunAsync((lambda: 1, lambda: 2))
|
D | timeout_retry_unittest.py | 73 return reraiser_thread.RunAsync((InnerInnerFunc,))[0]
|
D | reraiser_thread.py | 219 def RunAsync(funcs, watcher=None): function
|
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
D | QpsWorker.cs | 60 workerServer.RunAsync().Wait(); in Run() 64 private async Task RunAsync() in RunAsync() method in Grpc.IntegrationTesting.QpsWorker
|
/external/tensorflow/tensorflow/core/common_runtime/ |
D | executor.h | 105 virtual void RunAsync(const Args& args, DoneCallback done) = 0; 111 RunAsync(args, [&ret, &n](const Status& s) { in Run()
|
D | executor.cc | 315 void RunAsync(const Args& args, DoneCallback done) override; 856 void RunAsync(Executor::DoneCallback done); 1507 void ExecutorState::RunAsync(Executor::DoneCallback done) { in RunAsync() function in tensorflow::__anon675242740111::ExecutorState 2852 void ExecutorImpl::RunAsync(const Args& args, DoneCallback done) { in RunAsync() function in tensorflow::__anon675242740111::ExecutorImpl 2853 (new ExecutorState(args, this))->RunAsync(std::move(done)); in RunAsync()
|
D | function.cc | 1019 item->exec->RunAsync( in RunRemote() 1101 item->exec->RunAsync( in Run() 1156 item->exec->RunAsync(exec_args, std::move(done)); in Run()
|
D | direct_session.cc | 654 item.executor->RunAsync(args, barrier->Get()); in RunInternal() 906 item.executor->RunAsync(args, barrier->Get()); in PRunSetup()
|
/external/chromium-trace/catapult/devil/devil/android/ |
D | crash_handler_devicetest.py | 67 reraiser_thread.RunAsync([crasher, victim]))
|
D | device_utils.py | 1571 host_checksums, device_checksums = reraiser_thread.RunAsync(( 1674 host_checksums, device_checksums = reraiser_thread.RunAsync((
|
/external/tensorflow/tensorflow/core/kernels/data/ |
D | captured_function.h | 79 void RunAsync(IteratorContext* ctx, std::vector<Tensor>&& args,
|
D | parallel_map_dataset_op.cc | 255 instantiated_captured_func_->RunAsync( in MapFunc()
|
D | single_threaded_executor.cc | 160 void RunAsync(const Args& args, DoneCallback done) override { in RunAsync() function in tensorflow::data::__anon94ff5ae60111::SingleThreadedExecutorImpl
|
D | captured_function.cc | 409 void InstantiatedCapturedFunction::RunAsync( in RunAsync() function in tensorflow::data::InstantiatedCapturedFunction
|
/external/tensorflow/tensorflow/core/distributed_runtime/ |
D | graph_mgr.cc | 516 unit.root->RunAsync(args, barrier->Get()); in StartParallelExecutors()
|
/external/tensorflow/tensorflow/core/kernels/data/experimental/ |
D | map_and_batch_dataset_op.cc | 100 instantiated_captured_func->RunAsync( in MakeDataset()
|