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.h91 RendezvousInterface* rendezvous = nullptr; member
Dprocess_function_library_runtime.cc126 RendezvousInterface* rendezvous) { in SendTensors()
145 RendezvousInterface* rendezvous, std::vector<Tensor>* received_tensors, in ReceiveTensorsAsync()
1301 auto rendezvous = opts.rendezvous; in RunInternal() local
Dfunction.cc1021 RendezvousInterface* rendezvous = opts.rendezvous; in RunRemote() local
1120 auto* rendezvous = new PrivateIntraProcessRendezvous(device_mgr_); in Run() local
1191 auto* rendezvous = new PrivateIntraProcessRendezvous(device_mgr_); in Run() local
Ddirect_session.cc704 PrivateIntraProcessRendezvous rendezvous(device_mgr_.get()); in RunInternal() local
711 core::RefCountPtr<RefCountedIntraProcessRendezvous> rendezvous( in RunInternal() local
Dfunction_test.cc1856 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.cc346 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in SendInputs() local
365 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in RecvOutputs() local
384 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in RecvOutputsAsync() local
446 RemoteRendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in ExecuteAsync() local
498 const string& handle, int64 step_id, Item* item, Rendezvous* rendezvous, in StartParallelExecutors()
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Dremote_mgr_test.cc53 tensorflow::Rendezvous* rendezvous = in RemoteMgrTest() local
Deager_service_impl_test.cc709 tensorflow::Rendezvous* rendezvous = in TEST_F() local
/external/tensorflow/tensorflow/core/common_runtime/eager/
Dmkl_eager_op_rewrite_test.cc37 tensorflow::Rendezvous* rendezvous = in CreateOp() local
Dkernel_and_device.cc335 Rendezvous* rendezvous = rendezvous_creator_(opts->step_id); in Run() local
Dcontext.cc77 bool device_mgr_owned, Rendezvous* rendezvous, in EagerContext()
/external/autotest/client/common_lib/
Dbarrier.py494 def rendezvous(self, *hosts, **dargs): member in barrier
/external/tensorflow/tensorflow/c/experimental/
Drendezvous_internal.h117 auto* rendezvous = new CRemoteRendezvous( in Create() local
/external/tensorflow/tensorflow/compiler/xla/service/
Dcollective_ops_utils.h197 std::shared_ptr<Rendezvous<O>> rendezvous = rendezvous_getter(); in SubmitParticipant() local
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
Dcollective_permute_thunk.cc236 std::shared_ptr<Rendezvous> rendezvous = GlobalRendezvousMap()[key]; in ExecuteOnStream() local
/external/tensorflow/tensorflow/core/framework/
Dfunction.h690 RendezvousInterface* rendezvous = nullptr; member
Dop_kernel.h679 RendezvousInterface* rendezvous = nullptr; member
1109 RendezvousInterface* rendezvous() const { return params_->rendezvous; } in rendezvous() function