| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service_impl.h | 63 EnqueueRequest(&service_, cq_.get(), \
74 void EnqueueHandler(EagerCall<EnqueueRequest, EnqueueResponse>* call) { in EnqueueHandler() argument
81 Call<GrpcEagerServiceImpl, grpc::EagerService::AsyncService, EnqueueRequest, in EnqueueHandler()
83 EnqueueRequest(&service_, cq_.get(), in EnqueueHandler()
104 EnqueueRequest( in RunComponentFunctionHandler()
121 StreamingCall<EnqueueRequest, EnqueueResponse>* call) { in StreamingEnqueueHandler() argument
|
| D | grpc_eager_service_impl.cc | 47 EnqueueRequest(&service_, cq_.get(), \ in HandleRPCsLoop()
63 EnqueueRequest, EnqueueResponse>:: in HandleRPCsLoop()
64 EnqueueRequest(&service_, cq_.get(), in HandleRPCsLoop()
|
| D | grpc_eager_client.cc | 183 const EnqueueRequest* request, in StreamingEnqueueAsync()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | destroy_tensor_handle_node.h | 32 DestroyTensorHandleNode(std::unique_ptr<EnqueueRequest> request, in DestroyTensorHandleNode()
79 std::unique_ptr<EnqueueRequest> request_;
|
| D | remote_execute_node.h | 41 std::unique_ptr<EnqueueRequest> request, Device* device, in RemoteExecuteNode()
126 std::unique_ptr<EnqueueRequest> request_;
|
| D | eager_service_impl_test.cc | 90 void EnqueueAsync(CallOptions* call_opts, const EnqueueRequest* request, in EnqueueAsync()
103 const EnqueueRequest* request, in StreamingEnqueueAsync()
217 EnqueueRequest* request) { in AddOperationToEnqueueRequest()
402 EnqueueRequest remote_enqueue_request; in TEST_F()
486 EnqueueRequest enqueue_request; in TestFunction()
494 EnqueueRequest remote_enqueue_request; in TestFunction()
585 EnqueueRequest enqueue_request; in TestComponentFunction()
593 EnqueueRequest remote_enqueue_request; in TestComponentFunction()
760 EnqueueRequest remote_enqueue_request; in Init()
1057 EnqueueRequest remote_enqueue_request; in TEST_F()
[all …]
|
| D | remote_tensor_handle_data.cc | 47 std::unique_ptr<eager::EnqueueRequest> request(new eager::EnqueueRequest); in DestroyRemoteTensorHandle()
|
| D | remote_copy_node.cc | 148 EnqueueRequest request; in StartSend()
214 EnqueueRequest request; in RunRemoteRecv()
365 EnqueueRequest request; in StartSendPackedHandle()
418 EnqueueRequest request; in StartRemoteSendTensor()
|
| D | eager_client.h | 68 const EnqueueRequest* request,
|
| D | cluster_function_library_runtime.cc | 84 auto request = std::make_shared<EnqueueRequest>(); in Instantiate()
271 auto request = std::make_shared<EnqueueRequest>(); in CleanUp()
|
| D | eager_service_impl.h | 93 Status Enqueue(CallOptions* call_opts, const EnqueueRequest* request,
|
| D | eager_service_impl.cc | 550 const EnqueueRequest* request, in Enqueue()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_call.h | 208 static void EnqueueRequest(GrpcService* grpc_service, in EnqueueRequest() function
440 ResponseMessage>::EnqueueRequest(grpc_service_, cq_, enqueue_function_, in CallOpen()
475 static void EnqueueRequest(GrpcService* grpc_service, in EnqueueRequest() function
|
| D | grpc_master_service.cc | 97 EnqueueRequest(&master_service_, cq_.get(), \
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | eager_service.proto | 156 message EnqueueRequest { message
302 rpc Enqueue(EnqueueRequest) returns (EnqueueResponse);
310 rpc StreamingEnqueue(stream EnqueueRequest) returns (stream EnqueueResponse);
317 // server. Different from EnqueueRequest, ops/functions sent through this
|
| /external/tensorflow/tensorflow/core/common_runtime/eager/ |
| D | context.cc | 626 std::shared_ptr<eager::EnqueueRequest> request(new eager::EnqueueRequest); in MaybeRegisterFunctionRemotely()
664 std::vector<std::shared_ptr<eager::EnqueueRequest>> requests( in RegisterExistingFunctionsOnRemoteWorkers()
667 requests[i] = std::make_shared<eager::EnqueueRequest>(); in RegisterExistingFunctionsOnRemoteWorkers()
812 eager::EnqueueRequest request; in SyncExecutors()
|
| D | execute.cc | 842 std::unique_ptr<eager::EnqueueRequest> request(new eager::EnqueueRequest); in EagerRemoteExecute()
|