diff options
Diffstat (limited to 'src/engine/Engine.cpp')
| -rw-r--r-- | src/engine/Engine.cpp | 225 |
1 files changed, 0 insertions, 225 deletions
diff --git a/src/engine/Engine.cpp b/src/engine/Engine.cpp deleted file mode 100644 index 357604ed..00000000 --- a/src/engine/Engine.cpp +++ /dev/null @@ -1,225 +0,0 @@ -/* This file is part of Ingen. - * Copyright 2007-2011 David Robillard <http://drobilla.net> - * - * Ingen is free software; you can redistribute it and/or modify it under the - * terms of the GNU General Public License as published by the Free Software - * Foundation; either version 2 of the License, or (at your option) 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 General Public License for details. - * - * You should have received a copy of the GNU General Public License along - * with this program; if not, write to the Free Software Foundation, Inc., - * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA - */ - -#include <cassert> -#include <sys/mman.h> -#include <unistd.h> -#include "raul/log.hpp" -#include "raul/Deletable.hpp" -#include "raul/Maid.hpp" -#include "raul/SharedPtr.hpp" -#include "lv2/lv2plug.in/ns/ext/uri-map/uri-map.h" -#include "ingen/EventType.hpp" -#include "events/CreatePatch.hpp" -#include "events/CreatePort.hpp" -#include "shared/World.hpp" -#include "shared/LV2Features.hpp" -#include "shared/LV2URIMap.hpp" -#include "shared/Store.hpp" -#include "BufferFactory.hpp" -#include "ClientBroadcaster.hpp" -#include "ControlBindings.hpp" -#include "Driver.hpp" -#include "Engine.hpp" -#include "EngineStore.hpp" -#include "Event.hpp" -#include "EventSource.hpp" -#include "MessageContext.hpp" -#include "NodeFactory.hpp" -#include "PatchImpl.hpp" -#include "PostProcessor.hpp" -#include "ProcessContext.hpp" -#include "QueuedEngineInterface.hpp" -#include "ThreadManager.hpp" - -using namespace std; -using namespace Raul; - -namespace Ingen { -namespace Engine { - -bool ThreadManager::single_threaded = true; - -Engine::Engine(Ingen::Shared::World* a_world) - : _world(a_world) - , _broadcaster(new ClientBroadcaster()) - , _buffer_factory(new BufferFactory(*this, a_world->uris())) - , _control_bindings(new ControlBindings(*this)) - , _maid(new Raul::Maid(event_queue_size())) - , _message_context(new MessageContext(*this)) - , _node_factory(new NodeFactory(a_world)) - , _post_processor(new PostProcessor(*this, event_queue_size())) -{ - if (a_world->store()) { - assert(PtrCast<EngineStore>(a_world->store())); - } else { - a_world->set_store(SharedPtr<Ingen::Shared::Store>(new EngineStore())); - } -} - -Engine::~Engine() -{ - deactivate(); - - SharedPtr<EngineStore> store = engine_store(); - if (store) - for (EngineStore::iterator i = store->begin(); i != store->end(); ++i) - if ( ! PtrCast<GraphObjectImpl>(i->second)->parent() ) - i->second.reset(); - - delete _maid; - delete _post_processor; - delete _node_factory; - delete _broadcaster; - - munlockall(); -} - -SharedPtr<EngineStore> -Engine::engine_store() const -{ - return PtrCast<EngineStore>(_world->store()); -} - -size_t -Engine::event_queue_size() const -{ - return world()->conf()->option("queue-size").get_int32(); -} - -void -Engine::quit() -{ - _quit_flag = true; -} - -bool -Engine::main_iteration() -{ - _post_processor->process(); - _maid->cleanup(); - return !_quit_flag; -} - -void -Engine::add_event_source(SharedPtr<EventSource> source) -{ - _event_sources.insert(source); -} - -void -Engine::set_driver(SharedPtr<Driver> driver) -{ - _driver = driver; -} - -static void -execute_and_delete_event(ProcessContext& context, QueuedEvent* ev) -{ - ev->pre_process(); - ev->execute(context); - ev->post_process(); - delete ev; -} - -bool -Engine::activate() -{ - assert(_driver); - ThreadManager::single_threaded = true; - - _buffer_factory->set_block_length(_driver->block_length()); - - _message_context->Thread::start(); - - const Ingen::Shared::LV2URIMap& uris = *world()->uris().get(); - - // Create root patch - PatchImpl* root_patch = _driver->root_patch(); - if (!root_patch) { - root_patch = new PatchImpl(*this, "root", 1, NULL, _driver->sample_rate(), 1); - root_patch->set_property(uris.rdf_type, - Resource::Property(uris.ingen_Patch, Resource::INTERNAL)); - root_patch->set_property(uris.ingen_polyphony, - Resource::Property(Raul::Atom(int32_t(1)), - Resource::INTERNAL)); - root_patch->activate(*_buffer_factory); - _world->store()->add(root_patch); - root_patch->compiled_patch(root_patch->compile()); - _driver->set_root_patch(root_patch); - - ProcessContext context(*this); - - Resource::Properties control_properties; - control_properties.insert(make_pair(uris.lv2_name, "Control")); - control_properties.insert(make_pair(uris.rdf_type, uris.ev_EventPort)); - - // Add control input - Resource::Properties in_properties(control_properties); - in_properties.insert(make_pair(uris.rdf_type, uris.lv2_InputPort)); - in_properties.insert(make_pair(uris.lv2_index, 0)); - in_properties.insert(make_pair(uris.ingenui_canvas_x, - Resource::Property(32.0f, Resource::EXTERNAL))); - in_properties.insert(make_pair(uris.ingenui_canvas_y, - Resource::Property(32.0f, Resource::EXTERNAL))); - - execute_and_delete_event(context, new Events::CreatePort( - *this, SharedPtr<Request>(), 0, - "/control_in", uris.ev_EventPort, false, in_properties)); - - // Add control out - Resource::Properties out_properties(control_properties); - out_properties.insert(make_pair(uris.rdf_type, uris.lv2_OutputPort)); - out_properties.insert(make_pair(uris.lv2_index, 1)); - out_properties.insert(make_pair(uris.ingenui_canvas_x, - Resource::Property(128.0f, Resource::EXTERNAL))); - out_properties.insert(make_pair(uris.ingenui_canvas_y, - Resource::Property(32.0f, Resource::EXTERNAL))); - - execute_and_delete_event(context, new Events::CreatePort( - *this, SharedPtr<Request>(), 0, - "/control_out", uris.ev_EventPort, true, out_properties)); - } - - _driver->activate(); - root_patch->enable(); - - ThreadManager::single_threaded = false; - - return true; -} - -void -Engine::deactivate() -{ - _driver->deactivate(); - _driver->root_patch()->deactivate(); - - ThreadManager::single_threaded = true; -} - -void -Engine::process_events(ProcessContext& context) -{ - ThreadManager::assert_thread(THREAD_PROCESS); - - for (EventSources::iterator i = _event_sources.begin(); i != _event_sources.end(); ++i) - (*i)->process(*_post_processor, context); -} - -} // namespace Engine -} // namespace Ingen |