Line data    Source code

       1              : //! Enum-dispatch to the `OpenOptions` type of the respective [`super::IoEngineKind`];
       2              : 
       3              : use super::io_engine::IoEngine;
       4              : use std::{os::fd::OwnedFd, path::Path};
       5              : 
       6              : #[derive(Debug, Clone)]
       7              : pub enum OpenOptions {
       8              :     StdFs(std::fs::OpenOptions),
       9              :     #[cfg(target_os = "linux")]
      10              :     TokioEpollUring(tokio_epoll_uring::ops::open_at::OpenOptions),
      11              : }
      12              : 
      13              : impl Default for OpenOptions {
      14         5687 :     fn default() -> Self {
      15         5687 :         match super::io_engine::get() {
      16            0 :             IoEngine::NotSet => panic!("io engine not set"),
      17         2840 :             IoEngine::StdFs => Self::StdFs(std::fs::OpenOptions::new()),
      18              :             #[cfg(target_os = "linux")]
      19              :             IoEngine::TokioEpollUring => {
      20         2847 :                 Self::TokioEpollUring(tokio_epoll_uring::ops::open_at::OpenOptions::new())
      21              :             }
      22              :         }
      23         5687 :     }
      24              : }
      25              : 
      26              : impl OpenOptions {
      27         5687 :     pub fn new() -> OpenOptions {
      28         5687 :         Self::default()
      29         5687 :     }
      30              : 
      31         4104 :     pub fn read(&mut self, read: bool) -> &mut OpenOptions {
      32         4104 :         match self {
      33         2051 :             OpenOptions::StdFs(x) => {
      34         2051 :                 let _ = x.read(read);
      35         2051 :             }
      36              :             #[cfg(target_os = "linux")]
      37         2053 :             OpenOptions::TokioEpollUring(x) => {
      38         2053 :                 let _ = x.read(read);
      39         2053 :             }
      40              :         }
      41         4104 :         self
      42         4104 :     }
      43              : 
      44         2828 :     pub fn write(&mut self, write: bool) -> &mut OpenOptions {
      45         2828 :         match self {
      46         1411 :             OpenOptions::StdFs(x) => {
      47         1411 :                 let _ = x.write(write);
      48         1411 :             }
      49              :             #[cfg(target_os = "linux")]
      50         1417 :             OpenOptions::TokioEpollUring(x) => {
      51         1417 :                 let _ = x.write(write);
      52         1417 :             }
      53              :         }
      54         2828 :         self
      55         2828 :     }
      56              : 
      57         8075 :     pub fn create(&mut self, create: bool) -> &mut OpenOptions {
      58         8075 :         match self {
      59         4032 :             OpenOptions::StdFs(x) => {
      60         4032 :                 let _ = x.create(create);
      61         4032 :             }
      62              :             #[cfg(target_os = "linux")]
      63         4043 :             OpenOptions::TokioEpollUring(x) => {
      64         4043 :                 let _ = x.create(create);
      65         4043 :             }
      66              :         }
      67         8075 :         self
      68         8075 :     }
      69              : 
      70         5715 :     pub fn create_new(&mut self, create_new: bool) -> &mut OpenOptions {
      71         5715 :         match self {
      72         2853 :             OpenOptions::StdFs(x) => {
      73         2853 :                 let _ = x.create_new(create_new);
      74         2853 :             }
      75              :             #[cfg(target_os = "linux")]
      76         2862 :             OpenOptions::TokioEpollUring(x) => {
      77         2862 :                 let _ = x.create_new(create_new);
      78         2862 :             }
      79              :         }
      80         5715 :         self
      81         5715 :     }
      82              : 
      83         6834 :     pub fn truncate(&mut self, truncate: bool) -> &mut OpenOptions {
      84         6834 :         match self {
      85         3412 :             OpenOptions::StdFs(x) => {
      86         3412 :                 let _ = x.truncate(truncate);
      87         3412 :             }
      88              :             #[cfg(target_os = "linux")]
      89         3422 :             OpenOptions::TokioEpollUring(x) => {
      90         3422 :                 let _ = x.truncate(truncate);
      91         3422 :             }
      92              :         }
      93         6834 :         self
      94         6834 :     }
      95              : 
      96       195118 :     pub(in crate::virtual_file) async fn open(&self, path: &Path) -> std::io::Result<OwnedFd> {
      97       195118 :         match self {
      98       100491 :             OpenOptions::StdFs(x) => x.open(path).map(|file| file.into()),
      99              :             #[cfg(target_os = "linux")]
     100        94627 :             OpenOptions::TokioEpollUring(x) => {
     101        94627 :                 let system = super::io_engine::tokio_epoll_uring_ext::thread_local_system().await;
     102        94628 :                 system.open(path, x).await.map_err(|e| match e {
     103            0 :                     tokio_epoll_uring::Error::Op(e) => e,
     104            0 :                     tokio_epoll_uring::Error::System(system) => {
     105            0 :                         std::io::Error::new(std::io::ErrorKind::Other, system)
     106              :                     }
     107        94627 :                 })
     108              :             }
     109              :         }
     110       195118 :     }
     111              : }
     112              : 
     113              : impl std::os::unix::prelude::OpenOptionsExt for OpenOptions {
     114            0 :     fn mode(&mut self, mode: u32) -> &mut OpenOptions {
     115            0 :         match self {
     116            0 :             OpenOptions::StdFs(x) => {
     117            0 :                 let _ = x.mode(mode);
     118            0 :             }
     119              :             #[cfg(target_os = "linux")]
     120            0 :             OpenOptions::TokioEpollUring(x) => {
     121            0 :                 let _ = x.mode(mode);
     122            0 :             }
     123              :         }
     124            0 :         self
     125            0 :     }
     126              : 
     127            0 :     fn custom_flags(&mut self, flags: i32) -> &mut OpenOptions {
     128            0 :         match self {
     129            0 :             OpenOptions::StdFs(x) => {
     130            0 :                 let _ = x.custom_flags(flags);
     131            0 :             }
     132              :             #[cfg(target_os = "linux")]
     133            0 :             OpenOptions::TokioEpollUring(x) => {
     134            0 :                 let _ = x.custom_flags(flags);
     135            0 :             }
     136              :         }
     137            0 :         self
     138            0 :     }
     139              : }