rrddmma 0.7.3

A Rust library for RDMA.
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

#[cfg(mlnx5)]
fn main() {
    eprintln!("cq_ex features is not yet implemented for MLNX_OFED v5.x+.");
}

#[cfg(mlnx4)]
fn main() -> anyhow::Result<()> {
    use rrddmma::{prelude::*, wrap::RegisteredMem};

    fn make_qp(dev: &str) -> anyhow::Result<Qp> {
        let Nic { context, ports } = Nic::finder().dev_name(dev).probe()?;
        let pd = Pd::new(&context)?;
        let cq = Cq::new_exp(&context, Cq::DEFAULT_CQ_DEPTH)?;
        let mut qp = Qp::builder()
            .qp_type(QpType::Rc)
            .caps(QpCaps::default())
            .send_cq(&cq)
            .recv_cq(&cq)
            .sq_sig_all(true)
            .build(&pd)?;
        qp.bind_local_port(&ports[0], None)?;
        Ok(qp)
    }

    let mut qp = make_qp("mlx5_0")?;
    let ep = qp.endpoint().unwrap();
    qp.bind_peer(ep)?;

    // Receive a message from the client.
    let mut mem0 = RegisteredMem::new(qp.pd(), 4096)?;
    let mut mem1 = RegisteredMem::new(qp.pd(), 4096)?;
    unsafe { std::ptr::write_bytes(mem0.as_mut_ptr(), 0x14, 4096) };
    unsafe { std::ptr::write_bytes(mem1.as_mut_ptr(), 0x0, 4096) };

    qp.recv(&[mem1.as_slice()], 0)?;
    qp.send(&[mem0.as_slice()], None, None, 0, true, false)?;
    qp.scq().poll_one_blocking_consumed();

    let mut wc = vec![ExpWc::default(); 1];
    while qp.rcq().exp_poll_into(&mut wc)? == 0 {}

    let ts = wc[0].timestamp();
    if let Some(ts) = ts {
        use chrono::DateTime;
        let (secs, nsecs) = (ts / 1_000_000_000, ts % 1_000_000_000);
        println!(
            "Timestamp: {:?}",
            DateTime::from_timestamp(secs as i64, nsecs as u32)
        );
    } else {
        eprintln!("Failed to get timestamp from wc!");
    }

    Ok(())
}