| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ffi/ |
| D | ssl.rs | 32 pub(crate) fn SSL_CTX_free(ctx: *mut SSL_CTX); in SSL_CTX_free()
40 ctx: *mut SSL_CTX, in SSL_CTX_ctrl()
48 ctx: *mut SSL_CTX, in SSL_CTX_load_verify_locations()
59 pub(crate) fn SSL_CTX_set_ciphersuites(ctx: *mut SSL_CTX, str: *const c_char) -> c_int; in SSL_CTX_set_ciphersuites()
65 ctx: *mut SSL_CTX, in SSL_CTX_use_certificate_file()
76 ctx: *mut SSL_CTX, in SSL_CTX_use_certificate_chain_file()
90 pub(crate) fn SSL_CTX_set_cert_store(ctx: *mut SSL_CTX, store: *mut X509_STORE); in SSL_CTX_set_cert_store()
93 pub(crate) fn SSL_CTX_get_cert_store(ctx: *const SSL_CTX) -> *mut X509_STORE; in SSL_CTX_get_cert_store()
104 pub(crate) fn SSL_CTX_set_default_verify_paths(ctx: *mut SSL_CTX) -> c_int; in SSL_CTX_set_default_verify_paths()
111 ctx: *mut SSL_CTX, in SSL_CTX_set_verify()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| D | mix.rs | 52 ctx: &mut Context<'_>, in poll_write()
56 MixStream::Http(s) => Pin::new(s).poll_write(ctx, buf), in poll_write()
57 MixStream::Https(s) => Pin::new(s).poll_write(ctx, buf), in poll_write()
61 fn poll_flush(mut self: Pin<&mut Self>, ctx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
63 MixStream::Http(s) => Pin::new(s).poll_flush(ctx), in poll_flush()
64 MixStream::Https(s) => Pin::new(s).poll_flush(ctx), in poll_flush()
68 fn poll_shutdown(mut self: Pin<&mut Self>, ctx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_shutdown()
70 MixStream::Http(s) => Pin::new(s).poll_shutdown(ctx), in poll_shutdown()
71 MixStream::Https(s) => Pin::new(s).poll_shutdown(ctx), in poll_shutdown()
|
| D | c_ssl_stream.rs | 29 fn with_context<F, R>(self: Pin<&mut Self>, ctx: &mut Context<'_>, f: F) -> R in with_context()
38 this.0.get_mut().context = ctx as *mut _ as *mut (); in with_context()
86 ctx: &mut Context<'_>, in poll_read()
90 self.with_context(ctx, |s| { in poll_read()
117 fn poll_write(self: Pin<&mut Self>, ctx: &mut Context, buf: &[u8]) -> Poll<io::Result<usize>> { in poll_write()
118 self.with_context(ctx, |s| check_io_to_poll(s.write(buf))) in poll_write()
121 fn poll_flush(self: Pin<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_flush()
122 self.with_context(ctx, |s| check_io_to_poll(s.flush())) in poll_flush()
125 fn poll_shutdown(mut self: Pin<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_shutdown()
127 match self.as_mut().with_context(ctx, |s| s.shutdown()) { in poll_shutdown()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | yield_now.rs | 49 let ctx = worker::get_current_ctx(); in poll() localVariable
55 if let Some(ctx) = ctx { in poll()
56 let mut yielded = ctx.worker.yielded.borrow_mut(); in poll()
|
| D | join_set.rs | 306 let mut ctx = Context::from_waker(&waker); in poll_join_next() localVariable
313 match Pin::new(&mut **(entry.handle.get())).poll(&mut ctx) { in poll_join_next()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | worker.rs | 55 CURRENT_HANDLE.with(|ctx| { in get_current_handle()
56 let val = ctx.get(); in get_current_handle()
68 CURRENT_WORKER.with(|ctx| { in get_current_ctx()
69 let val = ctx.get(); in get_current_ctx()
88 CURRENT_WORKER.with(|ctx| ctx.set(self.0)); in run_worker()
|
| D | mod.rs | 284 worker::CURRENT_HANDLE.with(|ctx| { in block_on()
285 ctx.set(&cur_context as *const _ as *const ()); in block_on()
300 worker::CURRENT_HANDLE.with(|ctx| { in block_on()
301 ctx.set(std::ptr::null()); in block_on()
|
| D | current_thread.rs | 410 crate::executor::worker::CURRENT_WORKER.with(|ctx| { in ut_current_thread_run_queue()
411 ctx.set(std::ptr::null()); in ut_current_thread_run_queue()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
| D | mod.rs | 14 mod ctx; module
22 pub(crate) use ctx::{SslContext, SslContextBuilder, SSL_VERIFY_NONE, SSL_VERIFY_PEER};
|
| D | ssl_base.rs | 46 pub(crate) fn new(ctx: &SslContext) -> Result<Ssl, ErrorStack> { in new()
48 let ptr = check_ptr(SSL_new(ctx.as_ptr()))?; in new()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| D | adapter.rs | 367 let ctx = self in build() localVariable
373 ctx, in build()
398 ctx: SslContext, field
419 let ctx = &self.ctx; in ssl_new() localVariable
420 let mut ssl = Ssl::new(ctx)?; in ssl_new()
|