0b779eaa8b
The request callback runs in the same thread as ~TileData, and is not run if the request is cancelled. So either ~TileData runs first and cancels the request, or the callback runs first, before TileData is destructed. Therefore the weak pointer and lock() check is unnecessary; `this` can be used instead.
75 lines
2.0 KiB
C++
75 lines
2.0 KiB
C++
#include <mbgl/map/tile_data.hpp>
|
|
#include <mbgl/map/environment.hpp>
|
|
#include <mbgl/map/source.hpp>
|
|
|
|
#include <mbgl/storage/file_source.hpp>
|
|
#include <mbgl/util/uv_detail.hpp>
|
|
#include <mbgl/platform/log.hpp>
|
|
|
|
using namespace mbgl;
|
|
|
|
TileData::TileData(const TileID& id_, const SourceInfo& source_)
|
|
: id(id_),
|
|
name(id),
|
|
state(State::initial),
|
|
source(source_),
|
|
env(Environment::Get()),
|
|
debugBucket(debugFontBuffer) {
|
|
// Initialize tile debug coordinates
|
|
debugFontBuffer.addText(name.c_str(), 50, 200, 5);
|
|
}
|
|
|
|
TileData::~TileData() {
|
|
cancel();
|
|
}
|
|
|
|
const std::string TileData::toString() const {
|
|
return std::string { "[tile " } + name + "]";
|
|
}
|
|
|
|
void TileData::request(uv::worker &worker, float pixelRatio, std::function<void()> callback) {
|
|
std::string url = source.tileURL(id, pixelRatio);
|
|
state = State::loading;
|
|
|
|
req = env.request({ Resource::Kind::Tile, url }, [url, callback, &worker, this](const Response &res) {
|
|
req = nullptr;
|
|
|
|
if (res.status != Response::Successful) {
|
|
Log::Error(Event::HttpRequest, "[%s] tile loading failed: %s", url.c_str(), res.message.c_str());
|
|
return;
|
|
}
|
|
|
|
state = State::loaded;
|
|
data = res.data;
|
|
|
|
// Schedule tile parsing in another thread
|
|
reparse(worker, callback);
|
|
});
|
|
}
|
|
|
|
void TileData::cancel() {
|
|
if (state != State::obsolete) {
|
|
state = State::obsolete;
|
|
}
|
|
if (req) {
|
|
env.cancelRequest(req);
|
|
req = nullptr;
|
|
}
|
|
}
|
|
|
|
void TileData::reparse(uv::worker& worker, std::function<void()> callback)
|
|
{
|
|
// We're creating a new work request. The work request deletes itself after it executed
|
|
// the after work handler
|
|
new uv::work<util::ptr<TileData>>(
|
|
worker,
|
|
[this](util::ptr<TileData>& tile) {
|
|
EnvironmentScope scope(env, ThreadType::TileWorker, "TileWorker_" + tile->name);
|
|
tile->parse();
|
|
},
|
|
[callback](util::ptr<TileData>&) {
|
|
callback();
|
|
},
|
|
shared_from_this());
|
|
}
|