From acbda29f838280ba98cf9e9e539e9d8a6e8fc6ad Mon Sep 17 00:00:00 2001 From: David Robillard Date: Fri, 9 Jun 2006 15:07:31 +0000 Subject: Added Om aka Graph aka god knows what git-svn-id: http://svn.drobilla.net/lad/grauph@9 a436a847-0d15-0410-975c-d299462d15a1 --- src/clients/demolition/demolition.cpp | 334 ++++++++++++++++++++++++++++++++++ 1 file changed, 334 insertions(+) create mode 100644 src/clients/demolition/demolition.cpp (limited to 'src/clients/demolition/demolition.cpp') diff --git a/src/clients/demolition/demolition.cpp b/src/clients/demolition/demolition.cpp new file mode 100644 index 00000000..84a08c84 --- /dev/null +++ b/src/clients/demolition/demolition.cpp @@ -0,0 +1,334 @@ +/* This file is part of Om. Copyright (C) 2005 Dave Robillard. + * + * Om 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. + * + * Om 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., + * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + +#include "OSCModelEngineInterface.h" +#include "OSCModelEngineInterface.h" // FIXME: make conditional +#include "PatchLibrarian.h" +#include "DemolitionClientInterface.h" +#include "interface/ClientInterface.h" +#include "interface/ClientKey.h" +#include "util/CountedPtr.h" +#include +#include +#include +#include "cmdline.h" // generated by gengetopt + +using std::cout; +using std::endl; + +using namespace LibOmClient; + +void do_something(); + +string random_name(); + +void create_patch(); +void destroy(); +void add_node(); +void connect(); +void disconnect(); +void disconnect_all(); +void set_port_value(); +void set_port_value_queued(); +void rename_object(); + + +// Yay globals! +DemolitionModel* model; +OSCModelEngineInterface* engine; + + +int +main(int argc, char** argv) +{ + const char* engine_url = NULL; + int client_port = 0; + + /* Parse command line options */ + gengetopt_args_info args_info; + if (cmdline_parser (argc, argv, &args_info) != 0) + return 1; + + if (args_info.engine_url_given) { + engine_url = args_info.engine_url_arg; + } else { + cout << "[Main] No engine URL specified. Attempting to use osc.udp://localhost:16180" << endl; + engine_url = "osc.udp://localhost:16180"; + } + + if (args_info.client_port_given) + client_port = args_info.client_port_arg; + else + client_port = 0; // will choose a free port automatically + + model = new DemolitionModel(); + + // Create this first so engine interface (liblo) uses the port + CountedPtr client + = CountedPtr(new DemolitionClientInterface(model)); + + engine = new OSCModelEngineInterface(engine_url); + engine->activate(); + + /* Connect to engine */ + //engine->attach(engine_url); + engine->register_client(ClientKey(), (CountedPtr)client); + + engine->load_plugins(); + engine->request_plugins(); + + //int id = engine->get_next_request_id(); + engine->request_all_objects(/*id*/); + //engine->set_wait_response_id(id); + //engine->wait_for_response(); + + // Disable DSP for stress testing + engine->disable_patch("/"); + + while (true) { + do_something(); + usleep(100000); + } + + sleep(2); + engine->unregister_client(ClientKey()); + //engine->detach(); + + delete engine; + delete model; + + return 0; +} + +/** Does some random action + */ +void +do_something() +{ + int action = rand() % 10; + + switch(action) { + case 0: + create_patch(); break; + case 1: + destroy(); break; + case 2: + add_node(); break; + case 3: + connect(); break; + case 4: + disconnect(); break; + case 5: + disconnect_all(); break; + case 6: + set_port_value(); break; + case 7: + set_port_value_queued(); break; + case 8: + rename_object(); break; + default: + break; + } +} + + +string +random_name() +{ + int length = (rand()%10)+1; + string name(length, '-'); + + for (int i=0; i < length; ++i) + name[i] = 'a' + rand()%26; + + return name; +} + + +void +create_patch() +{ + // Make the probability of this happening inversely proportionate to the number + // of patches to keep the # in a sane range + //if (model->num_patches() > 0 && (rand() % model->num_patches())) + // return; + + bool subpatch = rand()%2; + PatchModel* parent = NULL; + string name = random_name(); + PatchModel* pm = NULL; + + if (subpatch) + parent = model->random_patch(); + + if (parent != NULL) + pm = new PatchModel(parent->path() +"/"+ name, (rand()%8)+1); + else + pm = new PatchModel(string("/") + name, (rand()%8)+1); + + cout << "Creating patch " << pm->path() << endl; + + engine->create_patch_from_model(pm); + + // Spread them out a bit for easier monitoring with om_gtk + char tmp_buf[8]; + snprintf(tmp_buf, 8, "%d", 1600 + rand()%800 - 400); + engine->set_metadata(pm->path(), "module-x", string(tmp_buf)); + snprintf(tmp_buf, 8, "%d", 1200 + rand()%700 - 350); + engine->set_metadata(pm->path(), "module-y", string(tmp_buf)); + + delete pm; +} + + +void +destroy() +{ + // Make the probability of this happening proportionate to the number + // of patches to keep the # in a sane range + if (model->num_patches() == 0 || !(rand() % model->num_patches())) + return; + + NodeModel* nm = NULL; + + if (rand()%2) + nm = model->random_patch(); + else + nm = model->random_node(); + + if (nm != NULL) { + cout << "Destroying " << nm->path() << endl; + engine->destroy(nm->path()); + } +} + + +void +add_node() +{ + PatchModel* parent = model->random_patch(); + PluginModel* plugin = model->random_plugin(); + + if (parent != NULL && plugin != NULL) { + NodeModel* nm = new NodeModel(parent->path() +"/"+ random_name()); + nm->plugin(plugin); + cout << "Adding node " << nm->path() << endl; + engine->create_node_from_model(nm); + // Spread them out a bit for easier monitoring with om_gtk + char tmp_buf[8]; + snprintf(tmp_buf, 8, "%d", 1600 + rand()%800 - 400); + engine->set_metadata(nm->path(), "module-x", tmp_buf); + snprintf(tmp_buf, 8, "%d", 1200 + rand()%700 - 350); + engine->set_metadata(nm->path(), "module-y", tmp_buf); + } +} + + +void +connect() +{ + if (!(rand() % 10)) { // Attempt a connection between two nodes in the same patch + PatchModel* parent = model->random_patch(); + NodeModel* n1 = model->random_node_in_patch(parent); + NodeModel* n2 = model->random_node_in_patch(parent); + PortModel* p1 = model->random_port_in_node(n1); + PortModel* p2 = model->random_port_in_node(n2); + + if (p1 != NULL && p2 != NULL) { + cout << "Connecting " << p1->path() << " -> " << p2->path() << endl; + engine->connect(p1->path(), p2->path()); + } + + } else { // Attempt a connection between two truly random nodes + PortModel* p1 = model->random_port(); + PortModel* p2 = model->random_port(); + + if (p1 != NULL && p2 != NULL) { + cout << "Connecting " << p1->path() << " -> " << p2->path() << endl; + engine->connect(p1->path(), p2->path()); + } + } +} + + +void +disconnect() +{ + PortModel* p1 = model->random_port(); + PortModel* p2 = model->random_port(); + + if (p1 != NULL && p2 != NULL) { + cout << "Disconnecting " << p1->path() << " -> " << p2->path() << endl; + engine->disconnect(p1->path(), p2->path()); + } +} + + +void +disconnect_all() +{ + PortModel* p = model->random_port(); + + if (p != NULL) { + cout << "Disconnecting all from" << p->path() << endl; + engine->disconnect_all(p->path()); + } +} + + +void +set_port_value() +{ + PortModel* pm = model->random_port(); + float val = (float)rand() / (float)RAND_MAX; + + if (pm != NULL) { + cout << "Setting control for port " << pm->path() << " to " << val << endl; + engine->set_port_value(pm->path(), val); + } +} + + +void +set_port_value_queued() +{ + PortModel* pm = model->random_port(); + float val = (float)rand() / (float)RAND_MAX; + + if (pm != NULL) { + cout << "Setting control (slow) for port " << pm->path() << " to " << val << endl; + engine->set_port_value_queued(pm->path(), val); + } +} + + +void +rename_object() +{ + // 1/6th chance of it being a patch + /*int type = rand()%6; + + if (type == 0) { + NodeModel* n = model->random_node(); + if (n != NULL) + engine->rename(n->path(), random_name()); + } else { + PatchModel* p = model->random_patch(); + if (p != NULL) + engine->rename(p->path(), random_name()); + }*/ +} + -- cgit v1.2.1