i2o2 0.5.0

A io_uring based IO executor for sync and async runtimes
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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147

use fail::FailScenario;

use crate::I2o2Builder;

#[rstest::rstest]
#[case::default(crate::builder())]
#[case::with_io_polling(
    crate::builder()
        .with_io_polling(true)
)]
#[case::with_io_polling_off(
    crate::builder()
        .with_io_polling(false)
)]
#[case::with_queue_size(
    crate::builder()
        .with_queue_size(64)
)]
#[case::with_ring_depth(
    crate::builder()
        .with_ring_depth(64)
)]
#[case::with_register_buffers(
    crate::builder()
        .with_num_registered_buffers(64)
)]
#[case::with_register_files(
    crate::builder()
        .with_num_registered_files(64)
)]
// -- Begin size 128 tests
#[case::default_size128(
    crate::builder()
        .with_sqe_size128(true)
)]
#[case::with_size128_io_polling(
    crate::builder()
        .with_sqe_size128(true)
        .with_io_polling(true)
)]
#[case::with_size128_io_polling_off(
    crate::builder()
        .with_sqe_size128(true)
        .with_io_polling(false)
)]
#[case::with_size128_queue_size(
    crate::builder()
        .with_sqe_size128(true)
        .with_queue_size(64)
)]
#[case::with_size128_register_buffers(
    crate::builder()
        .with_sqe_size128(true)
        .with_num_registered_buffers(64)
)]
#[case::with_size128_register_files(
    crate::builder()
        .with_sqe_size128(true)
        .with_num_registered_files(64)
)]
#[case::with_size128_register_files(
    crate::builder()
        .skip_unsupported_features(true)
)]
fn test_scheduler_creation(#[case] builder: I2o2Builder) {
    let (_scheduler, _handle) = builder
        .try_create::<()>()
        .expect("builder should be produce valid scheduler");
}

