summaryrefslogtreecommitdiffstats
path: root/src/server/Engine.cpp
diff options
context:
space:
mode:
authorDavid Robillard <d@drobilla.net>2012-05-03 08:07:59 +0000
committerDavid Robillard <d@drobilla.net>2012-05-03 08:07:59 +0000
commit628e2f1606aead224c317d17b3e038122db61110 (patch)
treed1345665fbf3e36404ebe1bad3ba395bfe8e2fd1 /src/server/Engine.cpp
parent02dcc06a1675e936ef85714827accb20a9f2a94c (diff)
downloadingen-628e2f1606aead224c317d17b3e038122db61110.tar.gz
ingen-628e2f1606aead224c317d17b3e038122db61110.tar.bz2
ingen-628e2f1606aead224c317d17b3e038122db61110.zip
Real-time safe event source management (oops).
git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@4321 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/server/Engine.cpp')
-rw-r--r--src/server/Engine.cpp23
1 files changed, 15 insertions, 8 deletions
diff --git a/src/server/Engine.cpp b/src/server/Engine.cpp
index 77630d54..7138d2ea 100644
--- a/src/server/Engine.cpp
+++ b/src/server/Engine.cpp
@@ -125,7 +125,10 @@ Engine::main_iteration()
void
Engine::add_event_source(SharedPtr<EventSource> source)
{
- _event_sources.insert(source);
+ // FIXME: Not thread-safe
+ _maid->manage(source);
+ source->_next = _event_sources;
+ _event_sources = source;
}
void
@@ -237,14 +240,18 @@ Engine::process_events(ProcessContext& context)
{
ThreadManager::assert_thread(THREAD_PROCESS);
- EventSources::iterator i = _event_sources.begin();
- while (i != _event_sources.end()) {
- EventSources::iterator next = i;
- ++next;
- if (!(*i)->process(*_post_processor, context)) {
- _event_sources.erase(i);
+ SharedPtr<EventSource> src = _event_sources;
+ SharedPtr<EventSource> prev = src;
+ for (; src; src = src->_next) {
+ if (!src->process(*_post_processor, context)) {
+ // Source is finished, remove
+ if (src == _event_sources) {
+ _event_sources = src->_next;
+ } else {
+ prev->_next = src->_next;
+ }
}
- i = next;
+ prev = src;
}
}