Home
last modified time | relevance | path

Searched refs:EnqueueRequest (Results 1 – 20 of 20) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Dcluster_function_library_runtime.cc75 EnqueueRequest* request = new EnqueueRequest; in Instantiate()
144 eager::EnqueueRequest* request = new eager::EnqueueRequest; in Run()
194 eager::EnqueueRequest* request = new eager::EnqueueRequest; in CleanUp()
Ddestroy_tensor_handle_node.h32 DestroyTensorHandleNode(std::unique_ptr<EnqueueRequest> request, in DestroyTensorHandleNode()
77 std::unique_ptr<EnqueueRequest> request_;
Dremote_execute_node.h39 RemoteExecuteNode(std::unique_ptr<EnqueueRequest> request, Device* device, in RemoteExecuteNode()
97 std::unique_ptr<EnqueueRequest> request_;
Deager_service_impl_test.cc93 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()
Dremote_tensor_handle_data.cc46 std::unique_ptr<eager::EnqueueRequest> request(new eager::EnqueueRequest); in DestroyRemoteTensorHandle()
Deager_client.h57 virtual void StreamingEnqueueAsync(const EnqueueRequest* request,
Dremote_copy_node.cc144 EnqueueRequest request; in StartSend()
195 EnqueueRequest request; in RunRemoteRecv()
288 EnqueueRequest request; in StartRemoteSendTensor()
Deager_service_impl.h93 Status Enqueue(const EnqueueRequest* request, EnqueueResponse* response,
Deager_service_impl.cc397 Status EagerServiceImpl::Enqueue(const EnqueueRequest* request, in Enqueue()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service_impl.cc47 EnqueueRequest(&service_, cq_.get(), \ in HandleRPCsLoop()
62 EnqueueRequest, EnqueueResponse>:: in HandleRPCsLoop()
63 EnqueueRequest(&service_, cq_.get(), in HandleRPCsLoop()
Dgrpc_eager_service_impl.h63 EnqueueRequest(&service_, cq_.get(), \
85 StreamingCall<EnqueueRequest, EnqueueResponse>* call) { in StreamingEnqueueHandler() argument
Dgrpc_eager_client.cc160 void StreamingEnqueueAsync(const EnqueueRequest* request, in StreamingEnqueueAsync()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_call.h208 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
Dgrpc_master_service.cc97 EnqueueRequest(&master_service_, cq_.get(), \
/external/v8/src/heap/
Dmemory-measurement.h28 bool EnqueueRequest(std::unique_ptr<v8::MeasureMemoryDelegate> delegate,
Dmemory-measurement.cc175 bool MemoryMeasurement::EnqueueRequest( in EnqueueRequest() function in v8::internal::MemoryMeasurement
Dheap.cc3812 return memory_measurement_->EnqueueRequest(std::move(delegate), execution, in MeasureMemory()
/external/tensorflow/tensorflow/core/protobuf/
Deager_service.proto134 message EnqueueRequest { message
240 rpc Enqueue(EnqueueRequest) returns (EnqueueResponse);
248 rpc StreamingEnqueue(stream EnqueueRequest) returns (stream EnqueueResponse);
/external/tensorflow/tensorflow/core/common_runtime/eager/
Dcontext.cc514 std::shared_ptr<eager::EnqueueRequest> request(new eager::EnqueueRequest); in MaybeRegisterFunctionRemotely()
558 auto* request = new eager::EnqueueRequest; in RegisterExistingFunctionsOnRemoteWorkers()
Dexecute.cc650 std::unique_ptr<eager::EnqueueRequest> request(new eager::EnqueueRequest); in EagerRemoteExecute()