rzbackup 3.3.0

RZBackup
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

use protobuf;
use protobuf::CodedInputStream;
use protobuf::CodedOutputStream;

use misc::*;

pub fn protobuf_message_read <
	Type: protobuf::MessageStatic,
	NameFunction: Fn () -> String,
> (
	coded_input_stream: & mut CodedInputStream,
	name_function: NameFunction,
) -> Result <Type, String> {

	let message_length =
		protobuf_result_with_prefix (
			|| format! (
				"Error reading {} length: ",
				name_function ()),
			coded_input_stream.read_raw_varint32 (),
		) ?;

	let old_limit =
		protobuf_result_with_prefix (
			|| format! (
				"Error preparing to read {}: ",
				name_function ()),
			coded_input_stream.push_limit (
				message_length as u64),
		) ?;

	let message =
		protobuf_result_with_prefix (
			|| format! (
				"Error reading {}: ",
				name_function ()),
			protobuf::core::parse_from::<Type> (
				coded_input_stream),
		) ?;

	coded_input_stream.pop_limit (
		old_limit);

	Ok (message)

}

#[ inline ]
pub fn protobuf_message_write <
	NameFunction: Fn () -> String,
	Type: protobuf::MessageStatic,
> (
	name_function: NameFunction,
	coded_output_stream: & mut CodedOutputStream,
	message: & Type,
) -> Result <(), String> {

	// write size

	protobuf_result_with_prefix (
		|| format! (
			"Error writing {} size",
			name_function ()),
		coded_output_stream.write_raw_varint32 (
			message.compute_size ()),
	) ?;

	// write message

	protobuf_result_with_prefix (
		|| format! (
			"Error writing {}",
			name_function ()),
		message.write_to_with_cached_sizes (
			coded_output_stream),
	) ?;

	// return

	Ok (())

}

// ex: noet ts=4 filetype=rust