| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | remote_copy_node.cc | 177 EnqueueResponse* response = new EnqueueResponse; in StartSend()
250 EnqueueResponse* response = new EnqueueResponse; in RunRemoteRecv()
402 EnqueueResponse* response = new EnqueueResponse; in StartSendPackedHandle()
454 EnqueueResponse* response = new EnqueueResponse; in StartRemoteSendTensor()
|
| D | destroy_tensor_handle_node.h | 44 EnqueueResponse* response = new EnqueueResponse; in RunAsync()
|
| D | eager_service_impl_test.cc | 96 EnqueueResponse* response, StatusCallback done) override { in EnqueueAsync()
110 EnqueueResponse* response, in StreamingEnqueueAsync()
410 EnqueueResponse remote_enqueue_response; in TEST_F()
495 EnqueueResponse enqueue_response; in TestFunction()
502 EnqueueResponse remote_enqueue_response; in TestFunction()
594 EnqueueResponse enqueue_response; in TestComponentFunction()
601 EnqueueResponse remote_enqueue_response; in TestComponentFunction()
768 EnqueueResponse remote_enqueue_response; in Init()
1077 EnqueueResponse remote_enqueue_response; in TEST_F()
1149 EnqueueResponse remote_enqueue_response; in TEST_F()
[all …]
|
| D | eager_client.h | 69 EnqueueResponse* response,
|
| D | cluster_function_library_runtime.cc | 84 auto response = std::make_shared<EnqueueResponse>(); in Instantiate()
273 auto response = std::make_shared<EnqueueResponse>(); in CleanUp()
|
| D | remote_execute_node.cc | 28 auto response = std::make_shared<EnqueueResponse>(); in RunAsync()
|
| D | eager_service_impl.h | 93 EnqueueResponse* response,
|
| D | eager_service_impl.cc | 591 EnqueueResponse* response, uint64 stream_id) { in Enqueue()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service_impl.h | 74 void EnqueueHandler(EagerCall<EnqueueRequest, EnqueueResponse>* call) { in EnqueueHandler()
82 EnqueueResponse>:: in EnqueueHandler()
121 StreamingCall<EnqueueRequest, EnqueueResponse>* call) { in StreamingEnqueueHandler()
|
| D | grpc_eager_service_impl.cc | 63 EnqueueRequest, EnqueueResponse>:: in HandleRPCsLoop()
|
| D | grpc_eager_client.cc | 194 EnqueueResponse* response, in StreamingEnqueueAsync()
237 std::unordered_map<uint64, StreamingRPCDispatcher<EnqueueResponse>>
|
| /external/openthread/src/ncp/ |
| D | ncp_base.hpp | 245 otError EnqueueResponse(uint8_t aHeader, ResponseType aType, unsigned int aPropKeyOrStatus);
249 return EnqueueResponse(aHeader, kResponseTypeGet, aPropKey); in PrepareGetResponse()
253 return EnqueueResponse(aHeader, kResponseTypeSet, aPropKey); in PrepareSetResponse()
257 return EnqueueResponse(aHeader, kResponseTypeLastStatus, aStatus); in PrepareLastStatusResponse()
|
| D | ncp_base.cpp | 715 otError NcpBase::EnqueueResponse(uint8_t aHeader, ResponseType aType, unsigned int aPropKeyOrStatus) in EnqueueResponse() function in ot::Ncp::NcpBase
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | eager_service.proto | 162 message EnqueueResponse { message
302 rpc Enqueue(EnqueueRequest) returns (EnqueueResponse);
310 rpc StreamingEnqueue(stream EnqueueRequest) returns (stream EnqueueResponse);
|
| /external/tensorflow/tensorflow/core/common_runtime/eager/ |
| D | context.cc | 855 eager::EnqueueResponse* response = new eager::EnqueueResponse(); in MaybeRegisterFunctionRemotely()
900 auto response = std::make_shared<eager::EnqueueResponse>(); in RegisterExistingFunctionsOnRemoteWorkers()
1038 eager::EnqueueResponse* response = new eager::EnqueueResponse(); in SyncExecutors()
|
| /external/openthread/src/core/coap/ |
| D | coap.hpp | 300 …void EnqueueResponse(Message &aMessage, const Ip6::MessageInfo &aMessageInfo, const TxParameters &…
|
| D | coap.cpp | 263 mResponsesQueue.EnqueueResponse(aMessage, aMessageInfo, aTxParameters); in SendMessage()
1526 void ResponsesQueue::EnqueueResponse(Message & aMessage, in EnqueueResponse() function in ot::Coap::ResponsesQueue
|