Home
last modified time | relevance | path

Searched refs:req_ (Results 1 – 12 of 12) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_cc.cc596 : 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/
Dcollective_rma_distributed.cc45 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 …]
Dcollective_param_resolver_distributed.cc40 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 …]
Dmaster_session.cc879 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/
Dserver_async.cc262 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 …]
Dclient_async.cc78 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/
Drpc_rendezvous_mgr.cc70 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/
Drpc.h284 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/
Dserver_callback_handlers.h596 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/
Dserver_callback_handlers.h596 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/
Dsanitizer_syscalls_netbsd.inc299 (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/
Devdns.c1775 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()