Home
last modified time | relevance | path

Searched defs:rendezvous (Results 1 – 21 of 21) sorted by relevance

/external/tensorflow/tensorflow/core/common_runtime/
Drendezvous_util.cc23 RendezvousInterface* rendezvous, DeviceContext* device_context, in SendTensorsToRendezvous()
57 RendezvousInterface* rendezvous, DeviceContext* device_context, in RecvOutputsFromRendezvousAsync()
121 Status RecvOutputsFromRendezvous(RendezvousInterface* rendezvous, in RecvOutputsFromRendezvous()
Dfunction.cc1038 RendezvousInterface* rendezvous = opts.rendezvous; in RunRemote() local
1137 auto* rendezvous = new RefCountedIntraProcessRendezvous(device_mgr_); in Run() local
1217 auto* rendezvous = new RefCountedIntraProcessRendezvous(device_mgr_); in Run() local
1311 std::unique_ptr<PrivateIntraProcessRendezvous> rendezvous; in RunSync() local
1330 std::unique_ptr<PrivateIntraProcessRendezvous> rendezvous; in RunSync() local
Dexecutor.h94 RendezvousInterface* rendezvous = nullptr; member
Dprocess_function_library_runtime.cc125 RendezvousInterface* rendezvous) { in SendTensors()
144 RendezvousInterface* rendezvous, std::vector<Tensor>* received_tensors, in ReceiveTensorsAsync()
1794 auto rendezvous = opts.rendezvous; in RunInternal() local
Ddirect_session.cc734 PrivateIntraProcessRendezvous rendezvous(device_mgr_.get()); in RunInternal() local
741 core::RefCountPtr<RefCountedIntraProcessRendezvous> rendezvous( in RunInternal() local
Dfunction_test.cc1943 PrivateIntraProcessRendezvous rendezvous(device_mgr_.get()); in TEST_F() local
/external/tensorflow/tensorflow/core/distributed_runtime/
Dgraph_mgr.cc357 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in SendInputs() local
376 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in RecvOutputs() local
395 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in RecvOutputsAsync() local
462 RemoteRendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in ExecuteAsync() local
517 const string& handle, int64_t step_id, Item* item, Rendezvous* rendezvous, in StartParallelExecutors()
/external/tensorflow/tensorflow/core/runtime_fallback/kernel/
Dkernel_fallback_compat_request_state.cc66 core::RefCountPtr<Rendezvous> rendezvous, OpKernelRunnerTable* runner_table, in KernelFallbackCompatRequestState()
Dkernel_fallback_compat_request_state.h129 RendezvousInterface* rendezvous() const { return rendezvous_.get(); } in rendezvous() function
/external/tensorflow/tensorflow/core/common_runtime/eager/
Dmkl_eager_op_rewrite_test.cc41 tensorflow::Rendezvous* rendezvous = in CreateOp() local
Dkernel_and_device.h201 tensorflow::Rendezvous* rendezvous, bool log_memory, in KernelAndDeviceOp()
Dkernel_and_device.cc385 Rendezvous* rendezvous = rendezvous_creator_(opts->step_id); in PrepareForRun() local
Dcontext.cc150 DeviceMgr* device_mgr, bool device_mgr_owned, Rendezvous* rendezvous, in EagerContext()
1215 IntraProcessRendezvous* rendezvous = in GetGlobalRendezvousForFunctionLocalRendezvousStatus() local
1226 IntraProcessRendezvous* rendezvous = in UpdateGlobalRendezvousDeviceManager() local
/external/autotest/client/common_lib/
Dbarrier.py494 def rendezvous(self, *hosts, **dargs): member in barrier
/external/tensorflow/tensorflow/lite/delegates/flex/
Ddelegate_data.cc223 tensorflow::Rendezvous* rendezvous = in Prepare() local
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Dremote_mgr_test.cc55 tensorflow::Rendezvous* rendezvous = in RemoteMgrTest() local
Deager_service_impl_test.cc1232 tensorflow::Rendezvous* rendezvous = in TEST_F() local
/external/tensorflow/tensorflow/compiler/xla/service/
Dcollective_ops_utils.h309 std::shared_ptr<Rendezvous<I, O>> rendezvous = rendezvous_getter(); in SubmitParticipant() local
/external/tensorflow/tensorflow/core/framework/
Dop_kernel.h621 RendezvousInterface* rendezvous = nullptr; member
1059 RendezvousInterface* rendezvous() const { return params_->rendezvous; } in rendezvous() function
Dfunction.h845 RendezvousInterface* rendezvous = nullptr; member
/external/cronet/base/metrics/
Dfield_trial.cc1148 auto* rendezvous = MachPortRendezvousClient::GetInstance(); in DeserializeSharedMemoryRegionMetadata() local