9781785ab7
we are now scoping all file requests to an environment object. The FileSource implementation treats this as an opaque pointer, but allows canceling all Requests that are associated with that pointer. This is necessary to abort all file requests that originated from a particular Map object. Aborting a file request is different from canceling a file request: A canceled request doesn't have its callback called, while an aborted request will have its callback called with an error, indicating that the environment is going to be shut down.
108 lines
2.5 KiB
C++
108 lines
2.5 KiB
C++
#ifndef MBGL_STORAGE_DEFAULT_SHARED_REQUEST_BASE
|
|
#define MBGL_STORAGE_DEFAULT_SHARED_REQUEST_BASE
|
|
|
|
#include <mbgl/storage/resource.hpp>
|
|
#include <mbgl/storage/file_cache.hpp>
|
|
#include <mbgl/storage/default_file_source.hpp>
|
|
#include <mbgl/storage/default/request.hpp>
|
|
#include <mbgl/util/util.hpp>
|
|
#include <mbgl/util/noncopyable.hpp>
|
|
|
|
#include <string>
|
|
#include <set>
|
|
#include <vector>
|
|
#include <cassert>
|
|
|
|
typedef struct uv_loop_s uv_loop_t;
|
|
|
|
namespace mbgl {
|
|
|
|
class Request;
|
|
class Response;
|
|
class DefaultFileSource;
|
|
|
|
class SharedRequestBase : private util::noncopyable {
|
|
protected:
|
|
MBGL_STORE_THREAD(tid)
|
|
|
|
public:
|
|
SharedRequestBase(DefaultFileSource *source_, const Resource &resource_)
|
|
: resource(resource_), source(source_) {}
|
|
|
|
virtual void start(uv_loop_t *loop, std::unique_ptr<Response> response = nullptr) = 0;
|
|
virtual void cancel() = 0;
|
|
|
|
void notify(std::unique_ptr<Response> response, FileCache::Hint hint) {
|
|
MBGL_VERIFY_THREAD(tid);
|
|
|
|
if (source) {
|
|
source->notify(this, observers, std::shared_ptr<const Response>(std::move(response)),
|
|
hint);
|
|
}
|
|
}
|
|
|
|
void subscribe(Request *request) {
|
|
MBGL_VERIFY_THREAD(tid);
|
|
|
|
observers.insert(request);
|
|
}
|
|
|
|
void unsubscribe(Request *request) {
|
|
MBGL_VERIFY_THREAD(tid);
|
|
|
|
observers.erase(request);
|
|
|
|
if (abandoned()) {
|
|
// There are no observers anymore. We are initiating cancelation.
|
|
if (source) {
|
|
// First, remove this SharedRequestBase from the source.
|
|
source->notify(this, observers, nullptr, FileCache::Hint::No);
|
|
}
|
|
|
|
// Then, initiate cancelation of this request
|
|
cancel();
|
|
}
|
|
}
|
|
|
|
bool abandoned() const {
|
|
return observers.empty();
|
|
}
|
|
|
|
std::vector<Request *> removeAllInEnvironment(const Environment &env) {
|
|
MBGL_VERIFY_THREAD(tid);
|
|
|
|
std::vector<Request *> result;
|
|
|
|
// Removes all Requests in the supplied environment and returns a list
|
|
// of them.
|
|
util::erase_if(observers, [&](Request *req) -> bool {
|
|
if (&req->env == &env) {
|
|
result.push_back(req);
|
|
return true;
|
|
} else {
|
|
return false;
|
|
}
|
|
});
|
|
|
|
return result;
|
|
}
|
|
|
|
protected:
|
|
virtual ~SharedRequestBase() {
|
|
MBGL_VERIFY_THREAD(tid);
|
|
}
|
|
|
|
public:
|
|
const Resource resource;
|
|
|
|
protected:
|
|
DefaultFileSource *source = nullptr;
|
|
|
|
private:
|
|
std::set<Request *> observers;
|
|
};
|
|
|
|
}
|
|
|
|
#endif
|