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
|
#include "../libfilezilla/aio/xml_writer.hpp"
namespace fz {
xml_parser_writer::xml_parser_writer(xml::parser::callback_t && cb, std::wstring const& name, aio_buffer_pool & pool, progress_cb_t && progress_cb)
: writer_base(name, pool, std::move(progress_cb), 1)
, cb_(std::move(cb))
{
parser_.set_callback([this](xml::callback_event t, std::string_view path, std::string_view name, std::string && value) {
if (logger_) {
logger_->log(t, path, name, value);
}
return cb_ ? cb_(t, path, name, std::move(value)) : true;
});
}
void xml_parser_writer::enable_pretty_log(logmsg::type t)
{
logger_.emplace(buffer_pool_.logger(), t);
}
aio_result xml_parser_writer::do_add_buffer(scoped_lock &, buffer_lease && b)
{
bool ret = parser_.parse(b->to_view());
b.release();
if (!ret) {
auto error = parser_.get_error();
if (!error.empty()) {
buffer_pool_.logger().log(logmsg::error, "Could not parse XML: %s", error);
}
return aio_result::error;
}
return aio_result::ok;
}
aio_result xml_parser_writer::do_finalize(scoped_lock &)
{
if (!parser_.finalize()) {
auto error = parser_.get_error();
if (!error.empty()) {
buffer_pool_.logger().log(logmsg::error, "Could not parse XML: %s", error);
}
return aio_result::error;
}
return aio_result::ok;
}
xml_namespace_parser_writer::xml_namespace_parser_writer(xml::parser::callback_t && cb, std::wstring const& name, aio_buffer_pool & pool, progress_cb_t && progress_cb)
: writer_base(name, pool, std::move(progress_cb), 1)
{
parser_.set_callback(std::move(cb));
}
void xml_namespace_parser_writer::enable_pretty_log(logmsg::type t)
{
logger_.emplace(buffer_pool_.logger(), t);
parser_.set_raw_callback([this](xml::callback_event t, std::string_view path, std::string_view name, std::string_view value) { logger_->log(t, path, name, value); return true; });
}
aio_result xml_namespace_parser_writer::do_add_buffer(scoped_lock &, buffer_lease && b)
{
bool ret = parser_.parse(b->to_view());
b.release();
if (!ret) {
auto error = parser_.get_error();
if (!error.empty()) {
buffer_pool_.logger().log(logmsg::error, "Could not parse XML: %s", error);
}
return aio_result::error;
}
return aio_result::ok;
}
aio_result xml_namespace_parser_writer::do_finalize(scoped_lock &)
{
if (!parser_.finalize()) {
auto error = parser_.get_error();
if (!error.empty()) {
buffer_pool_.logger().log(logmsg::error, "Could not parse XML: %s", error);
}
return aio_result::error;
}
return aio_result::ok;}
}
|
