| /external/autotest/server/tests/barriertest_2client/ |
| D | control.srv | 30 logging.info('rendezvous-ing')
31 barrier.rendezvous(master_hostname, client_hostname)
36 logging.info('rendezvous-ing')
37 barrier.rendezvous(master_hostname + '#id0',
44 logging.info('rendezvous-ing')
45 barrier.rendezvous(socket.gethostbyname(master_hostname),
52 logging.info('rendezvous-ing')
53 barrier.rendezvous(socket.gethostbyname(master_hostname) + '#42',
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | graph_mgr.cc | 353 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in SendInputs() local
366 SendTensorsToRendezvous(rendezvous, nullptr, {}, keys, tensors_to_send); in SendInputs()
367 rendezvous->Unref(); in SendInputs()
372 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in RecvOutputs() local
373 Status s = RecvOutputsFromRendezvous(rendezvous, out, Rendezvous::Args()); in RecvOutputs()
374 rendezvous->Unref(); in RecvOutputs()
391 Rendezvous* rendezvous = worker_env_->rendezvous_mgr->Find(step_id); in RecvOutputsAsync() local
401 rendezvous, nullptr, {}, keys, received_keys, in RecvOutputsAsync()
402 [done, rendezvous, received_keys, out, keys](const Status s) { in RecvOutputsAsync()
403 rendezvous->Unref(); in RecvOutputsAsync()
[all …]
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | rendezvous_util.cc | 23 RendezvousInterface* rendezvous, DeviceContext* device_context, in SendTensorsToRendezvous() argument
38 if (!rendezvous) { in SendTensorsToRendezvous()
51 rendezvous->Send(parsed, rendez_args, tensors_to_send[i], false)); in SendTensorsToRendezvous()
57 RendezvousInterface* rendezvous, DeviceContext* device_context, in RecvOutputsFromRendezvousAsync() argument
100 rendezvous->RecvAsync( in RecvOutputsFromRendezvousAsync()
121 Status RecvOutputsFromRendezvous(RendezvousInterface* rendezvous, in RecvOutputsFromRendezvous() argument
131 TF_RETURN_IF_ERROR(rendezvous->Recv(parsed, args, val, &is_dead)); in RecvOutputsFromRendezvous()
|
| D | rendezvous_util.h | 34 RendezvousInterface* rendezvous, DeviceContext* device_context,
43 RendezvousInterface* rendezvous, DeviceContext* device_context,
48 Status RecvOutputsFromRendezvous(RendezvousInterface* rendezvous,
|
| D | function.cc | 529 opts.rendezvous = ctx->rendezvous(); in ComputeAsync()
983 exec_args->rendezvous = run_opts.rendezvous; in ExecutorArgsFromOptions()
1003 RendezvousInterface* rendezvous = opts.rendezvous; in RunRemote() local
1052 device_context, args_alloc_attrs, rendezvous, remote_args, in RunRemote()
1054 target_incarnation, rendezvous, device_context, rets, done, exec_args, in RunRemote()
1070 target_incarnation, rendezvous, device_context, remote_args, in RunRemote()
1084 *rets, device_context, rets_alloc_attrs, rendezvous); in RunRemote()
1102 auto* rendezvous = new PrivateIntraProcessRendezvous(device_mgr_); in Run() local
1103 run_opts.rendezvous = rendezvous; in Run()
1105 done = [done = std::move(done), rendezvous](const Status& status) mutable { in Run()
[all …]
|
| D | kernel_benchmark_testlib.cc | 117 args.rendezvous = rendez_; in Benchmark()
174 args.rendezvous = rendez_; in RunWithRendezvousArgs()
226 args.rendezvous = rendez_; in RunWithRendezvousArgs()
|
| D | process_function_library_runtime.cc | 122 RendezvousInterface* rendezvous) { in SendTensors() argument
131 rendezvous, device_context, alloc_attrs, keys, tensors_to_send)); in SendTensors()
141 RendezvousInterface* rendezvous, std::vector<Tensor>* received_tensors, in ReceiveTensorsAsync() argument
150 RecvOutputsFromRendezvousAsync(rendezvous, device_context, alloc_attrs, keys, in ReceiveTensorsAsync()
1100 if (opts.rendezvous && data->is_cross_process_ && in RunMultiDevice()
1101 !opts.rendezvous->is_cross_process()) { in RunMultiDevice()
1398 if (!opts.rendezvous) { in Run()
1404 new_opts.rendezvous = created_rendezvous; in Run()
1504 auto rendezvous = opts.rendezvous; in RunInternal() local
1525 rendezvous); in RunInternal()
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | sendrecv_ops.cc | 82 ctx, ctx->rendezvous() != nullptr, in Compute()
97 << reinterpret_cast<uintptr_t>(ctx->rendezvous()); in Compute()
98 ctx->SetStatus(ctx->rendezvous()->Send(parsed_key_, args, ctx->input(0), in Compute()
105 << reinterpret_cast<uintptr_t>(ctx->rendezvous()); in Compute()
109 ctx->SetStatus(ctx->rendezvous()->Send(in_loop_parsed, args, ctx->input(0), in Compute()
192 ctx, ctx->rendezvous() != nullptr, in ComputeAsync()
204 << reinterpret_cast<uintptr_t>(ctx->rendezvous()); in ComputeAsync()
205 ctx->rendezvous()->RecvAsync(parsed_key_, args, in ComputeAsync()
211 << reinterpret_cast<uintptr_t>(ctx->rendezvous()); in ComputeAsync()
214 ctx->rendezvous()->RecvAsync(in_loop_parsed, args, in ComputeAsync()
|
| /external/autotest/client/tests/netpipe/ |
| D | netpipe.py | 55 self.job.barrier(server_tag, 'start', 600).rendezvous(*all)
59 self.job.barrier(server_tag, 'stop', 300).rendezvous(*all)
62 self.job.barrier(client_tag, 'start', 600).rendezvous(*all)
67 self.job.barrier(client_tag, 'stop', 300).rendezvous(*all)
|
| /external/autotest/client/bin/self-test/tests/ |
| D | 100-barrier-2x-master-first | 11 b.rendezvous(*us)
20 b.rendezvous(*us)
|
| D | 101-barrier-2x-slave-first | 11 b.rendezvous(*us)
20 b.rendezvous(*us)
|
| D | 105-barrier-5x-master-middle | 19 b.rendezvous(*us)
28 b.rendezvous(*us)
|
| D | 103-barrier-2x-slave-only | 10 b.rendezvous(*us)
|
| D | 102-barrier-2x-master-only | 10 b.rendezvous(*us)
|
| D | 111-barrier-unordered-20x | 14 b.rendezvous(*us)
|
| /external/tensorflow/tensorflow/lite/delegates/flex/ |
| D | delegate_data.cc | 44 tensorflow::Rendezvous* rendezvous = in Prepare() local
50 rendezvous, nullptr); in Prepare()
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | collective_ops_utils.h | 219 std::shared_ptr<Rendezvous<I, O>> rendezvous = rendezvous_getter(); in SubmitParticipant() local
220 TF_ASSIGN_OR_RETURN(auto p, rendezvous->SubmitParticipant(participant)); in SubmitParticipant()
231 rendezvous.reset(); in SubmitParticipant()
237 rendezvous.get()); in SubmitParticipant()
|
| /external/tensorflow/tensorflow/core/common_runtime/eager/ |
| D | kernel_and_device.cc | 258 params.rendezvous = rendezvous_; in Run()
369 Rendezvous* rendezvous = rendezvous_creator_(opts->step_id); in RunAsync() local
370 opts->rendezvous = rendezvous; in RunAsync()
394 [opts, rendezvous, local_cm, step_container, this, in RunAsync()
396 rendezvous->Unref(); in RunAsync()
|
| D | mkl_eager_op_rewrite_test.cc | 41 tensorflow::Rendezvous* rendezvous = in CreateOp() local
46 async, device_mgr.get(), false, rendezvous); in CreateOp()
|
| /external/autotest/client/tests/barriertest/ |
| D | barriertest.py | 18 listen_server=server).rendezvous(*hostnames)
33 ).rendezvous(abort=True, *hostnames)
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _channel.py | 453 rendezvous = _Rendezvous(state, None, None, deadline)
454 return deadline, None, rendezvous
462 rendezvous = _Rendezvous(state, call, None, deadline)
463 return state.response, rendezvous
499 deadline, serialized_request, rendezvous = _start_unary_request(
502 return None, None, None, rendezvous
516 state, operations, deadline, rendezvous = self._prepare(
519 raise rendezvous
540 state, operations, deadline, rendezvous = self._prepare(
543 raise rendezvous
[all …]
|
| /external/tensorflow/tensorflow/core/tpu/kernels/ |
| D | host_compute_ops.cc | 111 ctx, ctx->rendezvous() != nullptr, in ComputeAsync()
149 ctx->rendezvous()->RecvAsync( in ComputeAsync()
266 ctx, ctx->rendezvous() != nullptr, in Compute()
285 ctx, ctx->rendezvous()->Send(parsed_key, args, ctx->input(i), false)); in Compute()
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | collective_permute_thunk.cc | 240 std::shared_ptr<Rendezvous> rendezvous = in ExecuteOnStream() local
261 rendezvous->SubmitParticipant(participant)); in ExecuteOnStream()
280 rendezvous.reset(); in ExecuteOnStream()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | remote_mgr_test.cc | 52 tensorflow::Rendezvous* rendezvous = in RemoteMgrTest() local
57 /*async=*/false, device_mgr.release(), true, rendezvous, nullptr); in RemoteMgrTest()
|
| /external/autotest/client/common_lib/ |
| D | barrier_unittest.py | 165 b1.rendezvous('127.0.0.1#0', '127.0.0.1#1', abort=abort)
167 b1.rendezvous('127.0.0.1#0', '127.0.0.1#1')
|