#[rstest::rstest]
#[should_panic]
#[case::failpoint_kernel_v5_13_default(crate::builder())]
#[case::failpoint_kernel_v5_15_default(crate::builder())]
#[case::failpoint_kernel_v5_19_default(crate::builder())]
#[case::failpoint_kernel_v6_0_default(crate::builder())]
#[case::failpoint_kernel_v6_1_default(crate::builder())]
#[should_panic]
#[case::failpoint_kernel_v5_13_io_polling(crate::builder().with_io_polling(true))]
#[case::failpoint_kernel_v5_15_io_polling(crate::builder().with_io_polling(true))]
#[case::failpoint_kernel_v5_19_io_polling(crate::builder().with_io_polling(true))]
#[case::failpoint_kernel_v6_0_io_polling(crate::builder().with_io_polling(true))]
#[case::failpoint_kernel_v6_1_io_polling(crate::builder().with_io_polling(true))]
#[should_panic]
#[case::failpoint_kernel_v5_13_defer_task_run(crate::builder().with_coop_task_run(true))]
#[should_panic]
#[case::failpoint_kernel_v5_15_defer_task_run(crate::builder().with_coop_task_run(true))]
#[case::failpoint_kernel_v5_19_defer_task_run(crate::builder().with_coop_task_run(true))]
#[case::failpoint_kernel_v6_0_defer_task_run(crate::builder().with_coop_task_run(true))]
#[case::failpoint_kernel_v6_1_defer_task_run(crate::builder().with_coop_task_run(true))]
#[should_panic]
#[case::failpoint_kernel_v5_13_registered_files(crate::builder().with_num_registered_files(8))]
#[case::failpoint_kernel_v5_15_registered_files(crate::builder().with_num_registered_files(8))]
#[case::failpoint_kernel_v5_19_registered_files(crate::builder().with_num_registered_files(8))]
#[case::failpoint_kernel_v6_0_registered_files(crate::builder().with_num_registered_files(8))]
#[case::failpoint_kernel_v6_1_registered_files(crate::builder().with_num_registered_files(8))]
#[should_panic]
#[case::failpoint_kernel_v5_13_registered_buffers(crate::builder().with_num_registered_buffers(8))]
#[case::failpoint_kernel_v5_15_registered_buffers(crate::builder().with_num_registered_buffers(8))]
#[case::failpoint_kernel_v5_19_registered_buffers(crate::builder().with_num_registered_buffers(8))]
#[case::failpoint_kernel_v6_0_registered_buffers(crate::builder().with_num_registered_buffers(8))]
#[case::failpoint_kernel_v6_1_registered_buffers(crate::builder().with_num_registered_buffers(8))]
#[should_panic]
#[case::failpoint_kernel_v5_13_skip_unsupported_features(crate::builder().with_coop_task_run(true).skip_unsupported_features(true))]
#[case::failpoint_kernel_v5_15_skip_unsupported_features(crate::builder().with_coop_task_run(true).skip_unsupported_features(true))]
#[case::failpoint_kernel_v5_19_skip_unsupported_features(crate::builder().with_coop_task_run(true).skip_unsupported_features(true))]
#[case::failpoint_kernel_v6_0_unsupported_features(crate::builder().with_coop_task_run(true).skip_unsupported_features(true))]
#[case::failpoint_kernel_v6_1_unsupported_features(crate::builder().with_coop_task_run(true).skip_unsupported_features(true))]
// -- Begin size 128 tests
#[should_panic]
#[case::size128_failpoint_kernel_v5_13_default(crate::builder().with_sqe_size128(true))]
#[case::size128_failpoint_kernel_v5_15_default(crate::builder().with_sqe_size128(true))]
#[case::size128_failpoint_kernel_v5_19_default(crate::builder().with_sqe_size128(true))]
#[case::size128_failpoint_kernel_v6_0_default(crate::builder().with_sqe_size128(true))]
#[case::size128_failpoint_kernel_v6_1_default(crate::builder().with_sqe_size128(true))]
#[should_panic]
#[case::size128_failpoint_kernel_v5_13_io_polling(crate::builder().with_sqe_size128(true).with_io_polling(true))]
#[case::size128_failpoint_kernel_v5_15_io_polling(crate::builder().with_sqe_size128(true).with_io_polling(true))]
#[case::size128_failpoint_kernel_v5_19_io_polling(crate::builder().with_sqe_size128(true).with_io_polling(true))]
#[case::size128_failpoint_kernel_v6_0_io_polling(crate::builder().with_sqe_size128(true).with_io_polling(true))]
#[case::size128_failpoint_kernel_v6_1_io_polling(crate::builder().with_sqe_size128(true).with_io_polling(true))]
#[should_panic]
#[case::size128_failpoint_kernel_v5_13_coop_task_run(crate::builder().with_sqe_size128(true).with_coop_task_run(true))]
#[should_panic]
#[case::size128_failpoint_kernel_v5_15_coop_task_run(crate::builder().with_sqe_size128(true).with_coop_task_run(true))]
#[case::size128_failpoint_kernel_v5_19_coop_task_run(crate::builder().with_sqe_size128(true).with_coop_task_run(true))]
#[case::size128_failpoint_kernel_v6_0_coop_task_run(crate::builder().with_sqe_size128(true).with_coop_task_run(true))]
#[case::size128_failpoint_kernel_v6_1_coop_task_run(crate::builder().with_sqe_size128(true).with_coop_task_run(true))]
#[should_panic]
#[case::size128_failpoint_kernel_v5_13_registered_files(crate::builder().with_sqe_size128(true).with_num_registered_files(8))]
#[case::size128_failpoint_kernel_v5_15_registered_files(crate::builder().with_sqe_size128(true).with_num_registered_files(8))]
#[case::size128_failpoint_kernel_v5_19_registered_files(crate::builder().with_sqe_size128(true).with_num_registered_files(8))]
#[case::size128_failpoint_kernel_v6_0_registered_files(crate::builder().with_sqe_size128(true).with_num_registered_files(8))]
#[case::size128_failpoint_kernel_v6_1_registered_files(crate::builder().with_sqe_size128(true).with_num_registered_files(8))]
#[should_panic]
#[case::size128_failpoint_kernel_v5_13_registered_buffers(crate::builder().with_sqe_size128(true).with_num_registered_buffers(8))]
#[case::size128_failpoint_kernel_v5_15_registered_buffers(crate::builder().with_sqe_size128(true).with_num_registered_buffers(8))]
#[case::size128_failpoint_kernel_v5_19_registered_buffers(crate::builder().with_sqe_size128(true).with_num_registered_buffers(8))]
#[case::size128_failpoint_kernel_v6_0_registered_buffers(crate::builder().with_sqe_size128(true).with_num_registered_buffers(8))]
#[case::size128_failpoint_kernel_v6_1_registered_buffers(crate::builder().with_sqe_size128(true).with_num_registered_buffers(8))]
fn failpoint_test_scheduler_creation(#[case] builder: I2o2Builder) {
    let scenario = FailScenario::setup();
    let (_scheduler, _handle) = builder
        .try_create::<()>()
        .expect("builder should be produce valid scheduler");
    scenario.teardown();
}