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

use crate::handler::ReqHandlerFuture;
use crate::type_alias::*;

/// Pending RPC request handler.
pub(super) struct PendingHandler {
    /// Session ID.
    pub sess_id: SessId,

    /// Slot ID.
    pub sslot_idx: usize,

    /// Request handler body.
    pub handler: ReqHandlerFuture,
}

impl PendingHandler {
    /// Create a new pending handler.
    #[inline]
    pub fn new(sess_id: SessId, sslot_idx: usize, handler: ReqHandlerFuture) -> Self {
        Self {
            sess_id,
            sslot_idx,
            handler,
        }
    }
}