nfs3_server 0.11.0

A Rust NFSv3 Server implementation
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

use nfs3_types::portmap::{self, PMAP_PROG, mapping};
use nfs3_types::rpc::accept_stat_data;
use nfs3_types::xdr_codec::Void;
use tracing::{debug, error, warn};

use crate::context::RPCContext;
use crate::rpcwire::handle;
use crate::rpcwire::messages::{HandleResult, IncomingRpcMessage};
use crate::vfs::NfsFileSystem;

pub async fn handle_portmap<T>(
    context: RPCContext<T>,
    message: IncomingRpcMessage,
) -> anyhow::Result<HandleResult>
where
    T: NfsFileSystem,
{
    let call = message.body();
    if call.vers != portmap::VERSION {
        error!(
            "Invalid Portmap Version number {} != {}",
            call.vers,
            portmap::VERSION
        );
        return message.into_error_reply(accept_stat_data::PROG_MISMATCH {
            low: portmap::VERSION,
            high: portmap::VERSION,
        });
    }

    let proc = PMAP_PROG::try_from(call.proc);
    match proc {
        Ok(PMAP_PROG::PMAPPROC_NULL) => handle(context, message, pmapproc_null).await,
        Ok(PMAP_PROG::PMAPPROC_GETPORT) => handle(context, message, pmapproc_getport).await,
        _ => {
            warn!("Unimplemented message {}", call.proc);
            message.into_error_reply(accept_stat_data::PROC_UNAVAIL)
        }
    }
}

async fn pmapproc_null<T>(_: RPCContext<T>, xid: u32, _: Void) -> Void
where
    T: crate::vfs::NfsFileSystem,
{
    debug!("pmapproc_null({})", xid);
    Void
}

// We fake a portmapper here. And always direct back to the same host port
async fn pmapproc_getport<T>(context: RPCContext<T>, xid: u32, m: mapping) -> u32
where
    T: crate::vfs::NfsFileSystem,
{
    debug!("pmapproc_getport({xid}, {m:?})");
    let port = u32::from(context.local_port);
    debug!("\t{xid} --> {port}");
    port
}