summaryrefslogtreecommitdiffstats
path: root/src/server/HTTPEngineReceiver.cpp
diff options
context:
space:
mode:
authorDavid Robillard <d@drobilla.net>2011-10-21 22:29:51 +0000
committerDavid Robillard <d@drobilla.net>2011-10-21 22:29:51 +0000
commit20b765b8befa32eed913e16d68f03a65459a605d (patch)
tree955dda8e59707c7dc0149288b31187d071518ce4 /src/server/HTTPEngineReceiver.cpp
parente928751490386d4ec028a3314ebc89cdd25ea45d (diff)
downloadingen-20b765b8befa32eed913e16d68f03a65459a605d.tar.gz
ingen-20b765b8befa32eed913e16d68f03a65459a605d.tar.bz2
ingen-20b765b8befa32eed913e16d68f03a65459a605d.zip
Make engine receivers depend only on ServerInterface.
git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@3572 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/server/HTTPEngineReceiver.cpp')
-rw-r--r--src/server/HTTPEngineReceiver.cpp22
1 files changed, 7 insertions, 15 deletions
diff --git a/src/server/HTTPEngineReceiver.cpp b/src/server/HTTPEngineReceiver.cpp
index 69859ad2..a7b4ee1f 100644
--- a/src/server/HTTPEngineReceiver.cpp
+++ b/src/server/HTTPEngineReceiver.cpp
@@ -27,18 +27,16 @@
#include "raul/log.hpp"
#include "ingen/ClientInterface.hpp"
-#include "ingen/shared/Module.hpp"
+#include "ingen/ServerInterface.hpp"
#include "ingen/serialisation/Parser.hpp"
#include "ingen/serialisation/Serialiser.hpp"
+#include "ingen/shared/Module.hpp"
+#include "ingen/shared/Store.hpp"
#include "ClientBroadcaster.hpp"
#include "Engine.hpp"
-#include "EngineStore.hpp"
-#include "EventSource.hpp"
#include "HTTPClientSender.hpp"
#include "HTTPEngineReceiver.hpp"
-#include "ServerInterfaceImpl.hpp"
-#include "ThreadManager.hpp"
#define LOG(s) s << "[HTTPEngineReceiver] "
@@ -51,9 +49,9 @@ using namespace Serialisation;
namespace Server {
-HTTPEngineReceiver::HTTPEngineReceiver(Engine& engine,
- SharedPtr<ServerInterfaceImpl> interface,
- uint16_t port)
+HTTPEngineReceiver::HTTPEngineReceiver(Engine& engine,
+ SharedPtr<ServerInterface> interface,
+ uint16_t port)
: _engine(engine)
, _interface(interface)
, _server(soup_server_new(SOUP_SERVER_PORT, port, NULL))
@@ -67,8 +65,6 @@ HTTPEngineReceiver::HTTPEngineReceiver(Engine& engine,
if (!engine.world()->parser() || !engine.world()->serialiser())
engine.world()->load_module("serialisation");
- _interface->set_name("HTTPEngineReceiver");
- _interface->start();
_receive_thread->set_name("HTTPEngineReceiver Listener");
_receive_thread->start();
}
@@ -76,7 +72,6 @@ HTTPEngineReceiver::HTTPEngineReceiver(Engine& engine,
HTTPEngineReceiver::~HTTPEngineReceiver()
{
_receive_thread->stop();
- _interface->stop();
delete _receive_thread;
if (_server) {
@@ -94,7 +89,7 @@ HTTPEngineReceiver::message_callback(SoupServer* server,
void* data)
{
HTTPEngineReceiver* me = (HTTPEngineReceiver*)data;
- ServerInterfaceImpl* interface = me->_interface.get();
+ ServerInterface* interface = me->_interface.get();
using namespace Ingen::Shared;
@@ -221,9 +216,6 @@ HTTPEngineReceiver::message_callback(SoupServer* server,
}
}
-/** Override the semaphore driven _run method of ServerInterfaceImpl
- * to wait on HTTP requests and process them immediately in this thread.
- */
void
HTTPEngineReceiver::ReceiveThread::_run()
{