blob: 47c501791cec8e2036543245aaa0d43a5b3d10b1 (
plain)
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
|
#include "io_helpers.h"
#include "io.h"
#include <cassert>
namespace saw {
void read_task_and_step_helper::read_step(input_stream &reader) {
while (read_task.has_value()) {
read_io_task &task = *read_task;
error_or<size_t> n_err = reader.read(task.buffer, task.max_length);
if (n_err.is_error()) {
const error &error = n_err.error();
if (error.is_critical()) {
if (read_done) {
read_done->fail(error.copy_error());
}
read_task = std::nullopt;
}
break;
} else if (n_err.is_value()) {
size_t n = n_err.value();
if (static_cast<size_t>(n) >= task.min_length &&
static_cast<size_t>(n) <= task.max_length) {
if (read_done) {
read_done->feed(n + task.already_read);
}
read_task = std::nullopt;
} else {
task.buffer = static_cast<uint8_t *>(task.buffer) + n;
task.min_length -= static_cast<size_t>(n);
task.max_length -= static_cast<size_t>(n);
task.already_read += n;
}
} else {
if (read_done) {
read_done->fail(critical_error("Read failed"));
}
read_task = std::nullopt;
}
}
}
void write_task_and_step_helper::write_step(output_stream &writer) {
while (write_task.has_value()) {
write_io_task &task = *write_task;
error_or<size_t> n_err = writer.write(task.buffer, task.length);
if (n_err.is_value()) {
size_t n = n_err.value();
assert(n <= task.length);
if (n == task.length) {
if (write_done) {
write_done->feed(n + task.already_written);
}
write_task = std::nullopt;
} else {
task.buffer = static_cast<const uint8_t *>(task.buffer) + n;
task.length -= n;
task.already_written += n;
}
} else if (n_err.is_error()) {
const error &error = n_err.error();
if (error.is_critical()) {
if (write_done) {
write_done->fail(error.copy_error());
}
write_task = std::nullopt;
}
break;
} else {
if (write_done) {
write_done->fail(critical_error("Write failed"));
}
write_task = std::nullopt;
}
}
}
} // namespace saw
|
