aboutsummaryrefslogtreecommitdiff
path: root/src/zenhttp/servers/wsasio.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/zenhttp/servers/wsasio.h')
-rw-r--r--src/zenhttp/servers/wsasio.h8
1 files changed, 7 insertions, 1 deletions
diff --git a/src/zenhttp/servers/wsasio.h b/src/zenhttp/servers/wsasio.h
index d8ffdc00a..e8bb3b1d2 100644
--- a/src/zenhttp/servers/wsasio.h
+++ b/src/zenhttp/servers/wsasio.h
@@ -14,6 +14,10 @@ ZEN_THIRD_PARTY_INCLUDES_END
#include <memory>
#include <vector>
+namespace zen {
+class HttpServer;
+} // namespace zen
+
namespace zen::asio_http {
/**
@@ -27,10 +31,11 @@ namespace zen::asio_http {
* connection alive for the duration of the async operation. The service layer
* also holds a Ref<WebSocketConnection>.
*/
+
class WsAsioConnection : public WebSocketConnection
{
public:
- WsAsioConnection(std::unique_ptr<asio::ip::tcp::socket> Socket, IWebSocketHandler& Handler);
+ WsAsioConnection(std::unique_ptr<asio::ip::tcp::socket> Socket, IWebSocketHandler& Handler, HttpServer* Server);
~WsAsioConnection() override;
/**
@@ -58,6 +63,7 @@ private:
std::unique_ptr<asio::ip::tcp::socket> m_Socket;
IWebSocketHandler& m_Handler;
+ zen::HttpServer* m_HttpServer;
asio::streambuf m_ReadBuffer;
RwLock m_WriteLock;