19
19
#include " pplx/threadpool.h"
20
20
#include " http_server.h"
21
21
22
- using boost::asio::ip::tcp;
23
- using namespace boost ::asio;
24
-
25
- #define FAILED (x ) ((x) != 0 )
26
-
27
22
namespace web
28
23
{
29
-
30
24
namespace http
31
25
{
32
-
33
26
namespace experimental
34
27
{
35
-
36
28
namespace listener
37
29
{
38
30
@@ -41,7 +33,6 @@ class http_linux_server;
41
33
namespace details
42
34
{
43
35
44
-
45
36
struct linux_request_context : web::http::details::_http_server_context
46
37
{
47
38
linux_request_context (){}
@@ -58,7 +49,7 @@ class hostport_listener;
58
49
class connection
59
50
{
60
51
private:
61
- std::unique_ptr<tcp::socket> m_socket;
52
+ std::unique_ptr<boost::asio::ip:: tcp::socket> m_socket;
62
53
boost::asio::streambuf m_request_buf;
63
54
boost::asio::streambuf m_response_buf;
64
55
http_linux_server* m_p_server;
@@ -71,7 +62,7 @@ class connection
71
62
std::atomic<int > m_refs; // track how many threads are still referring to this
72
63
73
64
public:
74
- connection (std::unique_ptr<tcp::socket> socket, http_linux_server* server, hostport_listener* parent)
65
+ connection (std::unique_ptr<boost::asio::ip:: tcp::socket> socket, http_linux_server* server, hostport_listener* parent)
75
66
: m_socket(std::move(socket))
76
67
, m_request_buf()
77
68
, m_response_buf()
@@ -113,7 +104,7 @@ class hostport_listener
113
104
private:
114
105
friend class connection ;
115
106
116
- std::unique_ptr<tcp::acceptor> m_acceptor;
107
+ std::unique_ptr<boost::asio::ip:: tcp::acceptor> m_acceptor;
117
108
std::map<std::string, web::http::experimental::listener::details::http_listener_impl* > m_listeners;
118
109
pplx::extensibility::reader_writer_lock_t m_listeners_lock;
119
110
@@ -155,14 +146,12 @@ class hostport_listener
155
146
void remove_listener (const std::string& path, web::http::experimental::listener::details::http_listener_impl* listener);
156
147
157
148
private:
158
- void on_accept (ip::tcp::socket* socket, const boost::system::error_code& ec);
149
+ void on_accept (boost::asio:: ip::tcp::socket* socket, const boost::system::error_code& ec);
159
150
160
151
};
161
152
162
153
}
163
154
164
- using namespace http ::experimental::listener::details;
165
-
166
155
struct iequal_to
167
156
{
168
157
bool operator ()(const std::string& left, const std::string& right) const
@@ -177,8 +166,8 @@ class http_linux_server : public web::http::experimental::details::http_server
177
166
friend class http ::experimental::listener::details::connection;
178
167
179
168
pplx::extensibility::reader_writer_lock_t m_listeners_lock;
180
- std::map<std::string, std::unique_ptr<hostport_listener>, iequal_to> m_listeners;
181
- std::unordered_map<web::http::experimental::listener:: details::http_listener_impl *, std::unique_ptr<pplx::extensibility::reader_writer_lock_t >> m_registered_listeners;
169
+ std::map<std::string, std::unique_ptr<details:: hostport_listener>, iequal_to> m_listeners;
170
+ std::unordered_map<details::http_listener_impl *, std::unique_ptr<pplx::extensibility::reader_writer_lock_t >> m_registered_listeners;
182
171
bool m_started;
183
172
184
173
public:
@@ -202,7 +191,4 @@ class http_linux_server : public web::http::experimental::details::http_server
202
191
pplx::task<void > respond (http::http_response response);
203
192
};
204
193
205
- }
206
- }
207
- }
208
- }
194
+ }}}}
0 commit comments