/commonlibrary/rust/ylong_runtime/ylong_signal/src/ |
H A D | spin_rwlock.rs | 40 version: AtomicUsize, 56 version: Default::default(), 65 let version = self.version.load(Ordering::SeqCst) % VERSIONS; 66 let curr_count = &self.version_holder_count[version]; 75 // 1. reader loads the current version 76 // 2. writer increments the version 78 // 4. writer blocking waits until old version counter is 0 79 // 5. reader increments the old version counter 80 // 6. reader acquires the old data using the old version [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/ |
H A D | sync_utils.rs | 29 Version: $version: expr, 58 Version: $version, 82 Version: $version, 114 Version: $version: expr, 140 Version: $version, 169 Version: $version: expr, 194 assert_eq!(response.version().as_str(), $version, "Assert response version failed");
|
H A D | mod.rs | 165 Version: $version: expr, 227 let mut resp_str = String::from(format!("{} {} OK\r\n", $version, $status)); 283 $(Version: $version: expr,)? 294 $(.version($version))?
|
/commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
H A D | async_utils.rs | 32 Version: $version: expr, 52 Version: $version, 94 Version: $version, 121 Version: $version: expr, 141 Version: $version, 182 Version: $version, 216 Version: $version: expr, 246 Version: $version, 273 Version: $version: expr, 300 Version: $version, [all...] |
H A D | sync_utils.rs | 31 Version: $version: expr, 51 Version: $version, 93 Version: $version, 119 Version: $version: expr, 139 Version: $version, 180 Version: $version, 214 Version: $version: expr, 243 Version: $version, 272 Version: $version: expr, 297 Version: $version, [all...] |
H A D | mod.rs | 280 Version: $version: expr, 299 $version, 300 format!("{:?}", request.version()), 301 "Assert request version failed", 318 .version(hyper::Version::HTTP_11) 343 Version: $version: expr, 362 $version, 363 format!("{:?}", request.version()), 364 "Assert request version failed", 381 .version(hype [all...] |
/commonlibrary/rust/ylong_http/ylong_http/src/response/ |
H A D | mod.rs | 20 use crate::version::Version; 44 pub fn version(&self) -> &Version { in version() functions 45 &self.part.version in version() 89 /// protocol version. 96 pub version: Version, 112 /// UT test cases for `Response::version`. 116 /// 2. Gets the reference of a `Version` by calling `Response::version`. 127 assert_eq!(response.version().as_str(), "HTTP/1.1") in ut_response_version() 227 assert_eq!(part.version.as_str(), "HTTP/1.1"); in ut_response_into_parts() 243 assert_eq!(response.version() in ut_response_from_raw_parts() [all...] |
/commonlibrary/rust/ylong_http/ylong_http/src/request/ |
H A D | mod.rs | 29 //! use ylong_http::version::Version; 35 //! .version("HTTP/1.1") 43 //! assert_eq!(request.version(), &Version::HTTP1_1); 67 use crate::version::Version; 322 /// let version = request.version(); 324 pub fn version(&self) -> &Version { in version() functions 325 &self.part.version in version() 336 /// let version = request.version_mut(); 339 &mut self.part.version in version_mut() 565 pub fn version<T>(mut self, version: T) -> Self version() functions [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
H A D | test_utils.rs | 35 Version: $version: expr, 47 $(.version($version))? 63 Version: $version: expr, 105 let mut resp_str = String::from(format!("{} {} OK\r\n", $version, $status));
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
H A D | mod.rs | 20 mod version; modules 30 pub(crate) use version::SslVersion;
|
/commonlibrary/rust/ylong_http/ylong_http/src/h1/response/ |
H A D | decoder.rs | 22 use crate::version::Version; 31 /// use ylong_http::version::Version; 49 /// assert_eq!(part.version.as_str(), "HTTP/1.1"); 64 version: Option<Version>, 86 // | HTTP-version SP status-code SP [ reason-phrase ]CRLF | // status-line 95 // "HTTP-version" phase of parsing response-message 168 version: None, in new() 194 /// use ylong_http::version::Version; 202 /// assert_eq!(part.version, Version::HTTP1_1); 233 TokenStatus::Complete((version, unparse [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
H A D | client.rs | 229 self.http.version = HttpVersion::Http1; in http1_only() 329 /// Sets the maximum allowed TLS version for connections. 341 pub fn max_tls_version(mut self, version: crate::util::TlsVersion) -> Self { in max_tls_version() 342 self.tls = self.tls.max_proto_version(version); in max_tls_version() 346 /// Sets the minimum required TLS version for connections. 358 pub fn min_tls_version(mut self, version: crate::util::TlsVersion) -> Self { in min_tls_version() 359 self.tls = self.tls.min_proto_version(version); in min_tls_version()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
H A D | request.rs | 58 /// - The HTTP version of this `RequestBuilder` is `HTTP/1.1`. 96 /// .version("HTTP/1.1") 111 /// - The HTTP version of this `RequestBuilder` is `HTTP/1.1`. 158 /// let builder = RequestBuilder::new().version("HTTP/1.1"); 160 pub fn version(mut self, version: &str) -> Self { in version() functions 161 self.0 = self.0.version(version); in version()
|
H A D | client.rs | 332 self.http.version = HttpVersion::Http1; in http1_only() 496 let tls_builder = match self.http.version { in build() 544 self.http.version = HttpVersion::Http2; in http2_prior_knowledge() 662 self.http.version = HttpVersion::Http3; in http3_prior_knowledge() 711 /// Sets the maximum allowed TLS version for connections. 723 pub fn max_tls_version(mut self, version: crate::util::TlsVersion) -> Self { in max_tls_version() 724 self.tls = self.tls.max_proto_version(version); in max_tls_version() 728 /// Sets the minimum required TLS version for connections. 740 pub fn min_tls_version(mut self, version: crate::util::TlsVersion) -> Self { in min_tls_version() 741 self.tls = self.tls.min_proto_version(version); in min_tls_version() [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
H A D | sdv_async_http2.rs | 53 format!("{:?}", parts.version), 55 "Assert request version failed" 80 .version(hyper::Version::HTTP_2) 176 .version("HTTP/2.0") in sdv_async_h2_client_send_request() 256 .version("HTTP/2.0") in sdv_async_h2_client_send_request_concurrently()
|
H A D | sdv_async_http_proxy.rs | 90 response.version().as_str(), in sdv_async_client_send_request() 92 "Assert response version failed" in sdv_async_client_send_request()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
H A D | http1.rs | 23 use ylong_http::version::Version; 184 if part.version == Version::HTTP1_0 { in decode_response() 189 if part.version == Version::HTTP1_0 { in decode_response()
|
H A D | http2.rs | 92 version: ylong_http::version::Version::HTTP2, in frame_2_response() 395 Version: $version: expr, 405 .version($version)
|
/commonlibrary/rust/ylong_http/ylong_http/src/h1/request/ |
H A D | encoder.rs | 28 //! .version("HTTP/1.1") 70 use crate::version::Version; 86 /// .version("HTTP/1.1") 144 // "VersionCrlf" phase of encoding whitespace after version. 176 /// .version("HTTP/1.1") 191 version_part: EncodeVersion::new(part.version), in new() 228 /// .version("HTTP/1.1") 288 /// .version("HTTP/1.1") 475 fn new(version: Version) -> Self { in new() 477 inner: version, in new() [all...] |
/commonlibrary/rust/ylong_http/ylong_http/src/ |
H A D | lib.rs | 43 pub mod version; modules
|
/commonlibrary/rust/ylong_http/ylong_http/tests/ |
H A D | sdv_http_version.rs | 16 use ylong_http::version::Version; 22 /// 2. check the version.
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/ |
H A D | http.rs | 21 pub(crate) version: HttpVersion, 34 version: HttpVersion::Negotiate, 51 /// `HTTP` version to use. 65 /// Negotiate the protocol version through the ALPN.
|
/commonlibrary/rust/ylong_http/ylong_http_client/examples/ |
H A D | async_certs_adapter.rs | 26 // get version in verify() 27 let _ = certs.version().unwrap(); in verify()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
H A D | adapter.rs | 91 /// Sets the maximum supported protocol version. A value of `None` will 92 /// enable protocol versions down the highest version supported by 104 pub fn max_proto_version(mut self, version: TlsVersion) -> Self { in max_proto_version() 107 .set_max_proto_version(version.into_inner()) in max_proto_version() 113 /// Sets the minimum supported protocol version. A value of `None` will 114 /// enable protocol versions down the the lowest version supported by 126 pub fn min_proto_version(mut self, version: TlsVersion) -> Self { in min_proto_version() 129 .set_min_proto_version(version.into_inner()) in min_proto_version() 481 /// protocol version. 488 /// let version [all...] |
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
H A D | watch.rs | 28 /// The least significant bit that marks the version of channel. 59 version: 0, in channel() 146 version: value_version, in subscribe() 276 version: usize, 309 Ok(self.version != value_version) in is_notified() 314 if self.version != value_version { 315 self.version = value_version; 438 let is_notified = self.version != value_version; 476 let is_notified = self.version != value_version; 477 self.version [all...] |