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
|
#include "generator/maxspeeds_collector.hpp"
#include "generator/final_processor_utils.hpp"
#include "generator/maxspeeds_parser.hpp"
#include "routing_common/maxspeed_conversion.hpp"
#include "platform/platform.hpp"
#include "coding/internal/file_data.hpp"
#include "base/assert.hpp"
#include "base/geo_object_id.hpp"
#include "base/logging.hpp"
#include "base/string_utils.hpp"
#include <algorithm>
#include <iterator>
#include <sstream>
using namespace base;
using namespace generator;
using namespace routing;
using namespace feature;
using namespace std;
namespace
{
bool ParseMaxspeedAndWriteToStream(string const & maxspeed, SpeedInUnits & speed, ostringstream & ss)
{
if (!ParseMaxspeedTag(maxspeed, speed))
return false;
ss << UnitsToString(speed.GetUnits()) << "," << strings::to_string(speed.GetSpeed());
return true;
}
} // namespace
namespace generator
{
MaxspeedsCollector::MaxspeedsCollector(string const & filename)
: CollectorInterface(filename)
{
m_stream.exceptions(fstream::failbit | fstream::badbit);
m_stream.open(GetTmpFilename());
}
shared_ptr<CollectorInterface> MaxspeedsCollector::Clone(
shared_ptr<cache::IntermediateDataReaderInterface> const &) const
{
return make_shared<MaxspeedsCollector>(GetFilename());
}
void MaxspeedsCollector::CollectFeature(FeatureBuilder const &, OsmElement const & p)
{
if (!p.IsWay())
return;
ostringstream ss;
ss << p.m_id << ",";
auto const & tags = p.Tags();
string maxspeedForwardStr;
string maxspeedBackwardStr;
bool isReverse = false;
for (auto const & t : tags)
{
if (t.m_key == "maxspeed")
{
SpeedInUnits dummySpeed;
if (!ParseMaxspeedAndWriteToStream(t.m_value, dummySpeed, ss))
return;
m_stream << ss.str() << '\n';
return;
}
if (t.m_key == "maxspeed:forward")
maxspeedForwardStr = t.m_value;
else if (t.m_key == "maxspeed:backward")
maxspeedBackwardStr = t.m_value;
else if (t.m_key == "oneway")
isReverse = (t.m_value == "-1");
}
// Note 1. isReverse == true means feature |p| has tag "oneway" with value "-1". Now (10.2018)
// no feature with a tag oneway==-1 and a tag maxspeed:forward/backward is found. But to
// be on the safe side this case is handled.
// Note 2. If oneway==-1 the order of points is changed while conversion to mwm. So it's
// necessary to swap forward and backward as well.
if (isReverse)
maxspeedForwardStr.swap(maxspeedBackwardStr);
if (maxspeedForwardStr.empty())
return;
SpeedInUnits maxspeedForward;
if (!ParseMaxspeedAndWriteToStream(maxspeedForwardStr, maxspeedForward, ss))
return;
if (!maxspeedBackwardStr.empty())
{
SpeedInUnits maxspeedBackward;
if (!ParseMaxspeedTag(maxspeedBackwardStr, maxspeedBackward))
return;
// Note. Keeping only maxspeed:forward and maxspeed:backward if they have the same units.
// The exception is maxspeed:forward or maxspeed:backward have a special values
// like "none" or "walk". In that case units mean nothing an the values should
// be processed in a special way.
if (!HaveSameUnits(maxspeedForward, maxspeedBackward))
return;
ss << "," << strings::to_string(maxspeedBackward.GetSpeed());
}
m_stream << ss.str() << '\n';
}
void MaxspeedsCollector::Finish()
{
if (m_stream.is_open())
m_stream.close();
}
void MaxspeedsCollector::Save()
{
CHECK(!m_stream.is_open(), ("Finish() has not been called."));
LOG(LINFO, ("Saving maxspeed tag values to", GetFilename()));
if (Platform::IsFileExistsByFullPath(GetTmpFilename()))
CHECK(CopyFileX(GetTmpFilename(), GetFilename()), ());
}
void MaxspeedsCollector::OrderCollectedData() { OrderTextFileByLine(GetFilename()); }
void MaxspeedsCollector::Merge(CollectorInterface const & collector)
{
collector.MergeInto(*this);
}
void MaxspeedsCollector::MergeInto(MaxspeedsCollector & collector) const
{
CHECK(!m_stream.is_open() || !collector.m_stream.is_open(), ("Finish() has not been called."));
base::AppendFileToFile(GetTmpFilename(), collector.GetTmpFilename());
}
} // namespace generator
|
