| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | server_cc.cc | 589 : req_(req) { in CallbackCallTag()
606 Server::CallbackRequest<ServerContextType>* req_; member in grpc::Server::CallbackRequest::CallbackCallTag
614 void* ignored = req_; in Run()
616 GPR_ASSERT(!req_->FinalizeResult(&ignored, &new_ok)); in Run()
617 GPR_ASSERT(ignored == req_); in Run()
622 delete req_; in Run()
627 req_->ctx_->set_call(req_->call_); in Run()
628 req_->ctx_->cq_ = req_->cq_; in Run()
629 req_->ctx_->BindDeadlineAndMetadata(req_->deadline_, in Run()
630 &req_->request_metadata_); in Run()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | collective_param_resolver_distributed.cc | 39 req_.set_group_key(group.group_key); in CompleteGroupCall()
40 req_.set_group_size(group.group_size); in CompleteGroupCall()
41 req_.set_device_type(group.device_type.type_string()); in CompleteGroupCall()
42 *req_.mutable_device_attributes() = device; in CompleteGroupCall()
47 wi_->CompleteGroupAsync(&opts_, &req_, &resp_, done); in IssueCall()
50 CompleteGroupRequest req_; member in tensorflow::__anond8d0a2c80111::CompleteGroupCall
62 req_.set_name(node_name); in CompleteInstanceCall()
63 req_.set_type(instance.type); in CompleteInstanceCall()
64 req_.set_data_type(instance.data_type); in CompleteInstanceCall()
65 instance.shape.AsProto(req_.mutable_shape()); in CompleteInstanceCall()
[all …]
|
| D | collective_rma_distributed.cc | 49 req_.set_step_id(step_id); in RecvBufCall()
50 req_.set_buf_rendezvous_key(key); in RecvBufCall()
51 *req_.mutable_client_locality() = client_locality; in RecvBufCall()
52 *req_.mutable_server_locality() = server_attributes.locality(); in RecvBufCall()
53 req_.set_num_bytes(to_tensor->TotalBytes()); in RecvBufCall()
54 req_.set_buf_ptr(reinterpret_cast<int64_t>(DMAHelper::base(to_tensor))); in RecvBufCall()
55 req_.set_src_device(peer_device); in RecvBufCall()
56 req_.set_src_incarnation(server_attributes.incarnation()); in RecvBufCall()
57 req_.set_dst_device(to_device->name()); in RecvBufCall()
58 req_.set_request_id(GetUniqueRequestId()); in RecvBufCall()
[all …]
|
| D | master_session.cc | 880 req_.set_step_id(step_id); in CleanupBroadcastHelper()
884 CleanupGraphRequest* request() { return &req_; } in request()
910 CleanupGraphRequest req_; member in tensorflow::__anon6bb77f8a0711::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 | 68 req_.set_step_id(step_id); in Init()
69 req_.set_rendezvous_key(key.data(), key.size()); in Init()
70 req_.set_request_id(GetUniqueRequestId()); in Init()
83 req_.Clear(); in Reset()
150 wi_->RecvTensorAsync(&opts_, &req_, &resp_, std::move(cb)); in StartRTCall()
175 RecvTensorRequest req_; member in tensorflow::__anonb800c7ed0111::RpcRecvTensorCall
|
| /external/cronet/net/url_request/ |
| D | url_request_http_job_unittest.cc | 351 req_ = context_->CreateRequest(GURL("http://www.example.com"), in URLRequestHttpJobTest()
376 std::unique_ptr<URLRequest> req_; member in net::__anonac478e770111::URLRequestHttpJobTest
1000 auto job = std::make_unique<TestURLRequestHttpJob>(req_.get()); in TEST_F()
1014 req_->url(), std::make_unique<TestURLRequestHttpJob>(req_.get())); in TEST_F()
1015 req_->SetPriority(LOW); in TEST_F()
1019 req_->Start(); in TEST_F()
1029 req_->url(), std::make_unique<TestURLRequestHttpJob>(req_.get())); in TEST_F()
1030 req_->SetPriority(LOW); in TEST_F()
1031 req_->Start(); in TEST_F()
1035 req_->SetPriority(HIGHEST); in TEST_F()
[all …]
|
| /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 | 602 req_(req), in ServerCallbackWriterImpl()
626 if (req_ != nullptr) { in ~ServerCallbackWriterImpl()
627 req_->~RequestType(); in ~ServerCallbackWriterImpl()
631 const RequestType* request() { return req_; } in request()
664 const RequestType* req_; variable
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | server_callback_handlers.h | 602 req_(req), in ServerCallbackWriterImpl()
626 if (req_ != nullptr) { in ~ServerCallbackWriterImpl()
627 req_->~RequestType(); in ~ServerCallbackWriterImpl()
631 const RequestType* request() { return req_; } in request()
664 const RequestType* req_; variable
|
| /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()
|