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
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
|
/*
Copyright (C) 2020 Carl Hetherington <cth@carlh.net>
This file is part of DCP-o-matic.
DCP-o-matic is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
DCP-o-matic is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with DCP-o-matic. If not, see <http://www.gnu.org/licenses/>.
*/
#include <boost/optional.hpp>
#include <string>
/* windows.h defines this but we want to use it */
#undef ERROR
class Nanomsg;
/* We have the front-end application dcpomatic2_disk and the back-end
* dcpomatic2_disk_writer. The communication is line-based, separated
* by \n.
*/
/* PING */
// Front-end sends:
#define DISK_WRITER_PING "P"
// Back-end responds
#define DISK_WRITER_PONG "O"
/* REQUEST TO WRITE DCP */
// Front-end sends:
#define DISK_WRITER_WRITE "W"
// DCP pathname
// Internal name of the drive to write to
// Back-end responds:
// everything is ok
#define DISK_WRITER_OK "D"
// there was an error
#define DISK_WRITER_ERROR "E"
// Error message
// Error number
// Additional error number (a platform-specific error from lwext4)
// the drive is being formatted, 40% done
#define DISK_WRITER_FORMAT_PROGRESS "F"
// 0.4\n
// data is being copied, 30% done
#define DISK_WRITER_COPY_PROGRESS "C"
// 0.3\n
// data is being verified, 60% done
#define DISK_WRITER_VERIFY_PROGRESS "V"
// 0.6\n
/* REQUEST TO QUIT */
// Front-end sends:
#define DISK_WRITER_QUIT "Q"
/* REQUEST TO UNMOUNT A DRIVE */
// Front-end sends:
#define DISK_WRITER_UNMOUNT "U"
// XML representation of Drive object to unmount
// Back-end responds:
// DISK_WRITER_OK
// or
// DISK_WRITER_ERROR
class DiskWriterBackEndResponse
{
public:
enum class Type {
OK,
ERROR,
PONG,
FORMAT_PROGRESS,
COPY_PROGRESS,
VERIFY_PROGRESS
};
static DiskWriterBackEndResponse ok() {
return DiskWriterBackEndResponse(Type::OK);
}
static DiskWriterBackEndResponse error(std::string message, int ext4_number, int platform_number) {
auto r = DiskWriterBackEndResponse(Type::ERROR);
r._error_message = message;
r._ext4_error_number = ext4_number;
r._platform_error_number = platform_number;
return r;
}
static DiskWriterBackEndResponse pong() {
return DiskWriterBackEndResponse(Type::PONG);
}
static DiskWriterBackEndResponse format_progress(float p) {
auto r = DiskWriterBackEndResponse(Type::FORMAT_PROGRESS);
r._progress = p;
return r;
}
static DiskWriterBackEndResponse copy_progress(float p) {
auto r = DiskWriterBackEndResponse(Type::COPY_PROGRESS);
r._progress = p;
return r;
}
static DiskWriterBackEndResponse verify_progress(float p) {
auto r = DiskWriterBackEndResponse(Type::VERIFY_PROGRESS);
r._progress = p;
return r;
}
static boost::optional<DiskWriterBackEndResponse> read_from_nanomsg(Nanomsg& nanomsg, int timeout);
bool write_to_nanomsg(Nanomsg& nanomsg, int timeout) const;
Type type() const {
return _type;
}
std::string error_message() const {
return _error_message;
}
int ext4_error_number() const {
return _ext4_error_number;
}
int platform_error_number() const {
return _platform_error_number;
}
float progress() const {
return _progress;
}
private:
DiskWriterBackEndResponse(Type type)
: _type(type)
{}
Type _type;
std::string _error_message;
int _ext4_error_number = 0;
int _platform_error_number = 0;
float _progress = 0;
};
|
