Searched refs:run_blocking (Results 1 – 4 of 4) sorted by relevance
473 f.run_blocking(|f| f.metadata()).await in get_metadata()477 d.run_blocking(|d| d.dir_metadata()).await in get_metadata()485 match f.run_blocking(|f| f.sync_data()).await { in sync_data()501 d.run_blocking(|d| { in sync_data()590 match f.run_blocking(|f| f.sync_all()).await { in sync()606 d.run_blocking(|d| { in sync()709 pub(crate) async fn run_blocking<F, R>(&self, body: F) -> R in run_blocking() method762 self.run_blocking(move |f| f.set_len(size)).await?; in set_size()881 self.run_blocking(move |d| { in set_times_at()890 self.run_blocking(move |d| { in set_times_at()[all …]
674 f.run_blocking(move |f| do_write(f, &buf)).await in fd_write_impl()1703 .run_blocking(move |file| -> Result<_, types::Error> { in fd_read()
158 .run_blocking(move |f| Self::blocking_read(f, p, size)) in blocking_read()321 .run_blocking(move |f| Self::blocking_write(f, buf, m)) in blocking_write_and_flush()
117 .run_blocking(move |f| { in read()154 .run_blocking(move |f| f.write_vectored_at(&[IoSlice::new(&buf)], offset)) in write()180 .run_blocking(|d| { in read_directory()