74 lines
1.7 KiB
C++
74 lines
1.7 KiB
C++
#include "mapview.h"
|
|
#include "osm_downloader_p.h"
|
|
#include "osm_tile_cache_p.h"
|
|
|
|
|
|
OSMDownloader::OSMDownloader(MapView * p): QThread() {
|
|
qRegisterMetaType<OSM::TileIndex>();
|
|
nam = new QNetworkAccessManager();
|
|
parent = p;
|
|
provider = "http://tile.openstreetmap.org";
|
|
start();
|
|
}
|
|
|
|
|
|
OSMDownloader::~OSMDownloader() {
|
|
requestInterruption();
|
|
cond.wakeAll();
|
|
wait();
|
|
delete nam;
|
|
}
|
|
|
|
|
|
void OSMDownloader::queueTile(OSM::TileIndex index) {
|
|
// auto hash = tile.hash();
|
|
cond_mutex.lock();
|
|
if (!queue.contains(index) && !in_progress.contains(index.hash())) {
|
|
queue.enqueue(index);
|
|
cond.wakeOne();
|
|
}
|
|
cond_mutex.unlock();
|
|
}
|
|
|
|
|
|
void OSMDownloader::requestTile(OSM::TileIndex index) {
|
|
QNetworkRequest req(provider + QString("/%1/%2/%3.png").arg(index.z).arg(index.x).arg(index.y));
|
|
req.setHeader(QNetworkRequest::UserAgentHeader, "Qt/5");
|
|
auto * r = nam->get(req);
|
|
if (!r) return;
|
|
connect(r, &QNetworkReply::finished, this, [this, r, index]() {
|
|
r->deleteLater();
|
|
if (r->error() != QNetworkReply::NoError) {
|
|
qDebug() << "Error:" << r->error();
|
|
} else {
|
|
QByteArray data = r->readAll();
|
|
if (!data.isEmpty()) {
|
|
QPixmap tim;
|
|
tim.loadFromData(data, "png");
|
|
if (!tim.isNull()) parent->cache->tileDownloaded(index, tim);
|
|
}
|
|
}
|
|
cond_mutex.lock();
|
|
in_progress.remove(index.hash());
|
|
cond_mutex.unlock();
|
|
});
|
|
}
|
|
|
|
|
|
void OSMDownloader::run() {
|
|
while (!isInterruptionRequested()) {
|
|
cond_mutex.lock();
|
|
if (queue.isEmpty())
|
|
cond.wait(&cond_mutex);
|
|
else {
|
|
auto t = queue.dequeue();
|
|
in_progress.insert(t.hash());
|
|
QMetaObject::invokeMethod(
|
|
parent,
|
|
[this, t]() { requestTile(t); },
|
|
Qt::QueuedConnection);
|
|
}
|
|
cond_mutex.unlock();
|
|
}
|
|
}
|