Home
last modified time | relevance | path

Searched defs:rendezvous (Results 1 – 19 of 19) 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()
Dexecutor.h97 RendezvousInterface* rendezvous = nullptr; member
Dfunction.cc1003 RendezvousInterface* rendezvous = opts.rendezvous; in RunRemote() local
1102 auto* rendezvous = new PrivateIntraProcessRendezvous(device_mgr_); in Run() local
1181 auto* rendezvous = new PrivateIntraProcessRendezvous(device_mgr_); in Run() local
1274 std::unique_ptr<PrivateIntraProcessRendezvous> rendezvous; in RunSync() local
1293 std::unique_ptr<PrivateIntraProcessRendezvous> rendezvous; in RunSync() local
Dprocess_function_library_runtime.cc122 RendezvousInterface* rendezvous) { in SendTensors()
141 RendezvousInterface* rendezvous, std::vector<Tensor>* received_tensors, in ReceiveTensorsAsync()
1504 auto rendezvous = opts.rendezvous; in RunInternal() local
Ddirect_session.cc718 PrivateIntraProcessRendezvous rendezvous(device_mgr_.get()); in RunInternal() local
725 core::RefCountPtr<RefCountedIntraProcessRendezvous> rendezvous( in RunInternal() local
Dfunction_test.cc1983 PrivateIntraProcessRendezvous rendezvous(device_mgr_.get()); in TEST_F() local
/external/tensorflow/tensorflow/lite/delegates/flex/
Ddelegate_data.cc44 tensorflow::Rendezvous* rendezvous = in Prepare() local
/external/tensorflow/tensorflow/core/distributed_runtime/
Dgraph_mgr.cc353 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in SendInputs() local
372 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in RecvOutputs() local
391 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in RecvOutputsAsync() local
458 RemoteRendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in ExecuteAsync() local
512 const string& handle, int64 step_id, Item* item, Rendezvous* rendezvous, in StartParallelExecutors()
/external/tensorflow/tensorflow/core/common_runtime/eager/
Dmkl_eager_op_rewrite_test.cc41 tensorflow::Rendezvous* rendezvous = in CreateOp() local
Dkernel_and_device.cc369 Rendezvous* rendezvous = rendezvous_creator_(opts->step_id); in RunAsync() local
Dkernel_and_device.h193 tensorflow::Rendezvous* rendezvous, bool log_memory, in KernelAndDeviceOp()
Dcontext.cc79 const DeviceMgr* device_mgr, bool device_mgr_owned, Rendezvous* rendezvous, in EagerContext()
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Dremote_mgr_test.cc52 tensorflow::Rendezvous* rendezvous = in RemoteMgrTest() local
Deager_service_impl_test.cc1214 tensorflow::Rendezvous* rendezvous = in TEST_F() local
/external/autotest/client/common_lib/
Dbarrier.py494 def rendezvous(self, *hosts, **dargs): member in barrier
/external/tensorflow/tensorflow/compiler/xla/service/
Dcollective_ops_utils.h219 std::shared_ptr<Rendezvous<I, O>> rendezvous = rendezvous_getter(); in SubmitParticipant() local
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
Dcollective_permute_thunk.cc240 std::shared_ptr<Rendezvous> rendezvous = in ExecuteOnStream() local
/external/tensorflow/tensorflow/core/framework/
Dop_kernel.h648 RendezvousInterface* rendezvous = nullptr; member
1103 RendezvousInterface* rendezvous() const { return params_->rendezvous; } in rendezvous() function
Dfunction.h789 RendezvousInterface* rendezvous = nullptr; member