boostorg/beast
1
0
Fork 1
mirror of https://github.com/boostorg/beast.git synced 2025-08-03 14:54:32 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fixes for websocket echo server:

Browse Source 
* Decorator members are const
* Enable permessage-deflate extension
This commit is contained in:
Vinnie Falco
2017-01-27 20:14:47 -05:00
parent bf7864cfc6
commit e81a2864ab
4 changed files with 16 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
CHANGELOG.md
View File

@@ -1,3 +1,9 @@
1.0.0-b25
* Fixes for WebSocket echo server
--------------------------------------------------------------------------------
1.0.0-b24 1.0.0-b24
* bjam use clang on MACOSX * bjam use clang on MACOSX

4
test/websocket/websocket_async_echo_server.hpp
View File

@@ -38,14 +38,14 @@ private:
{ {
template<class Body, class Fields> template<class Body, class Fields>
void void
operator()(http::message<true, Body, Fields>& req) operator()(http::message<true, Body, Fields>& req) const
{ {
req.fields.replace("User-Agent", "async_echo_client"); req.fields.replace("User-Agent", "async_echo_client");
} }
template<class Body, class Fields> template<class Body, class Fields>
void void
operator()(http::message<false, Body, Fields>& resp) operator()(http::message<false, Body, Fields>& resp) const
{ {
resp.fields.replace("Server", "async_echo_server"); resp.fields.replace("Server", "async_echo_server");
} }

7
test/websocket/websocket_echo.cpp
View File

@@ -18,17 +18,22 @@ int main()
try try
{ {
permessage_deflate pmd;
pmd.client_enable = true;
pmd.server_enable = true;
beast::error_code ec; beast::error_code ec;
async_echo_server s1{nullptr, 1}; async_echo_server s1{nullptr, 1};
s1.open(endpoint_type{ s1.open(endpoint_type{
address_type::from_string("127.0.0.1"), 6000 }, ec); address_type::from_string("127.0.0.1"), 6000 }, ec);
s1.set_option(read_message_max{64 * 1024 * 1024}); s1.set_option(read_message_max{64 * 1024 * 1024});
s1.set_option(auto_fragment{false}); s1.set_option(auto_fragment{false});
//s1.set_option(write_buffer_size{64 * 1024}); s1.set_option(pmd);
beast::websocket::sync_echo_server s2(&std::cout, endpoint_type{ beast::websocket::sync_echo_server s2(&std::cout, endpoint_type{
address_type::from_string("127.0.0.1"), 6001 }); address_type::from_string("127.0.0.1"), 6001 });
s2.set_option(read_message_max{64 * 1024 * 1024}); s2.set_option(read_message_max{64 * 1024 * 1024});
s2.set_option(pmd);
beast::test::sig_wait(); beast::test::sig_wait();
} }

4
test/websocket/websocket_sync_echo_server.hpp
View File

@@ -36,14 +36,14 @@ private:
{ {
template<class Body, class Fields> template<class Body, class Fields>
void void
operator()(http::message<true, Body, Fields>& req) operator()(http::message<true, Body, Fields>& req) const
{ {
req.fields.replace("User-Agent", "sync_echo_client"); req.fields.replace("User-Agent", "sync_echo_client");
} }
template<class Body, class Fields> template<class Body, class Fields>
void void
operator()(http::message<false, Body, Fields>& resp) operator()(http::message<false, Body, Fields>& resp) const
{ {
resp.fields.replace("Server", "sync_echo_server"); resp.fields.replace("Server", "sync_echo_server");
} }