summaryrefslogtreecommitdiff
path: root/src/mbgl/storage/default_file_source_impl.hpp
blob: bb28933798375579d9bd847c693a42711ac7848e (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
#ifndef MBGL_STORAGE_DEFAULT_DEFAULT_FILE_SOURCE_IMPL
#define MBGL_STORAGE_DEFAULT_DEFAULT_FILE_SOURCE_IMPL

#include <mbgl/storage/default_file_source.hpp>
#include <mbgl/storage/asset_context_base.hpp>
#include <mbgl/storage/http_context_base.hpp>

#include <set>
#include <unordered_map>

namespace mbgl {

class RequestBase;

struct DefaultFileRequest {
    const Resource resource;
    std::set<Request*> observers;

    std::unique_ptr<WorkRequest> cacheRequest;
    RequestBase* realRequest = nullptr;

    inline DefaultFileRequest(const Resource& resource_)
        : resource(resource_) {}

    // Make it movable-only
    DefaultFileRequest(const DefaultFileRequest&) = delete;
    inline DefaultFileRequest(DefaultFileRequest&&) = default;
    DefaultFileRequest& operator=(const DefaultFileRequest&) = delete;
    inline DefaultFileRequest& operator=(DefaultFileRequest&&) = default;
};

class DefaultFileSource::Impl {
public:
    Impl(FileCache*, const std::string& = "");

    void add(Request*);
    void cancel(Request*);

private:
    DefaultFileRequest* find(const Resource&);

    void startCacheRequest(DefaultFileRequest*);
    void startRealRequest(DefaultFileRequest*, std::shared_ptr<const Response> = nullptr);
    void notify(DefaultFileRequest*, std::shared_ptr<const Response>, FileCache::Hint);

    std::unordered_map<Resource, DefaultFileRequest, Resource::Hash> pending;
    uv_loop_t* loop = nullptr;
    FileCache* cache = nullptr;
    const std::string assetRoot;
    std::unique_ptr<AssetContextBase> assetContext;
    std::unique_ptr<HTTPContextBase> httpContext;
};

}

#endif