rrppcc 0.4.0

A high-performance userspace RDMA RPC engine.
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

#![allow(unused_imports)]

use super::{type_alias::*, *};
use std::{
    array, ptr,
    sync::{atomic::*, *},
    thread,
};

use futures::executor::block_on;
use futures::future::join_all;
use rand::Rng;
use simple_logger::SimpleLogger;

static PORT: AtomicU16 = AtomicU16::new(31850);

#[inline]
pub(self) fn next_port() -> u16 {
    PORT.fetch_add(1, Ordering::SeqCst)
}

const NIC_NAME: &str = "mlx5_0";

mod control_plane;
mod corners;
mod large;
mod small;