Searched refs:src_incarnation (Results 1 – 10 of 10) sorted by relevance
| /external/tensorflow/tensorflow/core/framework/ |
| D | rendezvous.cc | 44 src_incarnation = b.src_incarnation; in operator =()
54 string Rendezvous::CreateKey(const string& src_device, uint64 src_incarnation, in CreateKey() argument
66 src_device, ";", strings::Uint64ToHexString(src_incarnation, buf), ";", in CreateKey()
106 strings::HexStringToUint64(parts[1], &out->src_incarnation) && in ParseKey()
|
| D | rendezvous.h | 62 uint64 src_incarnation = 0; member
173 uint64 src_incarnation,
|
| D | rendezvous_test.cc | 54 EXPECT_EQ(parsed.src_incarnation, 7890); in TEST()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | process_function_library_runtime.h | 92 const string& key_prefix, int64 src_incarnation,
106 const string& key_prefix, int64 src_incarnation, int64 num_tensors,
|
| D | process_function_library_runtime.cc | 119 const string& key_prefix, int64 src_incarnation, in SendTensors() argument
126 string key = Rendezvous::CreateKey(source_device, src_incarnation, in SendTensors()
138 const string& key_prefix, int64 src_incarnation, int64 num_tensors, in ReceiveTensorsAsync() argument
146 string key = Rendezvous::CreateKey(source_device, src_incarnation, in ReceiveTensorsAsync()
1512 int64 src_incarnation, target_incarnation; in RunInternal() local
1513 s = GetDeviceIncarnation(source_device, &src_incarnation); in RunInternal()
1523 s = SendTensors(source_device, target_device, "arg_", src_incarnation, in RunInternal()
|
| D | function.cc | 1010 int64 src_incarnation, target_incarnation; in RunRemote() local
1011 s = parent_->GetDeviceIncarnation(source_device, &src_incarnation); in RunRemote()
1051 source_device, target_device, "arg_", src_incarnation, args.size(), in RunRemote()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker.cc | 443 if ((*src_dev)->attributes().incarnation() != parsed.src_incarnation) { in PrepareRecvTensor()
446 parsed.src_incarnation, " vs. ", (*src_dev)->attributes().incarnation(), in PrepareRecvTensor()
|
| D | collective_rma_distributed_test.cc | 111 << " src_incarnation=" << request->src_incarnation(); in RecvBufAsync()
114 request->src_incarnation(), in RecvBufAsync()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_worker_service.cc | 699 request->src_incarnation(), consumer_callback, in RecvBufAsync()
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | worker.proto | 515 uint64 src_incarnation = 11; field
|