| /external/autotest/client/common_lib/ |
| H A D | barrier.py | 113 In addition, there is another rendezvous, that makes each slave a server
123 b.rendezvous(CLIENT, SERVER)
129 b.rendezvous(CLIENT, SERVER)
135 abort=True in the rendezvous arguments.
494 def rendezvous(self, *hosts, **dargs): member in class:barrier
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| H A D | rendezvous_util.cc | 20 Rendezvous* rendezvous, DeviceContext* device_context,
35 if (!rendezvous) {
48 rendezvous->Send(parsed, rendez_args, tensors_to_send[i], false));
54 Rendezvous* rendezvous, DeviceContext* device_context,
103 rendezvous->RecvAsync(
133 Status RecvOutputsFromRendezvous(Rendezvous* rendezvous, NamedTensors* out, argument
142 TF_RETURN_IF_ERROR(rendezvous->Recv(parsed, args, val, &is_dead));
19 SendTensorsToRendezvous( Rendezvous* rendezvous, DeviceContext* device_context, const std::vector<AllocatorAttributes>& alloc_attrs, const std::vector<string>& keys, gtl::ArraySlice<Tensor> tensors_to_send) argument
53 RecvOutputsFromRendezvousAsync( Rendezvous* rendezvous, DeviceContext* device_context, const std::vector<AllocatorAttributes>& alloc_attrs, const std::vector<string>& keys, std::vector<Tensor>* received_tensors, const StatusCallback& done) argument
|
| H A D | executor.h | 20 #include "tensorflow/core/framework/rendezvous.h"
39 // Rendezvous* rendezvous = NewNaiveRendezvous();
40 // TF_CHECK_OK(rendezvous->Send("input", some_input_tensor));
41 // TF_CHECK_OK(executor->Run({ExecutorOpts, rendezvous, nullptr}));
42 // TF_CHECK_OK(rendezvous->Recv("output", &output_tensor));
55 // ensure objects passed in Args (rendezvous, stats_collector, etc.)
64 // RunAsync() uses the given "rendezvous", if not null, as the
85 Rendezvous* rendezvous = nullptr; member in struct:tensorflow::Executor::Args
161 // rendezvous object will be aborted exactly once.
|
| H A D | process_function_library_runtime.cc | 79 Rendezvous* rendezvous) {
88 rendezvous, device_context, alloc_attrs, keys, tensors_to_send));
97 const std::vector<AllocatorAttributes>& alloc_attrs, Rendezvous* rendezvous,
107 rendezvous, device_context, alloc_attrs, keys, received_tensors,
284 auto rendezvous = opts.rendezvous; local
302 device_context, opts.args_alloc_attrs, rendezvous);
311 [source_device, target_device, target_incarnation, rendezvous,
324 device_context, rets_alloc_attrs, rendezvous,
74 SendTensors( const string& source_device, const string& target_device, const string& key_prefix, int64 src_incarnation, gtl::ArraySlice<Tensor> tensors_to_send, DeviceContext* device_context, const std::vector<AllocatorAttributes>& alloc_attrs, Rendezvous* rendezvous) argument
93 ReceiveTensorsAsync( const string& source_device, const string& target_device, const string& key_prefix, int64 src_incarnation, int64 num_tensors, DeviceContext* device_context, const std::vector<AllocatorAttributes>& alloc_attrs, Rendezvous* rendezvous, std::vector<Tensor>* received_tensors, const StatusCallback& done) argument
|
| H A D | function.cc | 299 opts.rendezvous = ctx->rendezvous();
675 Rendezvous* rendezvous = opts.rendezvous; local
710 device_context, {}, rendezvous, remote_args,
712 target_incarnation, rendezvous, device_context, rets, done,
727 target_incarnation, rendezvous, device_context,
742 *rets, device_context, {}, rendezvous);
760 Rendezvous* rendezvous = new IntraProcessRendezvous(device_mgr_); local
761 run_opts.rendezvous
840 Rendezvous* rendezvous = new IntraProcessRendezvous(device_mgr_); local
[all...] |
| /external/tensorflow/tensorflow/c/eager/ |
| H A D | c_api_internal.h | 33 #include "tensorflow/core/framework/rendezvous.h"
50 rendezvous(new tensorflow::IntraProcessRendezvous(s->device_mgr)),
65 tensorflow::Rendezvous* const rendezvous; member in class:TFE_Context::tensorflow
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| H A D | graph_mgr.cc | 336 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); local
346 SendTensorsToRendezvous(rendezvous, nullptr, {}, keys, tensors_to_send);
347 rendezvous->Unref();
352 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); local
353 Status s = RecvOutputsFromRendezvous(rendezvous, out, Rendezvous::Args());
354 rendezvous->Unref();
360 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); local
370 rendezvous, nullptr, {}, keys, received_keys,
371 [done, rendezvous, received_keys, out, keys](const Status s) {
372 rendezvous
415 RemoteRendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); local
447 StartParallelExecutors(const string& handle, int64 step_id, Item* item, Rendezvous* rendezvous, StepStatsCollector* collector, CostGraphDef* cost_graph, CancellationManager* cancellation_manager, StatusCallback done) argument
[all...] |
| /external/tensorflow/tensorflow/core/framework/ |
| H A D | function.h | 478 Rendezvous* rendezvous = nullptr; member in struct:tensorflow::FunctionLibraryRuntime::Options
|
| H A D | op_kernel.h | 30 #include "tensorflow/core/framework/rendezvous.h"
533 Rendezvous* rendezvous = nullptr; member in struct:tensorflow::OpKernelContext::Params
935 Rendezvous* rendezvous() const { return params_->rendezvous; } function in class:tensorflow::OpKernelContext
|