~raof/mir/rootless-xserver-work

Viewing changes to src/server/frontend/socket_session.cpp

Committer: Tarmac
Author(s): Alan Griffiths
Date: 2014-01-17 13:53:05 UTC
mfrom: (1333.2.12 mir)
Revision ID: tarmac-20140117135305-92ioysypng39cssc

frontend: refactoring to make it easier to expose the underlying RPC transport on the server side.

Approved by Alexandros Frantzis, Kevin DuBois, PS Jenkins bot.

files added:
include/server/mir/frontend/protobuf_message_sender.h

include/server/mir/frontend/template_protobuf_message_processor.h

src/server/frontend/template_protobuf_message_processor.cpp

files renamed:
src/server/frontend/fd_sets.h => include/server/mir/frontend/fd_sets.h

src/server/frontend/message_processor.h => include/server/mir/frontend/message_processor.h

src/server/frontend/protobuf_response_processor.cpp => src/server/frontend/protobuf_responder.cpp

src/server/frontend/protobuf_response_processor.h => src/server/frontend/protobuf_responder.h

files modified:
include/test/mir_test_doubles/stub_ipc_factory.h

src/server/frontend/CMakeLists.txt

src/server/frontend/default_configuration.cpp

src/server/frontend/event_sender.cpp

src/server/frontend/message_sender.h

src/server/frontend/null_message_processor.cpp

src/server/frontend/protobuf_ipc_factory.h

src/server/frontend/protobuf_message_processor.cpp

src/server/frontend/protobuf_message_processor.h

src/server/frontend/protobuf_session_creator.cpp

src/server/frontend/protobuf_session_creator.h

src/server/frontend/socket_messenger.cpp

src/server/frontend/socket_session.cpp

src/server/frontend/socket_session.h

tests/mir_test_doubles/test_protobuf_socket_server.cpp

tests/unit-tests/frontend/test_event_sender.cpp

tests/unit-tests/frontend/test_published_socket_connector.cpp

tests/unit-tests/frontend/test_socket_session.cpp

Show diffs side-by-side

added added

removed removed

src/server/frontend/socket_session.cpp

#include "socket_session.h"

#include "message_processor.h"

#include "message_sender.h"

#include "message_receiver.h"

#include "mir/frontend/message_processor.h"

#include <boost/signals2.hpp>

#include <boost/throw_exception.hpp>

}

void mfd::SocketSession::on_new_message(const boost::system::error_code& error)

try

{

if (error)

{

connected_sessions->remove(id());

BOOST_THROW_EXCEPTION(std::runtime_error(error.message()));

}

connected_sessions->remove(id());

}

catch (...)

{

100

connected_sessions->remove(id());

101

throw;

102

}

103

104

void mfd::SocketSession::on_response_sent(bs::error_code const& error, std::size_t)

100

105

{

Older »