Home
last modified time | relevance | path

Searched refs:poll_write_vectored (Results 1 – 20 of 20) sorted by relevance

/external/rust/crates/tokio/src/io/
Dasync_write.rs154 fn poll_write_vectored( in poll_write_vectored() method
191 fn poll_write_vectored(
196 Pin::new(&mut **self).poll_write_vectored(cx, bufs)
234 fn poll_write_vectored( in poll_write_vectored() function
239 self.get_mut().as_mut().poll_write_vectored(cx, bufs) in poll_write_vectored()
265 fn poll_write_vectored( in poll_write_vectored() method
295 fn poll_write_vectored( in poll_write_vectored() method
325 fn poll_write_vectored( in poll_write_vectored() method
355 fn poll_write_vectored( in poll_write_vectored() method
385 fn poll_write_vectored( in poll_write_vectored() method
Dpoll_evented.rs181 pub(crate) fn poll_write_vectored<'a>(
/external/rust/crates/futures-util/src/io/
Dwrite_all_vectored.rs33 let n = ready!(Pin::new(&mut this.writer).poll_write_vectored(cx, this.bufs))?; in poll()
79 self.poll_write_vectored(cx, &[IoSlice::new(buf)]) in poll_write()
82 fn poll_write_vectored( in poll_write_vectored() method
130 assert_poll_ok!(dst.as_mut().poll_write_vectored(&mut cx, &[]), 0); in test_writer_read_from_one_buf()
135 assert_poll_ok!(dst.as_mut().poll_write_vectored(&mut cx, bufs), 2); in test_writer_read_from_one_buf()
139 assert_poll_ok!(dst.as_mut().poll_write_vectored(&mut cx, bufs), 1); in test_writer_read_from_one_buf()
154 assert_poll_ok!(dst.as_mut().poll_write_vectored(&mut cx, bufs), 3); in test_writer_read_from_multiple_bufs()
162 assert_poll_ok!(dst.as_mut().poll_write_vectored(&mut cx, bufs), 3); in test_writer_read_from_multiple_bufs()
Dbuf_writer.rs108 fn poll_write_vectored( in poll_write_vectored() method
118 self.project().inner.poll_write_vectored(cx, bufs) in poll_write_vectored()
Dsplit.rs78 fn poll_write_vectored(self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>]) in poll_write_vectored() method
81 lock_and_then(&self.handle, cx, |l, cx| l.poll_write_vectored(cx, bufs)) in poll_write_vectored()
Dwrite_vectored.rs28 Pin::new(&mut this.writer).poll_write_vectored(cx, this.bufs) in poll()
Dsink.rs45 fn poll_write_vectored( in poll_write_vectored() method
Dcursor.rs208 fn poll_write_vectored(mut self: Pin<&mut Self>, _: &mut Context<'_>, bufs: &[IoSlice<'_>])
Dallow_std.rs88 fn poll_write_vectored(mut self: Pin<&mut Self>, _: &mut Context<'_>, bufs: &[IoSlice<'_>]) in poll_write_vectored() function
/external/rust/crates/futures-io/src/
Dlib.rs178 fn poll_write_vectored(self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>]) in poll_write_vectored() method
401 … fn poll_write_vectored(mut self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>])
404 Pin::new(&mut **self).poll_write_vectored(cx, bufs)
436 fn poll_write_vectored(self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>]) in poll_write_vectored() function
439 self.get_mut().as_mut().poll_write_vectored(cx, bufs) in poll_write_vectored()
459 … fn poll_write_vectored(mut self: Pin<&mut Self>, _: &mut Context<'_>, bufs: &[IoSlice<'_>])
/external/rust/crates/futures/tests/
Dio_write.rs55 let res = Pin::new(&mut writer).poll_write_vectored(cx, bufs); in write_vectored_no_buffers()
83 let res = Pin::new(&mut writer).poll_write_vectored(cx, bufs); in write_vectored_first_non_empty()
/external/rust/crates/futures-util/src/future/
Deither.rs228 fn poll_write_vectored( in poll_write_vectored() function
234 Either::Left(x) => x.poll_write_vectored(cx, bufs), in poll_write_vectored()
235 Either::Right(x) => x.poll_write_vectored(cx, bufs), in poll_write_vectored()
/external/rust/crates/tokio/src/io/util/
Dwrite_vectored.rs45 Pin::new(&mut *me.writer).poll_write_vectored(cx, me.bufs) in poll()
/external/rust/crates/tokio/src/net/unix/
Dsplit.rs69 fn poll_write_vectored( in poll_write_vectored() method
Dstream.rs664 fn poll_write_vectored( in poll_write_vectored() method
720 self.io.poll_write_vectored(cx, bufs) in poll_write_vectored_priv()
Dsplit_owned.rs153 fn poll_write_vectored( in poll_write_vectored() method
/external/rust/crates/tokio/src/net/tcp/
Dsplit.rs158 fn poll_write_vectored( in poll_write_vectored() method
Dstream.rs1037 self.io.poll_write_vectored(cx, bufs) in poll_write_vectored_priv()
1074 fn poll_write_vectored( in poll_write_vectored() method
Dsplit_owned.rs240 fn poll_write_vectored( in poll_write_vectored() method
/external/rust/crates/futures-util/src/
Dlib.rs132 fn poll_write_vectored(
137 self.project().$field.poll_write_vectored(cx, bufs)