diff options
Diffstat (limited to 'src/server/EventSource.cpp')
-rw-r--r-- | src/server/EventSource.cpp | 126 |
1 files changed, 0 insertions, 126 deletions
diff --git a/src/server/EventSource.cpp b/src/server/EventSource.cpp deleted file mode 100644 index a8eb3ec4..00000000 --- a/src/server/EventSource.cpp +++ /dev/null @@ -1,126 +0,0 @@ -/* - 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 "EventSource.hpp" -#include "PostProcessor.hpp" -#include "ProcessContext.hpp" -#include "Event.hpp" -#include "ThreadManager.hpp" - -using namespace std; - -namespace Ingen { -namespace Server { - -EventSource::EventSource() -{ - Thread::set_context(THREAD_PRE_PROCESS); - set_name("EventSource"); -} - -EventSource::~EventSource() -{ - Thread::stop(); -} - -/** Push an unprepared event onto the queue. - */ -void -EventSource::push_queued(Event* const ev) -{ - assert(!ev->is_prepared()); - assert(!ev->next()); - - Event* const head = _head.get(); - Event* const tail = _tail.get(); - - if (!head) { - _head = ev; - _tail = ev; - } else { - _tail = ev; - tail->next(ev); - } - - if (!_prepared_back.get()) { - _prepared_back = ev; - } - - whip(); -} - -/** Process all events for a cycle. - * - * Executed events will be pushed to @a dest. - */ -void -EventSource::process(PostProcessor& dest, ProcessContext& context, bool limit) -{ - ThreadManager::assert_thread(THREAD_PROCESS); - - if (!_head.get()) - return; - - /* Limit the maximum number of queued events to process per cycle. This - makes the process callback (more) realtime-safe by preventing being - choked by events coming in faster than they can be processed. - FIXME: test this and figure out a good value - */ - const size_t MAX_QUEUED_EVENTS = context.nframes() / 32; - - size_t num_events_processed = 0; - - Event* ev = _head.get(); - Event* last = ev; - - while (ev && ev->is_prepared() && ev->time() < context.end()) { - ev->execute(context); - last = ev; - ev = (Event*)ev->next(); - ++num_events_processed; - if (limit && (num_events_processed > MAX_QUEUED_EVENTS)) - break; - } - - if (num_events_processed > 0) { - Event* next = (Event*)last->next(); - last->next(NULL); - assert(!last->next()); - dest.append(_head.get(), last); - _head = next; - if (!next) - _tail = NULL; - } -} - -/** Pre-process a single event */ -void -EventSource::_whipped() -{ - Event* ev = _prepared_back.get(); - if (!ev) - return; - - assert(!ev->is_prepared()); - ev->pre_process(); - assert(ev->is_prepared()); - - _prepared_back = (Event*)ev->next(); -} - -} // namespace Server -} // namespace Ingen - |