gtfs-actions/generate-shapes
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

write doubles as bytes to shape container, not strings, to safe some disk space and speed up writing

Browse source
This commit is contained in:
Patrick Brosi 2021-07-24 10:06:19 +02:00 committed by Patrick Brosi
parent e0e4ee1f2b
commit cea4474631
2 changed files with 26 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/pfaedle/gtfs/ShapeContainer.h
View file

@ -61,6 +61,7 @@ class ShapeContainer {
size_t _max; size_t _max;
std::string _curId; std::string _curId;
std::stringstream _writeBuffer; std::stringstream _writeBuffer;
std::fpos<std::mbstate_t> _lastBuff;
}; };
#include "ShapeContainer.tpp" #include "ShapeContainer.tpp"

39
src/pfaedle/gtfs/ShapeContainer.tpp
View file

@ -3,10 +3,11 @@
// Authors: Patrick Brosi <brosi@informatik.uni-freiburg.de> // Authors: Patrick Brosi <brosi@informatik.uni-freiburg.de>
#include <string> #include <string>
#include <iostream>
// ____________________________________________________________________________ // ____________________________________________________________________________
template <typename T> template <typename T>
ShapeContainer<T>::ShapeContainer() { ShapeContainer<T>::ShapeContainer() : _lastBuff(0) {
std::string f = pfaedle::getTmpFName("", ""); std::string f = pfaedle::getTmpFName("", "");
_storage.open(f, std::fstream::in | std::fstream::out | std::fstream::trunc); _storage.open(f, std::fstream::in | std::fstream::out | std::fstream::trunc);
@ -23,6 +24,8 @@ ShapeContainer<T>::ShapeContainer() {
// ____________________________________________________________________________ // ____________________________________________________________________________
template <typename T> template <typename T>
ShapeContainer<T>::~ShapeContainer() { ShapeContainer<T>::~ShapeContainer() {
_storage << _writeBuffer.rdbuf();
_storage.flush();
_storage.close(); _storage.close();
} }
@ -70,18 +73,22 @@ size_t ShapeContainer<T>::size() const {
template <typename T> template <typename T>
std::string ShapeContainer<T>::add(const ad::cppgtfs::gtfs::Shape& s) { std::string ShapeContainer<T>::add(const ad::cppgtfs::gtfs::Shape& s) {
if (has(s.getId())) return s.getId(); if (has(s.getId())) return s.getId();
size_t size = s.getPoints().size();
_ids.insert(s.getId()); _ids.insert(s.getId());
_writeBuffer << s.getId() << '\t' << s.getPoints().size(); _writeBuffer << s.getId();
_writeBuffer << std::setprecision(11); _writeBuffer.put(' ');
for (auto p : s.getPoints()) { _writeBuffer.write(reinterpret_cast<const char*>(&size), sizeof(size));
_writeBuffer << " " << p.lat << " " << p.lng << " " << p.travelDist;
}
// entries are newline separated
_writeBuffer << '\n';
if (_writeBuffer.tellp() > 1000 * 5000) { for (const auto& p : s.getPoints()) {
_storage << _writeBuffer.rdbuf(); _writeBuffer.write(reinterpret_cast<const char*>(&p.lat), sizeof(p.lat));
_writeBuffer.write(reinterpret_cast<const char*>(&p.lng), sizeof(p.lng));
_writeBuffer.write(reinterpret_cast<const char*>(&p.travelDist), sizeof(p.travelDist));
}
if (_writeBuffer.tellp() - _lastBuff > 1000 * 5000) {
_lastBuff = _writeBuffer.tellp();
_storage << _writeBuffer.rdbuf();
_writeBuffer.clear(); _writeBuffer.clear();
} }
@ -92,6 +99,7 @@ std::string ShapeContainer<T>::add(const ad::cppgtfs::gtfs::Shape& s) {
template <typename T> template <typename T>
void ShapeContainer<T>::open() { void ShapeContainer<T>::open() {
_storage << _writeBuffer.rdbuf(); _storage << _writeBuffer.rdbuf();
_storage.flush();
_writeBuffer.clear(); _writeBuffer.clear();
_ptr = 0; _ptr = 0;
@ -107,14 +115,17 @@ bool ShapeContainer<T>::nextStoragePt(
while (_storage.good() && !_storage.fail()) { while (_storage.good() && !_storage.fail()) {
if (!_ptr) { if (!_ptr) {
_storage >> _curId; _storage >> _curId;
_storage >> _max; _storage.ignore();
_storage.read(reinterpret_cast<char*>(&_max), sizeof(_max));
} }
if (!_storage.good() || _storage.fail()) return false; if (!_storage.good() || _storage.fail()) return false;
_storage >> ret->lat; _storage.read(reinterpret_cast<char*>(&ret->lat), sizeof(ret->lat));
_storage >> ret->lng; _storage.read(reinterpret_cast<char*>(&ret->lng), sizeof(ret->lng));
_storage >> ret->travelDist; _storage.read(reinterpret_cast<char*>(&ret->travelDist), sizeof(ret->travelDist));
ret->seq = _ptr + 1; ret->seq = _ptr + 1;
ret->id = _curId; ret->id = _curId;