| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | pool.rs | 28 use crate::util::dispatcher::{Conn, ConnDispatcher, Dispatcher};
46 pub(crate) async fn connect_to(&self, uri: &Uri) -> Result<Conn<C::Stream>, HttpClientError> { in connect_to()
93 ) -> Result<Conn<S>, HttpClientError> in conn()
114 async fn conn_h1<C>(&self, connector: Arc<C>, url: &Uri) -> Result<Conn<S>, HttpClientError> in conn_h1()
131 ) -> Result<Conn<S>, HttpClientError> in conn_h2()
167 ) -> Result<Conn<S>, HttpClientError> in conn_negotiate()
206 fn dispatch_h1_conn(&self, dispatcher: ConnDispatcher<S>) -> Conn<S> { in dispatch_h1_conn()
220 ) -> Conn<S> { in dispatch_h2_conn()
227 fn exist_h1_conn(&self) -> Option<Conn<S>> { in exist_h1_conn()
248 ) -> Option<Conn<S>> { in exist_h2_conn()
|
| H A D | client.rs | 33 use crate::util::dispatcher::Conn;
192 async fn connect_to(&self, uri: &Uri) -> Result<Conn<C::Stream>, HttpClientError> { in connect_to()
206 conn: Conn<C::Stream>, in send_request_on_conn()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/conn/ |
| H A D | mod.rs | 19 use crate::util::dispatcher::Conn;
29 conn: Conn<S>, in request()
38 Conn::Http1(http1) => http1::request(http1, request), in request()
41 Conn::Http2(_) => todo!(), in request()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | mod.rs | 25 use crate::util::dispatcher::Conn;
34 pub(crate) async fn request<S>(conn: Conn<S>, message: Message) -> Result<Response, HttpClientError> in request()
40 Conn::Http1(http1) => http1::request(http1, message).await, in request()
43 Conn::Http2(http2) => http2::request(http2, message).await, in request()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | pool.rs | 23 use crate::util::dispatcher::{Conn, ConnDispatcher, Dispatcher};
39 pub(crate) fn connect_to(&self, uri: Uri) -> Result<Conn<C::Stream>, HttpClientError> { in connect_to()
72 fn conn<F, E>(&self, connect_fn: F) -> Result<Conn<S>, HttpClientError> in conn()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | sqlite_shared_result_set.h | 38 using Conn = std::shared_ptr<Connection>; variable
40 …SqliteSharedResultSet(Time start, Conn conn, std::string sql, const Values &args, const std::strin…
|
| H A D | step_result_set.h | 34 using Conn = std::shared_ptr<Connection>; variable
36 …StepResultSet(Time start, Conn conn, const std::string &sql, const Values &args, bool preCount, bo…
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | connection_pool.cpp | 38 using Conn = Connection; typedef
219 std::shared_ptr<Conn> ConnPool::AcquireConnection(bool isReadOnly) in AcquireConnection()
265 std::shared_ptr<Conn> ConnPool::Acquire(bool isReadOnly, std::chrono::milliseconds ms) in Acquire()
466 std::pair<int, std::shared_ptr<Conn>> ConnPool::DisableWal() in DisableWal()
484 ConnPool::ConnNode::ConnNode(std::shared_ptr<Conn> conn) : connect_(std::move(conn)) in ConnNode()
488 std::shared_ptr<Conn> ConnPool::ConnNode::GetConnect() in GetConnect()
|
| H A D | sqlite_shared_result_set.cpp | 41 SqliteSharedResultSet::SqliteSharedResultSet(Time start, Conn conn, std::string sql, const Values &… in SqliteSharedResultSet()
|
| H A D | step_result_set.cpp | 34 StepResultSet::StepResultSet(Time start, Conn conn, const std::string &sql, const Values &args, in StepResultSet()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 31 type Handle = Conn<S>;
36 Self::Http1(h1) => h1.dispatch().map(Conn::Http1), in dispatch()
39 Self::Http2(h2) => h2.dispatch().map(Conn::Http2), in dispatch()
54 pub(crate) enum Conn<S> { enum
|
| /ohos5.0/foundation/communication/dsoftbus/ |
| H A D | CODEOWNERS | 27 [Conn]
|