mpstthree 0.1.17

A library implementing Multiparty Session Types for 2 or more participants
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

//! This module contains the functions and macros
//! for sending
//! a choice for binary sessions.

use crate::binary::cancel::cancel;
use crate::binary::struct_trait::{end::End, session::Session};
use crate::binary_atmp::send::send;
use crate::binary_atmp::struct_trait::send::SendTimed;

use either::Either;

use std::collections::HashMap;
use std::error::Error;
use std::time::Instant;

/// Choose between two sessions `S1` and `S2`. Implemented
/// using `Send` and `Either`.
pub type ChooseTimed<
    S1,
    S2,
    const CLOCK: char,
    const START: i128,
    const INCLUDE_START: bool,
    const END: i128,
    const INCLUDE_END: bool,
    const RESET: char,
> = SendTimed<
    Either<<S1 as Session>::Dual, <S2 as Session>::Dual>,
    CLOCK,
    START,
    INCLUDE_START,
    END,
    INCLUDE_END,
    RESET,
    End,
>;

/// Given a choice between sessions `S1` and `S1`, choose
/// the first option.
pub fn choose_left<
    'a,
    S1,
    S2,
    const CLOCK: char,
    const START: i128,
    const INCLUDE_START: bool,
    const END: i128,
    const INCLUDE_END: bool,
    const RESET: char,
>(
    all_clocks: &mut HashMap<char, Instant>,
    s: ChooseTimed<S1, S2, CLOCK, START, INCLUDE_START, END, INCLUDE_END, RESET>,
) -> Result<S1, Box<dyn Error>>
where
    S1: Session + 'a,
    S2: Session + 'a,
{
    let (here, there) = S1::new();
    let s = send(Either::Left(there), all_clocks, s)?;
    cancel(s);
    Ok(here)
}

/// Given a choice between sessions `S1` and `S1`, choose
/// the second option.
pub fn choose_right<
    'a,
    S1,
    S2,
    const CLOCK: char,
    const START: i128,
    const INCLUDE_START: bool,
    const END: i128,
    const INCLUDE_END: bool,
    const RESET: char,
>(
    all_clocks: &mut HashMap<char, Instant>,
    s: ChooseTimed<S1, S2, CLOCK, START, INCLUDE_START, END, INCLUDE_END, RESET>,
) -> Result<S2, Box<dyn Error>>
where
    S1: Session + 'a,
    S2: Session + 'a,
{
    let (here, there) = S2::new();
    let s = send(Either::Right(there), all_clocks, s)?;
    cancel(s);
    Ok(here)
}

/// Choose between many different sessions wrapped in an
/// `enum`
#[macro_export]
macro_rules! choose_atmp {
    ($label:path, $all_clocks:expr, $session:expr) => {{
        let (here, there) = <_ as mpstthree::binary::struct_trait::session::Session>::new();
        let s = mpstthree::binary_atmp::send_atmp::send($label(there), $all_clocks, $session);
        mpstthree::binary::cancel::cancel(s);
        here
    }};
}