Searched refs:read_waker (Results 1 – 4 of 4) sorted by relevance
72 read_waker: Option<Waker>, field160 read_waker: None, in new()168 if let Some(waker) = self.read_waker.take() { in close_write()201 self.read_waker = Some(cx.waker().clone()); in poll_read_internal()222 if let Some(waker) = self.read_waker.take() { in poll_write_internal()
77 if(data->hyp.read_waker) in Curl_hyper_recv()78 hyper_waker_free(data->hyp.read_waker); in Curl_hyper_recv()79 data->hyp.read_waker = hyper_context_waker(ctx); in Curl_hyper_recv()80 if(!data->hyp.read_waker) { in Curl_hyper_recv()367 if(h->read_waker) in Curl_hyper_stream()368 hyper_waker_wake(h->read_waker); in Curl_hyper_stream()369 h->read_waker = NULL; in Curl_hyper_stream()1236 if(h->read_waker) { in Curl_hyper_done()1237 hyper_waker_free(h->read_waker); in Curl_hyper_done()1238 h->read_waker = NULL; in Curl_hyper_done()
35 hyper_waker *read_waker; member
938 if(h->read_waker) { in recv_CONNECT_resp()939 hyper_waker_free(h->read_waker); in recv_CONNECT_resp()940 h->read_waker = NULL; in recv_CONNECT_resp()