20 #ifndef MIR_FRONTEND_DETAIL_SOCKET_SESSION_H_
21 #define MIR_FRONTEND_DETAIL_SOCKET_SESSION_H_
25 #include <boost/asio.hpp>
27 #include <sys/types.h>
35 class MessageProcessor;
36 class MessageReceiver;
41 std::shared_ptr<MessageReceiver>
const& socket_receiver,
44 std::shared_ptr<MessageProcessor>
const& processor);
48 int id()
const {
return id_; }
53 void on_response_sent(boost::system::error_code
const&
error, std::size_t);
54 void on_new_message(
const boost::system::error_code& ec);
55 void on_read_size(
const boost::system::error_code& ec);
57 std::shared_ptr<MessageReceiver>
const socket_receiver;
59 std::shared_ptr<ConnectedSessions<SocketSession>>
const connected_sessions;
60 std::shared_ptr<MessageProcessor> processor;
62 static size_t const header_size = 2;
63 char header[header_size];
64 std::vector<char> body;
Definition: connected_sessions.h:33
Definition: socket_session.h:38
SocketSession(std::shared_ptr< MessageReceiver > const &socket_receiver, int id_, std::shared_ptr< ConnectedSessions< SocketSession >> const &connected_sessions, std::shared_ptr< MessageProcessor > const &processor)
Definition: socket_session.cpp:39
int id() const
Definition: socket_session.h:48
~SocketSession() noexcept
Definition: socket_session.cpp:51
error
Definition: connector_report_tp.h:60
void read_next_message()
Definition: socket_session.cpp:56