Home
last modified time | relevance | path

Searched refs:executor_ (Results 1 – 24 of 24) sorted by relevance

/external/tensorflow/tensorflow/stream_executor/tpu/
Dtpu_executor.cc36 tpu::ExecutorApiFn()->TpuExecutor_FreeFn(executor_); in ~TpuExecutor()
45 tpu::ExecutorApiFn()->TpuExecutor_InitFn(executor_, device_ordinal, options, in Init()
52 return tpu::ExecutorApiFn()->TpuExecutor_PlatformDeviceCountFn(executor_); in PlatformDeviceCount()
56 tpu::ExecutorApiFn()->TpuExecutor_SyncAndForgetFailedStreamsFn(executor_); in SyncAndForgetFailedStreams()
60 return tpu::ExecutorApiFn()->TpuExecutor_SynchronizeAllActivityFn(executor_); in SynchronizeAllActivity()
66 executor_, get_stream(stream->implementation()), status.c_status); in BlockHostUntilDone()
72 tpu::ExecutorApiFn()->TpuExecutor_BlockUntilDoneOrFailedFn(executor_, in BlockUntilDoneOrFailed()
80 executor_, get_stream(stream->implementation()), status.c_status); in GetStatus()
86 tpu::ExecutorApiFn()->TpuExecutor_GetCoreLocationFn(executor_)); in GetCoreLocationExternal()
91 executor_, get_stream(stream->implementation())); in AllocateStream()
[all …]
Dtpu_executor.h62 : platform_(platform), executor_(executor) {} in TpuExecutor()
220 SE_StreamExecutor* se_executor() { return executor_; } in se_executor()
238 SE_StreamExecutor* executor_; variable
/external/tensorflow/tensorflow/core/common_runtime/eager/
Deager_op_rewrite_registry_test.cc25 : EagerOpRewrite(name, file, line), executor_(/*async=*/false) {} in TestEagerOpRewrite()
27 EagerExecutor executor_; member in tensorflow::TestEagerOpRewrite
34 TF_RETURN_IF_ERROR(op->Reset("NoOp", nullptr, false, &executor_)); in Run()
Dmkl_eager_op_rewrite_test.cc48 EagerExecutor executor_(false); in CreateOp() local
52 op.get()->Reset(op_name.c_str(), nullptr, false, &executor_)); in CreateOp()
Deager_operation.h184 EagerExecutor& Executor() { return *executor_; } in Executor()
254 EagerExecutor* executor_; // Not owned. variable
Deager_operation.cc346 executor_ = executor ? executor : &ctx_.Executor(); in Reset()
/external/tensorflow/tensorflow/compiler/xla/tests/
Dbuffer_donation_test.cc48 executor_ = backend_->default_stream_executor(); in BufferDonationTest()
49 TF_CHECK_OK(executor_->Init()); in BufferDonationTest()
56 se::StreamExecutor* executor_; member in xla::__anonf885129d0111::BufferDonationTest
70 std::move(hlo_module), executor_, in RunAndCheck()
76 backend_->compiler()->RunBackend(std::move(hlo_module), executor_, in RunAndCheck()
79 se::Stream stream(executor_); in RunAndCheck()
103 executor_->device_ordinal())); in RunAndCheck()
115 input_buffers.element(index), executor_->device_ordinal(), in RunAndCheck()
/external/tensorflow/tensorflow/compiler/xla/pjrt/
Dlocal_device_state.h96 se::StreamExecutor* executor() const { return executor_; } in executor()
98 int device_ordinal() const { return executor_->device_ordinal(); } in device_ordinal()
174 se::StreamExecutor* const executor_; variable
Dlocal_device_state.cc37 executor_(executor), in LocalDeviceState()
/external/tensorflow/tensorflow/stream_executor/
Dstream_executor_pimpl.h758 : executor_(executor), module_handle_(module_handle) {} in ScopedModuleHandle()
761 executor_ = other.executor_; in ScopedModuleHandle()
763 other.executor_ = nullptr; in ScopedModuleHandle()
768 executor_ = other.executor_;
770 other.executor_ = nullptr;
777 CHECK(executor_->UnloadModule(module_handle_)); in ~ScopedModuleHandle()
782 StreamExecutor *executor_;
/external/libchrome/base/
Ddeferred_sequenced_task_runner_unittest.cc29 : executor_(executor), in ExecuteTaskOnDestructor()
34 virtual ~ExecuteTaskOnDestructor() { executor_->ExecuteTask(task_id_); } in ~ExecuteTaskOnDestructor()
35 DeferredSequencedTaskRunnerTest* executor_; member in base::__anon03a06eda0111::DeferredSequencedTaskRunnerTest::ExecuteTaskOnDestructor
/external/tensorflow/tensorflow/lite/delegates/coreml/
Dcoreml_delegate_kernel.mm64 executor_ = [[::CoreMlExecutor alloc] init];
71 NSURL* model_url = [executor_ saveModel:model_.get()];
73 if (![executor_ build:model_url]) {
218 if (![executor_ invokeWithInputs:inputs_ outputs:outputs_]) {
232 CoreMlDelegateKernel::~CoreMlDelegateKernel() { [executor_ cleanup]; }
Dcoreml_delegate_kernel.h59 ::CoreMlExecutor* executor_;
/external/webrtc/test/pc/e2e/
Dpeer_connection_quality_test.cc114 executor_(std::make_unique<TestActivitiesExecutor>( in PeerConnectionE2EQualityTest()
139 executor_->ScheduleActivity(target_time_since_start, absl::nullopt, func); in ExecuteAt()
146 executor_->ScheduleActivity(initial_delay_since_start, interval, func); in ExecuteEvery()
309 executor_->ScheduleActivity(TimeDelta::Zero(), kStatsUpdateInterval, in Run()
334 executor_->Start(task_queue_.get()); in Run()
348 executor_->Stop(); in Run()
Dpeer_connection_quality_test.h116 std::unique_ptr<TestActivitiesExecutor> executor_; variable
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Dremote_copy_node.h165 EagerExecutor* const executor_; variable
Dremote_copy_node.cc82 executor_(executor), in RemoteCopyNode()
100 TF_RETURN_IF_ERROR(executor_->status()); in RunLocalSend()
190 TF_RETURN_IF_ERROR(executor_->status()); in RunLocalRecv()
/external/libtextclassifier/native/annotator/
Dmodel-executor.h104 std::unique_ptr<TfLiteModelExecutor> executor_; variable
Dmodel-executor.cc95 : executor_(std::move(executor)), in TFLiteEmbeddingExecutor()
/external/tensorflow/tensorflow/core/common_runtime/gpu/
Dgpu_device.h97 se::StreamExecutor* executor() const { return executor_; } in executor()
126 se::StreamExecutor* executor_; // not owned variable
Dgpu_device.cc417 TF_RETURN_IF_ERROR(executor_->SynchronousMemZero( in InitScratchBuffers()
432 executor_ = executor_status.ValueOrDie(); in Init()
435 tf_gpu_id_, 0, executor_, options.config.gpu_options()); in Init()
444 em_ = EventMgrFactory::Singleton()->GetEventMgr(executor_, in Init()
/external/tensorflow/tensorflow/c/eager/parallel_device/
Dparallel_device_lib.cc73 executor_(TFE_NewExecutor(is_async)), in DeviceThread()
140 ExecutorPtr executor_ TF_GUARDED_BY(execution_mutex_);
228 TFE_ContextSetExecutorForThread(context, executor_.get()); in Execute()
/external/tensorflow/tensorflow/core/platform/s3/
Ds3_file_system.h124 std::shared_ptr<Aws::Utils::Threading::PooledThreadExecutor> executor_; variable
Ds3_file_system.cc456 executor_(nullptr, ShutdownExecutor) { in S3FileSystem()
562 if (this->executor_.get() == nullptr) { in GetExecutor()
563 this->executor_ = in GetExecutor()
567 return this->executor_; in GetExecutor()