| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio/src/ |
| D | client.rs | 35 pub fn unary_call<Req, Resp: Unpin>( in unary_call()
37 method: &Method<Req, Resp>, in unary_call()
38 req: &Req, in unary_call()
45 pub fn unary_call_async<Req, Resp>( in unary_call_async()
47 method: &Method<Req, Resp>, in unary_call_async()
48 req: &Req, in unary_call_async()
57 pub fn client_streaming<Req, Resp>( in client_streaming()
59 method: &Method<Req, Resp>, in client_streaming()
61 ) -> Result<(ClientCStreamSender<Req>, ClientCStreamReceiver<Resp>)> { in client_streaming()
68 pub fn server_streaming<Req, Resp>( in server_streaming()
[all …]
|
| D | server.rs | 84 pub fn add_unary_handler<Req, Resp, F>( in add_unary_handler()
86 method: &Method<Req, Resp>, in add_unary_handler()
104 pub fn add_client_streaming_handler<Req, Resp, F>( in add_client_streaming_handler()
106 method: &Method<Req, Resp>, in add_client_streaming_handler()
112 F: FnMut(RpcContext<'_>, RequestStream<Req>, ClientStreamingSink<Resp>) in add_client_streaming_handler()
127 pub fn add_server_streaming_handler<Req, Resp, F>( in add_server_streaming_handler()
129 method: &Method<Req, Resp>, in add_server_streaming_handler()
147 pub fn add_duplex_streaming_handler<Req, Resp, F>( in add_duplex_streaming_handler()
149 method: &Method<Req, Resp>, in add_duplex_streaming_handler()
155 F: FnMut(RpcContext<'_>, RequestStream<Req>, DuplexSink<Resp>) + Send + Clone + 'static, in add_duplex_streaming_handler()
|
| D | channel.rs | 747 pub(crate) fn create_call<Req, Resp>( in create_call()
749 method: &Method<Req, Resp>, in create_call()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/tests/retry/ |
| D | main.rs | 93 type Req = &'static str; typedef
105 fn retry(&self, _: &Req, result: Result<&Res, &Error>) -> Option<Self::Future> { in retry()
113 fn clone_request(&self, req: &Req) -> Option<Req> { in clone_request()
123 fn retry(&self, _: &Req, result: Result<&Res, &Error>) -> Option<Self::Future> { in retry()
131 fn clone_request(&self, req: &Req) -> Option<Req> { in clone_request()
141 fn retry(&self, _: &Req, result: Result<&Res, &Error>) -> Option<Self::Future> { in retry()
151 fn clone_request(&self, req: &Req) -> Option<Req> { in clone_request()
161 fn retry(&self, _: &Req, _: Result<&Res, &Error>) -> Option<Self::Future> { in retry()
165 fn clone_request(&self, _req: &Req) -> Option<Req> { in clone_request()
170 fn new_service<P: Policy<Req, Res, Error> + Clone>( in new_service()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio/src/call/ |
| D | client.rs | 85 pub fn unary_async<Req, Resp>( in unary_async()
87 method: &Method<Req, Resp>, in unary_async()
88 req: &Req, in unary_async()
110 pub fn client_streaming<Req, Resp>( in client_streaming()
112 method: &Method<Req, Resp>, in client_streaming()
114 ) -> Result<(ClientCStreamSender<Req>, ClientCStreamReceiver<Resp>)> { in client_streaming()
134 pub fn server_streaming<Req, Resp>( in server_streaming()
136 method: &Method<Req, Resp>, in server_streaming()
137 req: &Req, in server_streaming()
169 pub fn duplex_streaming<Req, Resp>( in duplex_streaming()
[all …]
|
| D | mod.rs | 134 pub fn req_ser(&self) -> SerializeFn<Req> { in req_ser()
140 pub fn req_de(&self) -> DeserializeFn<Req> { in req_de()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tungstenite/src/ |
| D | client.rs | 45 pub fn connect_with_config<Req: IntoClientRequest>( in connect_with_config()
120 pub fn connect<Req: IntoClientRequest>( in connect()
155 request: Req, in client_with_config()
172 request: Req, in client()
|
| /aosp_15_r20/external/clang/lib/StaticAnalyzer/Checkers/MPI-Checker/ |
| H A D | MPIBugReporter.cpp | 25 const CallEvent &MPICallEvent, const ento::mpi::Request &Req, in reportDoubleNonblocking()
51 const ento::mpi::Request &Req, const MemRegion *const RequestRegion, in reportMissingWait()
95 const Request *const Req = N->getState()->get<RequestMap>(RequestRegion); in VisitNode() local
|
| H A D | MPIChecker.cpp | 41 const Request *const Req = State->get<RequestMap>(MR); in checkDoubleNonblocking() local
80 const Request *const Req = State->get<RequestMap>(ReqRegion); in checkUnmatchedWaits() local
113 for (const auto &Req : ReqMap) { in checkMissingWaits() local
|
| /aosp_15_r20/external/swiftshader/third_party/llvm-16.0/llvm/lib/FileCheck/ |
| H A D | FileCheck.cpp | 917 SourceMgr &SM, const FileCheckRequest &Req) { in parsePattern()
1687 FindCheckType(const FileCheckRequest &Req, StringRef Buffer, StringRef Prefix, in FindCheckType()
1777 FindCheckType(const FileCheckRequest &Req, StringRef Buffer, StringRef Prefix) { in FindCheckType()
1816 FindFirstMatchingPrefix(const FileCheckRequest &Req, Regex &PrefixRE, in FindFirstMatchingPrefix()
1871 FileCheck::FileCheck(FileCheckRequest Req) in FileCheck()
2080 const FileCheckRequest &Req, in printMatch()
2233 const FileCheckRequest &Req, in reportMatchResult()
2268 FileCheckRequest &Req, in Check()
2410 const FileCheckRequest &Req, in CheckNot()
2429 const FileCheckRequest &Req, in CheckDag()
|
| /aosp_15_r20/external/swiftshader/third_party/llvm-10.0/llvm/lib/Support/ |
| H A D | FileCheck.cpp | 310 SourceMgr &SM, const FileCheckRequest &Req) { in parsePattern()
1111 FileCheck::FileCheck(FileCheckRequest Req) in FileCheck()
1277 size_t MatchLen, const FileCheckRequest &Req, in PrintMatch()
1314 FileCheckRequest &Req, in PrintMatch()
1412 FileCheckRequest &Req, in Check()
1555 const FileCheckRequest &Req, in CheckNot()
1581 const FileCheckRequest &Req, in CheckDag()
|
| /aosp_15_r20/external/bouncycastle/bcpkix/src/main/java/org/bouncycastle/cert/ocsp/ |
| H A D | Req.java | 6 public class Req class
10 public Req( in Req() method in Req
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/src/retry/ |
| D | policy.rs | 61 fn retry(&self, req: &Req, result: Result<&Res, &E>) -> Option<Self::Future>; in retry()
66 fn clone_request(&self, req: &Req) -> Option<Req>; in clone_request()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/tests/ |
| D | builder.rs | 48 fn retry(&self, _req: &Req, _result: Result<&Res, &E>) -> Option<Self::Future> { in retry()
52 fn clone_request(&self, req: &Req) -> Option<Req> { in clone_request()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/tests/hedge/ |
| D | main.rs | 144 type Req = &'static str; typedef
160 fn clone_request(&self, req: &Req) -> Option<Req> { in clone_request()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/src/steer/ |
| D | mod.rs | 78 fn pick(&mut self, r: &Req, services: &[S]) -> usize; in pick()
85 fn pick(&mut self, r: &Req, services: &[S]) -> usize { in pick()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/examples/ |
| D | tower-balance.rs | 147 D::Service: Service<Req, Response = Rsp> + load::Load + Send, in run()
229 struct Req; struct
|
| /aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/service/ |
| D | oneshot.rs | 12 S: Service<Req>, in oneshot()
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/net/http/ |
| D | readrequest_test.go | 20 Req *Request member
|
| D | requestwrite_test.go | 22 Req Request member
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/tests/balance/ |
| D | main.rs | 13 type Req = &'static str; typedef
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/net/http/httputil/ |
| D | dump_test.go | 31 Req *http.Request member
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/cmd/go/internal/mvs/ |
| D | mvs.go | 187 func Req(mainModule module.Version, base []string, reqs Reqs) ([]module.Version, error) { func
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/tests/ready_cache/ |
| D | main.rs | 10 type Req = &'static str; typedef
|
| /aosp_15_r20/external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/ |
| H A D | FileCheck.h | 141 FileCheckRequest Req; variable
|