|
22 | 22 | #error "Only <httpserver.hpp> or <httpserverpp> can be included directly." |
23 | 23 | #endif |
24 | 24 |
|
25 | | -#ifndef _DEFERRED_RESPONSE_HPP_ |
26 | | -#define _DEFERRED_RESPONSE_HPP_ |
| 25 | +#ifndef SRC_HTTPSERVER_DEFERRED_RESPONSE_HPP_ |
| 26 | +#define SRC_HTTPSERVER_DEFERRED_RESPONSE_HPP_ |
27 | 27 |
|
28 | 28 | #include <stddef.h> |
29 | 29 | #include <stdint.h> |
|
35 | 35 |
|
36 | 36 | struct MHD_Response; |
37 | 37 |
|
38 | | -namespace httpserver |
39 | | -{ |
| 38 | +namespace httpserver { |
40 | 39 |
|
41 | | -namespace details |
42 | | -{ |
| 40 | +namespace details { |
43 | 41 | MHD_Response* get_raw_response_helper(void* cls, ssize_t (*cb)(void*, uint64_t, char*, size_t)); |
44 | 42 | } |
45 | 43 |
|
46 | 44 | template <class T> |
47 | | -class deferred_response : public string_response |
48 | | -{ |
49 | | - public: |
50 | | - explicit deferred_response( |
51 | | - ssize_t(*cycle_callback)(std::shared_ptr<T>, char*, size_t), |
52 | | - std::shared_ptr<T> closure_data, |
53 | | - const std::string& content = "", |
54 | | - int response_code = http::http_utils::http_ok, |
55 | | - const std::string& content_type = http::http_utils::text_plain |
56 | | - ): |
57 | | - string_response(content, response_code, content_type), |
58 | | - cycle_callback(cycle_callback), |
59 | | - closure_data(closure_data) |
60 | | - { |
61 | | - } |
62 | | - |
63 | | - deferred_response(const deferred_response& other) = default; |
64 | | - deferred_response(deferred_response&& other) noexcept = default; |
65 | | - deferred_response& operator=(const deferred_response& b) = default; |
66 | | - deferred_response& operator=(deferred_response&& b) = default; |
67 | | - |
68 | | - ~deferred_response() = default; |
69 | | - |
70 | | - MHD_Response* get_raw_response() |
71 | | - { |
72 | | - return details::get_raw_response_helper((void*) this, &cb); |
73 | | - } |
74 | | - |
75 | | - private: |
76 | | - ssize_t (*cycle_callback)(std::shared_ptr<T>, char*, size_t); |
77 | | - std::shared_ptr<T> closure_data; |
78 | | - |
79 | | - static ssize_t cb(void* cls, uint64_t, char* buf, size_t max) |
80 | | - { |
81 | | - deferred_response<T>* dfr = static_cast<deferred_response<T>*>(cls); |
82 | | - return dfr->cycle_callback(dfr->closure_data, buf, max); |
83 | | - } |
| 45 | +class deferred_response : public string_response { |
| 46 | + public: |
| 47 | + explicit deferred_response( |
| 48 | + ssize_t(*cycle_callback)(std::shared_ptr<T>, char*, size_t), |
| 49 | + std::shared_ptr<T> closure_data, |
| 50 | + const std::string& content = "", |
| 51 | + int response_code = http::http_utils::http_ok, |
| 52 | + const std::string& content_type = http::http_utils::text_plain): |
| 53 | + string_response(content, response_code, content_type), |
| 54 | + cycle_callback(cycle_callback), |
| 55 | + closure_data(closure_data) { } |
| 56 | + |
| 57 | + deferred_response(const deferred_response& other) = default; |
| 58 | + deferred_response(deferred_response&& other) noexcept = default; |
| 59 | + deferred_response& operator=(const deferred_response& b) = default; |
| 60 | + deferred_response& operator=(deferred_response&& b) = default; |
| 61 | + |
| 62 | + ~deferred_response() = default; |
| 63 | + |
| 64 | + MHD_Response* get_raw_response() { |
| 65 | + return details::get_raw_response_helper(reinterpret_cast<void*>(this), &cb); |
| 66 | + } |
| 67 | + |
| 68 | + private: |
| 69 | + ssize_t (*cycle_callback)(std::shared_ptr<T>, char*, size_t); |
| 70 | + std::shared_ptr<T> closure_data; |
| 71 | + |
| 72 | + static ssize_t cb(void* cls, uint64_t, char* buf, size_t max) { |
| 73 | + deferred_response<T>* dfr = static_cast<deferred_response<T>*>(cls); |
| 74 | + return dfr->cycle_callback(dfr->closure_data, buf, max); |
| 75 | + } |
84 | 76 | }; |
85 | 77 |
|
86 | | -} |
87 | | -#endif // _DEFERRED_RESPONSE_HPP_ |
| 78 | +} // namespace httpserver |
| 79 | +#endif // SRC_HTTPSERVER_DEFERRED_RESPONSE_HPP_ |
0 commit comments