/external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
D | cluster_function_library_runtime.cc | 75 EnqueueRequest* request = new EnqueueRequest; in Instantiate() 144 eager::EnqueueRequest* request = new eager::EnqueueRequest; in Run() 194 eager::EnqueueRequest* request = new eager::EnqueueRequest; in CleanUp()
|
D | destroy_tensor_handle_node.h | 32 DestroyTensorHandleNode(std::unique_ptr<EnqueueRequest> request, in DestroyTensorHandleNode() 77 std::unique_ptr<EnqueueRequest> request_;
|
D | remote_execute_node.h | 39 RemoteExecuteNode(std::unique_ptr<EnqueueRequest> request, Device* device, in RemoteExecuteNode() 97 std::unique_ptr<EnqueueRequest> request_;
|
D | eager_service_impl_test.cc | 93 void StreamingEnqueueAsync(const EnqueueRequest* request, in StreamingEnqueueAsync() 175 EnqueueRequest* request) { in AddOperationToEnqueueRequest() 293 EnqueueRequest remote_enqueue_request; in TEST_F() 375 EnqueueRequest enqueue_request; in TestFunction() 383 EnqueueRequest remote_enqueue_request; in TestFunction() 492 EnqueueRequest remote_enqueue_request; in Init() 657 EnqueueRequest remote_enqueue_request; in TEST_F() 732 EnqueueRequest remote_enqueue_request; in TEST_F()
|
D | remote_tensor_handle_data.cc | 46 std::unique_ptr<eager::EnqueueRequest> request(new eager::EnqueueRequest); in DestroyRemoteTensorHandle()
|
D | eager_client.h | 57 virtual void StreamingEnqueueAsync(const EnqueueRequest* request,
|
D | remote_copy_node.cc | 144 EnqueueRequest request; in StartSend() 195 EnqueueRequest request; in RunRemoteRecv() 288 EnqueueRequest request; in StartRemoteSendTensor()
|
D | eager_service_impl.h | 93 Status Enqueue(const EnqueueRequest* request, EnqueueResponse* response,
|
D | eager_service_impl.cc | 397 Status EagerServiceImpl::Enqueue(const EnqueueRequest* request, in Enqueue()
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
D | grpc_eager_service_impl.cc | 47 EnqueueRequest(&service_, cq_.get(), \ in HandleRPCsLoop() 62 EnqueueRequest, EnqueueResponse>:: in HandleRPCsLoop() 63 EnqueueRequest(&service_, cq_.get(), in HandleRPCsLoop()
|
D | grpc_eager_service_impl.h | 63 EnqueueRequest(&service_, cq_.get(), \ 85 StreamingCall<EnqueueRequest, EnqueueResponse>* call) { in StreamingEnqueueHandler() argument
|
D | grpc_eager_client.cc | 160 void StreamingEnqueueAsync(const EnqueueRequest* request, in StreamingEnqueueAsync()
|
/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/v8/src/heap/ |
D | memory-measurement.h | 28 bool EnqueueRequest(std::unique_ptr<v8::MeasureMemoryDelegate> delegate,
|
D | memory-measurement.cc | 175 bool MemoryMeasurement::EnqueueRequest( in EnqueueRequest() function in v8::internal::MemoryMeasurement
|
D | heap.cc | 3812 return memory_measurement_->EnqueueRequest(std::move(delegate), execution, in MeasureMemory()
|
/external/tensorflow/tensorflow/core/protobuf/ |
D | eager_service.proto | 134 message EnqueueRequest { message 240 rpc Enqueue(EnqueueRequest) returns (EnqueueResponse); 248 rpc StreamingEnqueue(stream EnqueueRequest) returns (stream EnqueueResponse);
|
/external/tensorflow/tensorflow/core/common_runtime/eager/ |
D | context.cc | 514 std::shared_ptr<eager::EnqueueRequest> request(new eager::EnqueueRequest); in MaybeRegisterFunctionRemotely() 558 auto* request = new eager::EnqueueRequest; in RegisterExistingFunctionsOnRemoteWorkers()
|
D | execute.cc | 650 std::unique_ptr<eager::EnqueueRequest> request(new eager::EnqueueRequest); in EagerRemoteExecute()
|