From 93850c202de8b073a1ce1dd8bd246d407bce4e2f Mon Sep 17 00:00:00 2001 From: David Robillard Date: Tue, 30 Sep 2008 16:50:21 +0000 Subject: Flatten ingen source directory heirarchy a bit. git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@1551 a436a847-0d15-0410-975c-d299462d15a1 --- src/libs/gui/ConnectWindow.cpp | 458 ----------------------------------------- 1 file changed, 458 deletions(-) delete mode 100644 src/libs/gui/ConnectWindow.cpp (limited to 'src/libs/gui/ConnectWindow.cpp') diff --git a/src/libs/gui/ConnectWindow.cpp b/src/libs/gui/ConnectWindow.cpp deleted file mode 100644 index 5600a0b2..00000000 --- a/src/libs/gui/ConnectWindow.cpp +++ /dev/null @@ -1,458 +0,0 @@ -/* This file is part of Ingen. - * Copyright (C) 2007 Dave Robillard - * - * 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 -#include -#include -#include -#include -#include -#include -#include CONFIG_H_PATH -#include "interface/EngineInterface.hpp" -#include "module/World.hpp" -#include "engine/tuning.hpp" -#include "engine/Engine.hpp" -#include "engine/QueuedEngineInterface.hpp" -#include "client/OSCClientReceiver.hpp" -#include "client/HTTPClientReceiver.hpp" -#include "client/OSCEngineSender.hpp" -#include "client/ThreadedSigClientInterface.hpp" -#include "client/ClientStore.hpp" -#include "client/PatchModel.hpp" -#include "module/Module.hpp" -#include "App.hpp" -#include "WindowFactory.hpp" -#include "ConnectWindow.hpp" -using Ingen::QueuedEngineInterface; -using Ingen::Client::ThreadedSigClientInterface; -using namespace std; - -namespace Ingen { -namespace GUI { - - -// ConnectWindow - - -ConnectWindow::ConnectWindow(BaseObjectType* cobject, const Glib::RefPtr& xml) - : Gtk::Dialog(cobject) - , _xml(xml) - , _mode(CONNECT_REMOTE) - , _ping_id(-1) - , _attached(false) - , _widgets_loaded(false) - , _connect_stage(0) - , _new_engine(NULL) -{ -} - - -void -ConnectWindow::start(Ingen::Shared::World* world) -{ - if (world->local_engine) { - _mode = INTERNAL; - if (_widgets_loaded) - _internal_radio->set_active(true); - } - - set_connected_to(world->engine); - - connect(true); -} - - -void -ConnectWindow::set_connected_to(SharedPtr engine) -{ - App::instance().world()->engine = engine; - - if (!_widgets_loaded) - return; - - if (engine) { - _icon->set(Gtk::Stock::CONNECT, Gtk::ICON_SIZE_LARGE_TOOLBAR); - _progress_bar->set_fraction(1.0); - _progress_label->set_text("Connected to engine"); - _url_entry->set_sensitive(false); - _connect_button->set_sensitive(false); - _disconnect_button->set_label("gtk-disconnect"); - _disconnect_button->set_sensitive(true); - _port_spinbutton->set_sensitive(false); - _launch_radio->set_sensitive(false); - _internal_radio->set_sensitive(false); - } else { - _icon->set(Gtk::Stock::DISCONNECT, Gtk::ICON_SIZE_LARGE_TOOLBAR); - _progress_bar->set_fraction(0.0); - _connect_button->set_sensitive(true); - _disconnect_button->set_sensitive(false); - - if (_new_engine) - _internal_radio->set_sensitive(true); - else - _internal_radio->set_sensitive(false); - - _server_radio->set_sensitive(true); - _launch_radio->set_sensitive(true); - - if (_mode == CONNECT_REMOTE ) - _url_entry->set_sensitive(true); - else if (_mode == LAUNCH_REMOTE ) - _port_spinbutton->set_sensitive(true); - - _progress_label->set_text(string("Disconnected")); - } -} - - -void -ConnectWindow::set_connecting_widget_states() -{ - if (!_widgets_loaded) - return; - - _connect_button->set_sensitive(false); - _disconnect_button->set_label("gtk-cancel"); - _disconnect_button->set_sensitive(true); - _server_radio->set_sensitive(false); - _launch_radio->set_sensitive(false); - _internal_radio->set_sensitive(false); - _url_entry->set_sensitive(false); - _port_spinbutton->set_sensitive(false); -} - - -/** Launch (if applicable) and connect to the Engine. - * - * This will create the EngineInterface and ClientInterface and initialize - * the App with them. - */ -void -ConnectWindow::connect(bool existing) -{ - if (_attached) - _attached = false; - - assert(!App::instance().client()); - - _connect_stage = 0; - set_connecting_widget_states(); - - Ingen::Shared::World* world = App::instance().world(); - - if (_mode == CONNECT_REMOTE) { - if (!existing) { - const string url = (_widgets_loaded ? (string)_url_entry->get_text() : world->engine->uri()); - world->engine = SharedPtr(new OSCEngineSender(url)); - } - - SharedPtr tsci(new ThreadedSigClientInterface(1024)); - SharedPtr client; - - const string& uri = world->engine->uri(); - const string& scheme = uri.substr(0, uri.find(":")); - if (scheme == "osc.udp" || scheme == "osc.tcp") - client = SharedPtr(new OSCClientReceiver(16181, tsci)); // FIXME: port - else if (scheme == "http") - client = SharedPtr(new HTTPClientReceiver(world, uri, tsci)); - - App::instance().attach(tsci, client); - App::instance().register_callbacks(); - - Glib::signal_timeout().connect( - sigc::mem_fun(this, &ConnectWindow::gtk_callback), 40); - - } else if (_mode == LAUNCH_REMOTE) { - - int port = _port_spinbutton->get_value_as_int(); - char port_str[6]; - snprintf(port_str, 6, "%u", port); - const string cmd = string("ingen -e --engine-port=").append(port_str); - - if (Raul::Process::launch(cmd)) { - world->engine = SharedPtr( - new OSCEngineSender(string("osc.udp://localhost:").append(port_str))); - - // FIXME: static args - SharedPtr tsci(new ThreadedSigClientInterface(1024)); - SharedPtr client(new OSCClientReceiver(16181, tsci)); - - App::instance().attach(tsci, client); - App::instance().register_callbacks(); - - Glib::signal_timeout().connect( - sigc::mem_fun(this, &ConnectWindow::gtk_callback), 40); - - } else { - cerr << "Failed to launch ingen process." << endl; - } - - } else if (_mode == INTERNAL) { - Ingen::Shared::World* world = App::instance().world(); - if ( ! world->local_engine) { - assert(_new_engine); - world->local_engine = SharedPtr(_new_engine(world)); - } - - if ( ! world->engine) - world->engine = world->local_engine->new_queued_interface(); - - SharedPtr client(new SigClientInterface()); - - world->local_engine->start_jack_driver(); - world->local_engine->activate(1); // FIXME: parallelism - - App::instance().attach(client); - App::instance().register_callbacks(); - - Glib::signal_timeout().connect( - sigc::mem_fun(this, &ConnectWindow::gtk_callback), 10); - } -} - - -void -ConnectWindow::disconnect() -{ - _connect_stage = -1; - _attached = false; - - App::instance().detach(); - set_connected_to(SharedPtr()); - - if (!_widgets_loaded) - return; - - _progress_bar->set_fraction(0.0); - _connect_button->set_sensitive(false); - _disconnect_button->set_sensitive(false); - - _connect_button->set_sensitive(true); - _disconnect_button->set_sensitive(false); -} - - -void -ConnectWindow::on_show() -{ - if (!_widgets_loaded) { - load_widgets(); - if (_attached) - set_connected_to(App::instance().engine()); - } - - Gtk::Dialog::on_show(); -} - - -void -ConnectWindow::load_widgets() -{ - _xml->get_widget("connect_icon", _icon); - _xml->get_widget("connect_progress_bar", _progress_bar); - _xml->get_widget("connect_progress_label", _progress_label); - _xml->get_widget("connect_server_radiobutton", _server_radio); - _xml->get_widget("connect_url_entry", _url_entry); - _xml->get_widget("connect_launch_radiobutton", _launch_radio); - _xml->get_widget("connect_port_spinbutton", _port_spinbutton); - _xml->get_widget("connect_internal_radiobutton", _internal_radio); - _xml->get_widget("connect_disconnect_button", _disconnect_button); - _xml->get_widget("connect_connect_button", _connect_button); - _xml->get_widget("connect_quit_button", _quit_button); - - _server_radio->signal_toggled().connect(sigc::mem_fun(this, &ConnectWindow::server_toggled)); - _launch_radio->signal_toggled().connect(sigc::mem_fun(this, &ConnectWindow::launch_toggled)); - _internal_radio->signal_clicked().connect(sigc::mem_fun(this, &ConnectWindow::internal_toggled)); - _disconnect_button->signal_clicked().connect(sigc::mem_fun(this, &ConnectWindow::disconnect)); - _connect_button->signal_clicked().connect(sigc::bind( - sigc::mem_fun(this, &ConnectWindow::connect), false)); - _quit_button->signal_clicked().connect(sigc::mem_fun(this, &ConnectWindow::quit)); - - _progress_bar->set_pulse_step(0.01); - _widgets_loaded = true; - - _engine_module = Ingen::Shared::load_module("ingen_engine"); - if (!_engine_module) - cerr << "Unable to load ingen_engine module, internal engine unavailable." << endl; - bool found = _engine_module->get_symbol("new_engine", (void*&)_new_engine); - if (!found) { - cerr << "Unable to find module entry point, internal engine unavailable." << endl; - _engine_module.reset(); - } - - server_toggled(); -} - - -void -ConnectWindow::on_hide() -{ - Gtk::Dialog::on_hide(); - if (!_attached) - Gtk::Main::quit(); -} - - -void -ConnectWindow::quit() -{ - if (_attached) { - Gtk::MessageDialog d(*this, "This will exit the GUI, but the engine will " - "remain running (if it is remote).\n\nAre you sure you want to quit?", - true, Gtk::MESSAGE_WARNING, Gtk::BUTTONS_NONE, true); - d.add_button(Gtk::Stock::CANCEL, Gtk::RESPONSE_CANCEL); - d.add_button(Gtk::Stock::QUIT, Gtk::RESPONSE_CLOSE); - int ret = d.run(); - if (ret == Gtk::RESPONSE_CLOSE) - Gtk::Main::quit(); - } else { - Gtk::Main::quit(); - } -} - - -void -ConnectWindow::server_toggled() -{ - _url_entry->set_sensitive(true); - _port_spinbutton->set_sensitive(false); - _mode = CONNECT_REMOTE; -} - - -void -ConnectWindow::launch_toggled() -{ - _url_entry->set_sensitive(false); - _port_spinbutton->set_sensitive(true); - _mode = LAUNCH_REMOTE; -} - - -void -ConnectWindow::internal_toggled() -{ - _url_entry->set_sensitive(false); - _port_spinbutton->set_sensitive(false); - _mode = INTERNAL; -} - - -bool -ConnectWindow::gtk_callback() -{ - /* If I call this a "state machine" it's not ugly code any more */ - - // Timing stuff for repeated attach attempts - timeval now; - gettimeofday(&now, NULL); - static const timeval start = now; - static timeval last = now; - - // Show if attempted connection goes on for a noticeable amount of time - if (!is_visible()) { - const float ms_since_start = (now.tv_sec - start.tv_sec) * 1000.0f + - (now.tv_usec - start.tv_usec) * 0.001f; - if (ms_since_start > 500) { - present(); - set_connecting_widget_states(); - } - } - - /* Connecting to engine */ - if (_connect_stage == 0) { - - _attached = false; - - assert(App::instance().engine()); - assert(App::instance().client()); - - App::instance().client()->signal_response_ok.connect( - sigc::mem_fun(this, &ConnectWindow::on_response)); - - _ping_id = abs(rand()) / 2 * 2; // avoid -1 - App::instance().engine()->set_next_response_id(_ping_id); - App::instance().engine()->ping(); - - if (_widgets_loaded) { - _progress_label->set_text("Connecting to engine..."); - _progress_bar->set_pulse_step(0.01); - } - - ++_connect_stage; - - } else if (_connect_stage == 1) { - if (_attached || App::instance().client()->enabled()) { - App::instance().engine()->activate(); - ++_connect_stage; - } else { - const float ms_since_last = (now.tv_sec - last.tv_sec) * 1000.0f + - (now.tv_usec - last.tv_usec) * 0.001f; - if (ms_since_last > 1000) { - App::instance().engine()->set_next_response_id(_ping_id); - App::instance().engine()->ping(); - last = now; - } - } - } else if (_connect_stage == 2) { - App::instance().engine()->request_all_objects(); - if (_widgets_loaded) - _progress_label->set_text(string("Requesting root patch...")); - ++_connect_stage; - } else if (_connect_stage == 3) { - if (App::instance().store()->size() > 0) { - SharedPtr root = PtrCast(App::instance().store()->object("/")); - if (root) { - set_connected_to(App::instance().engine()); - App::instance().window_factory()->present_patch(root); - App::instance().engine()->load_plugins(); - if (_widgets_loaded) - _progress_label->set_text(string("Loading plugins...")); - ++_connect_stage; - } - } - } else if (_connect_stage == 4) { - App::instance().engine()->request_plugins(); - hide(); - if (_widgets_loaded) - _progress_label->set_text("Connected to engine"); - _connect_stage = 0; // set ourselves up for next time (if there is one) - return false; // deregister this callback - } - - if (_widgets_loaded) - _progress_bar->pulse(); - - if (_connect_stage == -1) { // we were cancelled - if (_widgets_loaded) { - _icon->set(Gtk::Stock::DISCONNECT, Gtk::ICON_SIZE_LARGE_TOOLBAR); - _progress_bar->set_fraction(0.0); - _connect_button->set_sensitive(true); - _disconnect_button->set_sensitive(false); - _disconnect_button->set_label("gtk-disconnect"); - _progress_label->set_text(string("Disconnected")); - } - return false; - } else { - return true; - } -} - - -} // namespace GUI -} // namespace Ingen -- cgit v1.2.1