diff options
author | David Robillard <d@drobilla.net> | 2012-05-03 05:43:19 +0000 |
---|---|---|
committer | David Robillard <d@drobilla.net> | 2012-05-03 05:43:19 +0000 |
commit | 02dcc06a1675e936ef85714827accb20a9f2a94c (patch) | |
tree | e1980d770736b64b6652c4afed6f2a7bb3ba3858 /src/socket/SocketInterface.hpp | |
parent | 9ae720fdc60d7e40b1b8be7c1133a57acb4e564c (diff) | |
download | ingen-02dcc06a1675e936ef85714827accb20a9f2a94c.tar.gz ingen-02dcc06a1675e936ef85714827accb20a9f2a94c.tar.bz2 ingen-02dcc06a1675e936ef85714827accb20a9f2a94c.zip |
Work towards a proper server infrastructure with a thread per connection.
git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@4320 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/socket/SocketInterface.hpp')
-rw-r--r-- | src/socket/SocketInterface.hpp | 58 |
1 files changed, 58 insertions, 0 deletions
diff --git a/src/socket/SocketInterface.hpp b/src/socket/SocketInterface.hpp new file mode 100644 index 00000000..2a23cc64 --- /dev/null +++ b/src/socket/SocketInterface.hpp @@ -0,0 +1,58 @@ +/* + This file is part of Ingen. + Copyright 2007-2012 David Robillard <http://drobilla.net/> + + Ingen is free software: you can redistribute it and/or modify it under the + terms of the GNU Affero General Public License as published by the Free + Software Foundation, either version 3 of the License, or any later version. + + Ingen is distributed in the hope that it will be useful, but WITHOUT ANY + WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR + A PARTICULAR PURPOSE. See the GNU Affero General Public License for details. + + You should have received a copy of the GNU Affero General Public License + along with Ingen. If not, see <http://www.gnu.org/licenses/>. +*/ + +#include <string> + +#include "raul/SharedPtr.hpp" +#include "raul/Thread.hpp" +#include "ingen/Interface.hpp" + +#include "../server/EventSink.hpp" +#include "../server/EventSource.hpp" +#include "../server/EventWriter.hpp" + +namespace Ingen { + +namespace Shared { class World; } + +namespace Socket { + +class SocketInterface : public Raul::Thread + , public Server::EventSink + , public Server::EventSource +{ +public: + SocketInterface(Shared::World& world, int conn); + + void event(Server::Event* ev); + + bool process(Server::PostProcessor& dest, + Server::ProcessContext& context, + bool limit = true); + + ~SocketInterface(); + +private: + virtual void _run(); + + Shared::World& _world; + Server::EventWriter _iface; + Server::Event* _event; + int _conn; +}; + +} // namespace Ingen +} // namespace Socket |