way_stores.cpp

#include <boost/sort/sort.hpp>

#include "way_stores.h"

void BinarySearchWayStore::finalize(unsigned int threadNum) { 
	std::lock_guard<std::mutex> lock(mutex);
	boost::sort::block_indirect_sort(
		mLatpLonLists->begin(), mLatpLonLists->end(), 
		[](auto const &a, auto const &b) { return a.first < b.first; }, 
		threadNum);
}

void BinarySearchWayStore::reopen() {
	mLatpLonLists = std::make_unique<map_t>();
}

bool BinarySearchWayStore::contains(size_t shard, WayID id) const {
	auto iter = std::lower_bound(mLatpLonLists->begin(), mLatpLonLists->end(), id, [](auto const &e, auto id) { 
		return e.first < id; 
	});

	return !(iter == mLatpLonLists->end() || iter->first != id);
}

std::vector<LatpLon> BinarySearchWayStore::at(WayID wayid) const {
	std::lock_guard<std::mutex> lock(mutex);
	
	auto iter = std::lower_bound(mLatpLonLists->begin(), mLatpLonLists->end(), wayid, [](auto const &e, auto wayid) { 
		return e.first < wayid; 
	});

	if(iter == mLatpLonLists->end() || iter->first != wayid)
		throw std::out_of_range("Could not find way with id " + std::to_string(wayid));

	std::vector<LatpLon> rv;
	rv.reserve(iter->second.size());
	// TODO: copy iter->second to rv more efficiently
	for (const LatpLon& el : iter->second)
		rv.push_back(el);
	return rv;
}

void BinarySearchWayStore::insertLatpLons(std::vector<WayStore::ll_element_t> &newWays) {
	std::lock_guard<std::mutex> lock(mutex);
	auto i = mLatpLonLists->size();
	mLatpLonLists->resize(i + newWays.size());
	std::copy(std::make_move_iterator(newWays.begin()), std::make_move_iterator(newWays.end()), mLatpLonLists->begin() + i); 
}

void BinarySearchWayStore::insertNodes(const std::vector<std::pair<WayID, std::vector<NodeID>>>& newWays) {
	throw std::runtime_error("BinarySearchWayStore does not support insertNodes");
}

void BinarySearchWayStore::clear() {
	std::lock_guard<std::mutex> lock(mutex);
	mLatpLonLists->clear(); 
}

std::size_t BinarySearchWayStore::size() const {
	std::lock_guard<std::mutex> lock(mutex);
	return mLatpLonLists->size(); 
}