From 29baacf3a5bb773d94d08d16b81c3cda45a44eb6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Konstantin=20K=C3=A4fer?= <mail@kkaefer.com>
Date: Thu, 29 Jan 2015 18:30:46 +0100
Subject: refactor makefile

---
 include/mbgl/storage/default_file_source.hpp | 60 ++++++++++++++++++++++++++++
 1 file changed, 60 insertions(+)
 create mode 100644 include/mbgl/storage/default_file_source.hpp

(limited to 'include/mbgl/storage/default_file_source.hpp')

diff --git a/include/mbgl/storage/default_file_source.hpp b/include/mbgl/storage/default_file_source.hpp
new file mode 100644
index 0000000000..21048e99e5
--- /dev/null
+++ b/include/mbgl/storage/default_file_source.hpp
@@ -0,0 +1,60 @@
+#ifndef MBGL_STORAGE_DEFAULT_DEFAULT_FILE_SOURCE
+#define MBGL_STORAGE_DEFAULT_DEFAULT_FILE_SOURCE
+
+#include <mbgl/storage/file_source.hpp>
+#include <mbgl/storage/file_cache.hpp>
+
+#include <set>
+#include <unordered_map>
+#include <thread>
+
+namespace mapbox { namespace util { template<typename... Types> class variant; } }
+
+namespace mbgl {
+
+namespace util { template <typename T> class AsyncQueue; }
+
+class SharedRequestBase;
+
+class DefaultFileSource : public FileSource {
+public:
+    DefaultFileSource(FileCache *cache);
+    DefaultFileSource(FileCache *cache, uv_loop_t *loop);
+    ~DefaultFileSource();
+
+    Request *request(const Resource &resource, uv_loop_t *loop, Callback callback);
+    void cancel(Request *request);
+    void request(const Resource &resource, Callback callback);
+
+    enum class CacheHint : uint8_t { Full, Refresh, No };
+    void notify(SharedRequestBase *sharedRequest, const std::set<Request *> &observers,
+                std::shared_ptr<const Response> response, FileCache::Hint hint);
+
+private:
+    struct ActionDispatcher;
+    struct AddRequestAction;
+    struct RemoveRequestAction;
+    struct ResultAction;
+    struct StopAction;
+    using Action =
+        mapbox::util::variant<AddRequestAction, RemoveRequestAction, ResultAction, StopAction>;
+    using Queue = util::AsyncQueue<Action>;
+
+    void process(AddRequestAction &action);
+    void process(RemoveRequestAction &action);
+    void process(ResultAction &action);
+    void process(StopAction &action);
+
+    SharedRequestBase *find(const Resource &resource);
+
+    std::unordered_map<Resource, SharedRequestBase *, Resource::Hash> pending;
+
+    uv_loop_t *loop = nullptr;
+    FileCache *cache = nullptr;
+    Queue *queue = nullptr;
+    std::thread thread;
+};
+
+}
+
+#endif
-- 
cgit v1.2.1