Searched refs:S (Results 1 – 25 of 296) sorted by relevance
12345678910>>...12
193 impl<T, S> Inner<T, S>196 S: Schedule,292 S: Schedule, in get_result()302 S: Schedule, in drop_ref()311 S: Schedule, in set_waker()321 S: Schedule, in drop_join_handle()331 S: Schedule,341 S: Schedule,354 S: Schedule,437 impl<T, S> TaskMngInfo<T, S>[all …]
31 task: NonNull<TaskMngInfo<T, S>>,34 impl<T, S> TaskHandle<T, S>37 S: Schedule,41 task: ptr.cast::<TaskMngInfo<T, S>>(), in from_raw()49 fn inner(&self) -> &Inner<T, S> { in inner() argument54 impl<T, S> TaskHandle<T, S>57 S: Schedule,166 impl<T, S> TaskHandle<T, S>169 S: Schedule,270 impl<T, S> TaskHandle<T, S>[all …]
97 pub(crate) fn create_task<T, S>( in create_task()99 scheduler: Weak<S>, in create_task() argument106 S: Schedule, in create_task()108 let raw = Task::create_raw_task::<T, S>(builder, scheduler, task, virtual_table_type); in create_task()114 pub(crate) fn create_raw_task<T, S>( in create_raw_task()116 scheduler: Weak<S>, in create_raw_task() argument122 S: Schedule, in create_raw_task()124 let ptr = Box::into_raw(TaskMngInfo::<T, S>::new( in create_raw_task()
128 pub(crate) struct StreamState<S> {129 pub(crate) stream: S,134 unsafe fn get_state<'a, S: 'a>(bio: *mut BIO) -> &'a mut StreamState<S> { in get_state() argument139 let state = get_state::<S>(bio); in get_error()144 let state = get_state::<S>(bio); in get_panic()148 pub(crate) unsafe fn get_stream_ref<'a, S: 'a>(bio: *mut BIO) -> &'a S { in get_stream_ref() argument149 let state: &'a StreamState<S> = &*(BIO_get_data(bio) as *const StreamState<S>); in get_stream_ref()153 pub(crate) unsafe fn get_stream_mut<'a, S: 'a>(bio: *mut BIO) -> &'a mut S { in get_stream_mut() argument157 pub(crate) fn new<S: Read + Write>(stream: S) -> Result<(*mut BIO, BioMethod), ErrorStack> { in new()183 unsafe extern "C" fn ctrl<S: Write>( in ctrl()[all …]
30 impl<S> Dispatcher for ConnDispatcher<S> {70 impl<S> ConnDispatcher<S> {92 unsafe impl<S> Sync for Inner<S> {}94 impl<S> Http1Dispatcher<S> {106 impl<S> Dispatcher for Http1Dispatcher<S> {129 impl<S> Http1Conn<S> {141 impl<S> Drop for Http1Conn<S> {272 impl<S> ConnDispatcher<S>281 impl<S> Http2Dispatcher<S>385 impl<S> Drop for Http2Dispatcher<S> {[all …]
31 pub(crate) struct ConnPool<C, S> {32 pool: Pool<PoolKey, Conns<S>>,59 pub(crate) struct Conns<S> {65 impl<S> Conns<S> {76 impl<S> Clone for Conns<S> {87 impl<S: AsyncRead + AsyncWrite + ConnInfo + Unpin + Send + Sync + 'static> Conns<S> {95 C: Connector<Stream = S>, in conn()206 fn dispatch_h1_conn(&self, dispatcher: ConnDispatcher<S>) -> Conn<S> { in dispatch_h1_conn() argument218 stream: S, in dispatch_h2_conn() argument220 ) -> Conn<S> { in dispatch_h2_conn() argument[all …]
22 pub(crate) struct Wrapper<S> {23 pub(crate) stream: S,28 impl<S> Wrapper<S> {34 unsafe fn inner(&mut self) -> (Pin<&mut S>, &mut Context<'_>) { in inner() argument42 impl<S> Read for Wrapper<S>44 S: AsyncRead,56 impl<S> Write for Wrapper<S>58 S: AsyncWrite,78 unsafe impl<S: Send> Send for Wrapper<S> {}79 unsafe impl<S: Sync> Sync for Wrapper<S> {}
26 pub struct AsyncSslStream<S>(ssl::SslStream<Wrapper<S>>);28 impl<S> AsyncSslStream<S> {31 F: FnOnce(&mut ssl::SslStream<Wrapper<S>>) -> R, in with_context()45 fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut S> { in get_pin_mut() argument55 impl<S> AsyncSslStream<S>57 S: AsyncRead + AsyncWrite,62 stream: S, in new() argument88 impl<S> AsyncRead for AsyncSslStream<S>90 S: AsyncRead + AsyncWrite,122 impl<S> AsyncWrite for AsyncSslStream<S>[all …]
37 pub struct SslStream<S> {41 p: PhantomData<S>,44 impl<S> SslStream<S> {98 impl<S> fmt::Debug for SslStream<S>100 S: fmt::Debug,107 impl<S> Drop for SslStream<S> {116 impl<S: Read + Write> SslStream<S> {143 stream: S, in new_base() argument185 impl<S: Read + Write> Read for SslStream<S> {213 impl<S: Read + Write> Write for SslStream<S> {[all …]
37 pub(crate) async fn request<S>( in request()38 mut conn: Http1Conn<S>, in request() argument94 conn: &mut Http1Conn<S>, in encode_various_body() argument138 conn: &mut Http1Conn<S>, in encode_request_part() argument169 fn decode_response<S>( in decode_response()172 conn: Http1Conn<S>, in decode_response() argument223 async fn encode_body<S, T>( in encode_body() argument224 conn: &mut Http1Conn<S>, in encode_body() argument253 fn read_body_result<S, T>( in read_body_result() argument280 impl<S: AsyncRead + Unpin> AsyncRead for Http1Conn<S> {[all …]
40 pub(crate) async fn request<S>( in request()41 mut conn: Http2Conn<S>, in request() argument65 fn frame_2_response<S>( in frame_2_response()66 conn: Http2Conn<S>, in frame_2_response() argument197 struct TextIo<S> {226 impl<S> TextIo<S>241 text_io: &mut TextIo<S>, in match_channel_message() argument287 text_io: &mut TextIo<S>, in end_read() argument305 text_io: &mut TextIo<S>, in read_remaining_data() argument337 impl<S: Sync + Send + Unpin + 'static> StreamData for TextIo<S> {[all …]
26 pub(crate) struct ConnPool<C, S> {27 pool: Pool<PoolKey, Conns<S>>,51 pub(crate) struct Conns<S> {52 list: Arc<Mutex<Vec<ConnDispatcher<S>>>>,55 impl<S> Conns<S> {63 impl<S> Clone for Conns<S> {71 impl<S: Read + Write + 'static> Conns<S> {72 fn conn<F, E>(&self, connect_fn: F) -> Result<Conn<S>, HttpClientError> in conn() argument74 F: FnOnce() -> Result<S, E>, in conn() argument
Error! Your browser does not support the video tag. There was an error! Java heap space java.lang.OutOfMemoryError: Java heap space
Java heap space
java.lang.OutOfMemoryError: Java heap space