nfs-rs 0.3.0

An asynchronous, pure Rust client library for NFSv3 and NFSv4.1
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

use bytes::Bytes;

use super::attrs::{decode_getattr_response, standard_getattr_bitmap};
use super::mount::{Mount41, decode_fh};
use crate::error::Result;
use crate::mount;

impl Mount41 {
    pub(crate) async fn lookup(&self, dir_fh: Bytes, filename: &str) -> Result<mount::ObjRes> {
        let bitmap = standard_getattr_bitmap();
        let resp = self
            .compound("lookup", |b| {
                b.putfh(&dir_fh).lookup(filename).getfh().getattr(&bitmap)
            })
            .await?;
        // ops: [SEQUENCE(0), PUTFH(1), LOOKUP(2), GETFH(3), GETATTR(4)]
        resp.op_ok(1)?; // PUTFH
        resp.op_ok(2)?; // LOOKUP
        let getfh = resp.op_ok(3)?;
        let mut fh_data = getfh.data.clone();
        let fh = decode_fh(&mut fh_data)?;
        let getattr = resp.op_ok(4)?;
        let mut attr_data = getattr.data.clone();
        let attr = decode_getattr_response(&mut attr_data)?;
        Ok(mount::ObjRes {
            fh,
            attr: Some(attr),
        })
    }

    pub(crate) async fn lookup_path(&self, path: &str) -> Result<mount::ObjRes> {
        let components: Vec<&str> = path.split('/').filter(|c| !c.is_empty()).collect();
        if components.is_empty() {
            return Ok(mount::ObjRes {
                fh: self.root_fh.clone(),
                attr: None,
            });
        }
        let bitmap = standard_getattr_bitmap();
        let resp = self
            .compound("lookup_path", |mut b| {
                b = b.putfh(&self.root_fh);
                for c in &components {
                    b = b.lookup(c);
                }
                b.getfh().getattr(&bitmap)
            })
            .await?;
        // ops: [SEQUENCE(0), PUTFH(1), LOOKUP*n(2..2+n-1), GETFH(2+n), GETATTR(3+n)]
        let n = components.len();
        for i in 0..n {
            resp.op_ok(2 + i)?; // each LOOKUP
        }
        let getfh = resp.op_ok(2 + n)?;
        let mut fh_data = getfh.data.clone();
        let fh = decode_fh(&mut fh_data)?;
        let getattr = resp.op_ok(3 + n)?;
        let mut attr_data = getattr.data.clone();
        let attr = decode_getattr_response(&mut attr_data)?;
        Ok(mount::ObjRes {
            fh,
            attr: Some(attr),
        })
    }
}