| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | remote_tensor_handle_data.cc | 28 void DestroyRemoteTensorHandle(EagerContext* ctx, const string& remote_task, in DestroyRemoteTensorHandle() argument
39 Status status = ctx->GetClient(remote_task, &eager_client); in DestroyRemoteTensorHandle()
43 << remote_task << " is no longer available."; in DestroyRemoteTensorHandle()
101 const string& remote_task, in RemoteTensorHandleData() argument
106 remote_task_(remote_task), in RemoteTensorHandleData()
181 const TensorShape& shape, const string& remote_task) { in SetShapeAndRemoteTask() argument
192 if (!remote_task.empty()) { in SetShapeAndRemoteTask()
193 remote_task_ = remote_task; in SetShapeAndRemoteTask()
|
| D | remote_tensor_handle_data.h | 39 RemoteTensorHandleData(int64 op_id, int output_num, const string& remote_task,
55 const string& remote_task);
|
| /external/google-breakpad/src/client/mac/crash_generation/ |
| D | crash_generation_server.cc | 109 mach_port_t remote_task = message.GetTranslatedPort(0); in WaitForOneMessage() local
114 pid_for_task(remote_task, &remote_pid); in WaitForOneMessage()
120 ScopedTaskSuspend suspend(remote_task); in WaitForOneMessage()
122 MinidumpGenerator generator(remote_task, handler_thread); in WaitForOneMessage()
|
| D | Inspector.mm | 219 printf("remote_task = %d\n", remote_task_);
|
| /external/tensorflow/tensorflow/core/common_runtime/eager/ |
| D | tensor_handle.h | 67 TensorHandle(int64 op_id, int32 output_num, const string& remote_task,
109 int64 op_id, int32 output_num, const string& remote_task,
183 const string& remote_task, EagerContext* ctx);
|
| D | tensor_handle_test.cc | 160 const string remote_task = "/job:worker/replica:0/task:1"; in TEST_F() local
163 /*op_id=*/0, /*output_num=*/0, remote_task, dtype, d2, context()); in TEST_F()
167 /*op_id=*/1, /*output_num=*/0, remote_task, dtype, d3, context()); in TEST_F()
390 const string remote_task = "/job:worker/replica:0/task:1"; in TEST_F() local
393 /*op_id=*/0, /*output_num=*/0, remote_task, dtype, d1, context, in TEST_F()
|
| D | tensor_handle.cc | 369 int64 op_id, int32 output_num, const string& remote_task, in CreateUnshapedRemoteHandle() argument
372 return new TensorHandle(op_id, output_num, remote_task, dtype, d, ctx, in CreateUnshapedRemoteHandle()
377 const string& remote_task, in TensorHandle() argument
390 remote_task, ctx) { in TensorHandle()
771 const string& remote_task, in AddUnshapedRemoteMirror() argument
789 std::forward_as_tuple(op_id, output_num, remote_task, ctx)); in AddUnshapedRemoteMirror()
876 string remote_task; in SetRemoteShapeAndDevice() local
877 if (!DeviceNameUtils::GetTaskName(device->parsed_name(), &remote_task)) { in SetRemoteShapeAndDevice()
882 return data.SetShapeAndRemoteTask(shape, remote_task); in SetRemoteShapeAndDevice()
|
| D | execute.cc | 590 string remote_task; in CreateUnshapedOutput()
592 &remote_task)) { in CreateUnshapedOutput()
599 op_id, output_num, remote_task, output_dtype, output_device, ctx); in CreateUnshapedOutput()
835 string remote_task; in EagerRemoteExecute() local
836 if (!DeviceNameUtils::GetTaskName(op->GetDeviceParsedName(), &remote_task)) { in EagerRemoteExecute()
940 id, i, remote_task, output_dtypes[i], op_device, &ctx, unknown_device); in EagerRemoteExecute()
1278 string remote_task; in EagerCopyToDevice()
1279 if (!DeviceNameUtils::GetTaskName(device->parsed_name(), &remote_task)) { in EagerCopyToDevice()
1287 remote_task, ctx)); in EagerCopyToDevice()
1292 recv_op_id, 0, remote_task, h->dtype, device, ctx); in EagerCopyToDevice()
|
| D | context.cc | 1030 Status EagerContext::GetClient(const string& remote_task, in GetClient() argument
1038 TF_RETURN_IF_ERROR(remote_eager_workers_->GetClient(remote_task, client)); in GetClient()
1043 "Unable to find eager client corresponding to target ", remote_task); in GetClient()
|
| D | context.h | 344 Status GetClient(const string& remote_task,
|