diff options
author | Konstantin Käfer <mail@kkaefer.com> | 2015-10-15 23:02:11 +0200 |
---|---|---|
committer | Konstantin Käfer <mail@kkaefer.com> | 2015-10-26 15:54:27 +0100 |
commit | 9bbd9aba3a8cebf7191ae5b28c8cf16acf39987e (patch) | |
tree | 0acb1e4b9b027c0b54d87919f29d4962358a2826 /src/mbgl | |
parent | 6a7334b882a47ca193209f2012843e42aa3ed4e2 (diff) | |
download | qtlocation-mapboxgl-9bbd9aba3a8cebf7191ae5b28c8cf16acf39987e.tar.gz |
[core] set a timer and auto-refresh requests when they expire
When we get a request with an explicit expiration time, we're now starting a timer, and will trigger a refresh once the data expires. This gives requesters a chance to update their data.
Diffstat (limited to 'src/mbgl')
-rw-r--r-- | src/mbgl/storage/default_file_source.cpp | 35 | ||||
-rw-r--r-- | src/mbgl/storage/default_file_source_impl.hpp | 1 |
2 files changed, 33 insertions, 3 deletions
diff --git a/src/mbgl/storage/default_file_source.cpp b/src/mbgl/storage/default_file_source.cpp index 71c42f6220..5d698fc0f0 100644 --- a/src/mbgl/storage/default_file_source.cpp +++ b/src/mbgl/storage/default_file_source.cpp @@ -11,6 +11,7 @@ #include <mbgl/util/thread.hpp> #include <mbgl/util/mapbox.hpp> #include <mbgl/util/exception.hpp> +#include <mbgl/util/chrono.hpp> #pragma GCC diagnostic push #pragma GCC diagnostic ignored "-Wshadow" @@ -159,19 +160,26 @@ void DefaultFileSource::Impl::startCacheRequest(DefaultFileRequest* request) { request->cacheRequest = nullptr; if (response) { response->stale = response->isExpired(); - - // Notify in all cases; requestors can decide whether they want to use stale responses. - notify(request, response, FileCache::Hint::No); } if (!response || response->stale) { // No response or stale cache. Run the real request. startRealRequest(request, response); } + + if (response) { + // Notify in all cases; requestors can decide whether they want to use stale responses. + notify(request, response, FileCache::Hint::No); + } }); } void DefaultFileSource::Impl::startRealRequest(DefaultFileRequest* request, std::shared_ptr<const Response> response) { + // Cancel the timer if we have one. + if (request->timerRequest) { + request->timerRequest->stop(); + } + auto callback = [request, this] (std::shared_ptr<const Response> res, FileCache::Hint hint) { request->realRequest = nullptr; notify(request, res, hint); @@ -225,6 +233,27 @@ void DefaultFileSource::Impl::notify(DefaultFileRequest* request, std::shared_pt // Store response in database cache->put(request->resource, response, hint); } + + // Set timer for requests that have a known expiry times. Expiry times of 0 are technically + // expiring immediately, but we can't continually request. + if (!request->realRequest && response->expires > 0) { + const int64_t now = std::chrono::duration_cast<std::chrono::seconds>( + SystemClock::now().time_since_epoch()).count(); + const int64_t timeout = response->expires - now; + + if (timeout <= 0) { + update(request); + } else { + if (!request->timerRequest) { + request->timerRequest = std::make_unique<uv::timer>(util::RunLoop::getLoop()); + } + + // timeout is in seconds, but the timer takes milliseconds. + request->timerRequest->start(1000 * timeout, 0, [this, request] { + update(request); + }); + } + } } } diff --git a/src/mbgl/storage/default_file_source_impl.hpp b/src/mbgl/storage/default_file_source_impl.hpp index 980eedc118..387c6ce66e 100644 --- a/src/mbgl/storage/default_file_source_impl.hpp +++ b/src/mbgl/storage/default_file_source_impl.hpp @@ -19,6 +19,7 @@ struct DefaultFileRequest { std::unique_ptr<WorkRequest> cacheRequest; RequestBase* realRequest = nullptr; + std::unique_ptr<uv::timer> timerRequest; inline DefaultFileRequest(const Resource& resource_) : resource(resource_) {} |