/external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
D | server_cc.cc | 596 : req_(req) { in CallbackCallTag() 613 Server::CallbackRequest<ServerContextType>* req_; member in grpc::Server::CallbackRequest::CallbackCallTag 621 void* ignored = req_; in Run() 623 GPR_ASSERT(!req_->FinalizeResult(&ignored, &new_ok)); in Run() 624 GPR_ASSERT(ignored == req_); in Run() 629 delete req_; in Run() 634 req_->ctx_.set_call(req_->call_); in Run() 635 req_->ctx_.cq_ = req_->cq_; in Run() 636 req_->ctx_.BindDeadlineAndMetadata(req_->deadline_, in Run() 637 &req_->request_metadata_); in Run() [all …]
|
/external/tensorflow/tensorflow/core/distributed_runtime/ |
D | collective_rma_distributed.cc | 45 req_.set_step_id(step_id); in RecvBufCall() 46 req_.set_buf_rendezvous_key(key); in RecvBufCall() 47 *req_.mutable_client_locality() = client_locality; in RecvBufCall() 48 *req_.mutable_server_locality() = server_attributes.locality(); in RecvBufCall() 49 req_.set_num_bytes(to_tensor->TotalBytes()); in RecvBufCall() 50 req_.set_buf_ptr(reinterpret_cast<int64>(DMAHelper::base(to_tensor))); in RecvBufCall() 51 req_.set_src_device(peer_device); in RecvBufCall() 52 req_.set_src_incarnation(server_attributes.incarnation()); in RecvBufCall() 53 req_.set_dst_device(to_device->name()); in RecvBufCall() 54 req_.set_request_id(GetUniqueRequestId()); in RecvBufCall() [all …]
|
D | collective_param_resolver_distributed.cc | 40 req_.set_group_key(group.group_key); in CompleteGroupCall() 41 req_.set_group_size(group.group_size); in CompleteGroupCall() 42 req_.set_device_type(group.device_type.type_string()); in CompleteGroupCall() 43 *req_.mutable_device_attributes() = device; in CompleteGroupCall() 44 req_.set_collective_type(collective_type); in CompleteGroupCall() 49 wi_->CompleteGroupAsync(&opts_, &req_, &resp_, done); in IssueCall() 52 CompleteGroupRequest req_; member in tensorflow::__anon463e9d2a0111::CompleteGroupCall 64 req_.set_name(node_name); in CompleteInstanceCall() 65 req_.set_type(instance.type); in CompleteInstanceCall() 66 req_.set_data_type(instance.data_type); in CompleteInstanceCall() [all …]
|
D | master_session.cc | 879 req_.set_step_id(step_id); in CleanupBroadcastHelper() 883 CleanupGraphRequest* request() { return &req_; } in request() 909 CleanupGraphRequest req_; member in tensorflow::__anon4940402c0711::CleanupBroadcastHelper
|
/external/grpc-grpc/test/cpp/qps/ |
D | server_async.cc | 262 request_method_(srv_ctx_.get(), &req_, &response_writer_, in ServerRpcContextUnaryImpl() 269 req_ = RequestType(); in Reset() 275 request_method_(srv_ctx_.get(), &req_, &response_writer_, in Reset() 287 grpc::Status status = invoke_method_(&req_, &response_); in invoker() 295 RequestType req_; member in grpc::testing::AsyncQpsServerTest::ServerRpcContextUnaryImpl 324 req_ = RequestType(); in Reset() 339 stream_.Read(&req_, AsyncQpsServerTest::tag(this)); in request_done() 347 grpc::Status status = invoke_method_(&req_, &response_); in read_done() 362 stream_.Read(&req_, AsyncQpsServerTest::tag(this)); in write_done() 372 RequestType req_; member in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingImpl [all …]
|
D | client_async.cc | 78 req_(req), in ClientRpcContextUnaryImpl() 93 response_reader_ = prepare_req_(stub_, &context_, req_, cq_); in RunNextState() 112 auto* clone = new ClientRpcContextUnaryImpl(stub_, req_, next_issue_, in StartNewClone() 123 const RequestType& req_; member in grpc::testing::ClientRpcContextUnaryImpl 349 req_(req), in ClientRpcContextStreamingPingPongImpl() 382 stream_->WriteLast(req_, WriteOptions(), in RunNextState() 385 stream_->Write(req_, ClientRpcContext::tag(this)); in RunNextState() 428 stub_, req_, next_issue_, prepare_req_, callback_); in StartNewClone() 438 const RequestType& req_; member in grpc::testing::ClientRpcContextStreamingPingPongImpl 534 req_(req), in ClientRpcContextStreamingFromClientImpl() [all …]
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
D | rpc_rendezvous_mgr.cc | 70 req_.set_step_id(step_id); in Init() 71 req_.set_rendezvous_key(key.data(), key.size()); in Init() 72 req_.set_request_id(GetUniqueRequestId()); in Init() 85 req_.Clear(); in Reset() 152 wi_->RecvTensorAsync(&opts_, &req_, &resp_, std::move(cb)); in StartRTCall() 177 RecvTensorRequest req_; member in tensorflow::__anona9090a8f0111::RpcRecvTensorCall
|
/external/libevent/include/event2/ |
D | rpc.h | 284 struct evrpc_req_generic *req_ = (struct evrpc_req_generic *)(rpc_req); \ 285 evrpc_request_done(req_); \
|
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
D | server_callback_handlers.h | 596 req_(req), in ServerCallbackWriterImpl() 619 ~ServerCallbackWriterImpl() { req_->~RequestType(); } in ~ServerCallbackWriterImpl() 621 const RequestType* request() { return req_; } in request() 651 const RequestType* req_; variable
|
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
D | server_callback_handlers.h | 596 req_(req), in ServerCallbackWriterImpl() 619 ~ServerCallbackWriterImpl() { req_->~RequestType(); } in ~ServerCallbackWriterImpl() 621 const RequestType* request() { return req_; } in request() 651 const RequestType* req_; variable
|
/external/llvm-project/compiler-rt/lib/sanitizer_common/ |
D | sanitizer_syscalls_netbsd.inc | 299 (long long req_, long long pid_, void *addr_, long long data_) { 300 if (req_ == ptrace_pt_io) { 313 } else if (req_ == ptrace_pt_lwpinfo) { 318 } else if (req_ == ptrace_pt_set_event_mask) { 320 } else if (req_ == ptrace_pt_get_event_mask) { 322 } else if (req_ == ptrace_pt_set_siginfo) { 324 } else if (req_ == ptrace_pt_get_siginfo) { 326 } else if (req_ == ptrace_pt_lwpstatus) { 331 } else if (req_ == ptrace_pt_lwpnext) { 336 } else if (req_ == ptrace_pt_setregs) { [all …]
|
/external/libevent/ |
D | evdns.c | 1775 evdns_server_request_add_reply(struct evdns_server_request *req_, int section, const char *name, in… in evdns_server_request_add_reply() argument 1777 struct server_request *req = TO_SERVER_REQUEST(req_); in evdns_server_request_add_reply() 2005 evdns_server_request_respond(struct evdns_server_request *req_, int err) in evdns_server_request_respond() argument 2007 struct server_request *req = TO_SERVER_REQUEST(req_); in evdns_server_request_respond() 2153 evdns_server_request_drop(struct evdns_server_request *req_) in evdns_server_request_drop() argument 2155 struct server_request *req = TO_SERVER_REQUEST(req_); in evdns_server_request_drop() 2162 evdns_server_request_get_requesting_addr(struct evdns_server_request *req_, struct sockaddr *sa, in… in evdns_server_request_get_requesting_addr() argument 2164 struct server_request *req = TO_SERVER_REQUEST(req_); in evdns_server_request_get_requesting_addr()
|