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
|
/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/*
* This file is part of the libabw project.
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
#include <string.h>
#include <libxml/xmlIO.h>
#include <libxml/xmlmemory.h>
#include <librevenge-stream/librevenge-stream.h>
#include "ABWXMLHelper.h"
#include "libabw_internal.h"
namespace libabw
{
namespace
{
extern "C" {
static int abwxmlInputCloseFunc(void *)
{
return 0;
}
static int abwxmlInputReadFunc(void *context, char *buffer, int len)
{
librevenge::RVNGInputStream *input = (librevenge::RVNGInputStream *)context;
if ((!input) || (!buffer) || (len < 0))
return -1;
if (input->isEnd())
return 0;
unsigned long tmpNumBytesRead = 0;
const unsigned char *tmpBuffer = input->read((unsigned long) len, tmpNumBytesRead);
if (tmpBuffer && tmpNumBytesRead)
memcpy(buffer, tmpBuffer, tmpNumBytesRead);
return int(tmpNumBytesRead);
}
#ifdef DEBUG
static void abwxmlReaderErrorFunc(void *arg, const char *message, xmlParserSeverities severity, xmlTextReaderLocatorPtr)
#else
static void abwxmlReaderErrorFunc(void *arg, const char *, xmlParserSeverities severity, xmlTextReaderLocatorPtr)
#endif
{
const auto watcher = reinterpret_cast<ABWXMLProgressWatcher *>(arg);
switch (severity)
{
case XML_PARSER_SEVERITY_VALIDITY_WARNING:
ABW_DEBUG_MSG(("Found xml parser severity validity warning %s\n", message));
break;
case XML_PARSER_SEVERITY_VALIDITY_ERROR:
ABW_DEBUG_MSG(("Found xml parser severity validity error %s\n", message));
break;
case XML_PARSER_SEVERITY_WARNING:
ABW_DEBUG_MSG(("Found xml parser severity warning %s\n", message));
break;
case XML_PARSER_SEVERITY_ERROR:
ABW_DEBUG_MSG(("Found xml parser severity error %s\n", message));
if (watcher)
watcher->signalError();
break;
default:
break;
}
}
} // extern "C"
} // anonymous namespace
ABWXMLString::ABWXMLString(xmlChar *xml)
: m_xml(xml, xmlFree)
{
}
const xmlChar *ABWXMLString::get() const
{
return m_xml.get();
}
ABWXMLString::operator const char *() const
{
return reinterpret_cast<const char *>(m_xml.get());
}
ABWXMLProgressWatcher::ABWXMLProgressWatcher()
: m_reader(nullptr)
, m_line(0)
, m_col(0)
, m_wasError(false)
, m_isStuck(false)
{
}
void ABWXMLProgressWatcher::setReader(xmlTextReaderPtr reader)
{
m_reader = reader;
}
bool ABWXMLProgressWatcher::isStuck() const
{
return m_isStuck;
}
void ABWXMLProgressWatcher::signalError()
{
if (m_reader && !m_isStuck)
{
const int line = m_line;
const int col = m_col;
const bool checkStuck = m_wasError;
m_wasError = true;
m_line = xmlTextReaderGetParserLineNumber(m_reader);
m_col = xmlTextReaderGetParserColumnNumber(m_reader);
if (checkStuck)
m_isStuck = line == m_line && col == m_col;
}
}
// xmlTextReader helper function
std::unique_ptr<xmlTextReader, void(*)(xmlTextReaderPtr)> xmlReaderForStream(librevenge::RVNGInputStream *input, ABWXMLProgressWatcher *watcher)
{
std::unique_ptr<xmlTextReader, void(*)(xmlTextReaderPtr)> reader(
xmlReaderForIO(abwxmlInputReadFunc, abwxmlInputCloseFunc, (void *)input, nullptr, nullptr,
XML_PARSE_NOBLANKS|XML_PARSE_NOENT|XML_PARSE_NONET|XML_PARSE_RECOVER),
xmlFreeTextReader);
if (watcher)
watcher->setReader(reader.get());
if (reader)
xmlTextReaderSetErrorHandler(reader.get(), abwxmlReaderErrorFunc, watcher);
return reader;
}
}
/* vim:set shiftwidth=2 softtabstop=2 expandtab: */
|
