From 27a4f3c0c58cd92f564ee57b3d9b7356d23a3136 Mon Sep 17 00:00:00 2001 From: David Robillard Date: Sat, 18 Mar 2017 11:52:19 +0100 Subject: Add missing files --- tests/TestClient.hpp | 90 ++++++++++++++++++++++++++++++++ tests/ingen_bench.cpp | 139 ++++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 229 insertions(+) create mode 100644 tests/TestClient.hpp create mode 100644 tests/ingen_bench.cpp diff --git a/tests/TestClient.hpp b/tests/TestClient.hpp new file mode 100644 index 00000000..f1e0c5a7 --- /dev/null +++ b/tests/TestClient.hpp @@ -0,0 +1,90 @@ +/* + This file is part of Ingen. + Copyright 2007-2017 David Robillard + + 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 . +*/ + +#ifndef INGEN_TESTCLIENT_HPP +#define INGEN_TESTCLIENT_HPP + +#include "ingen/Interface.hpp" + +using namespace Ingen; + +class TestClient : public Ingen::Interface +{ +public: + explicit TestClient(Log& log) : _log(log) {} + ~TestClient() {} + + Raul::URI uri() const { return Raul::URI("ingen:testClient"); } + + void bundle_begin() {} + + void bundle_end() {} + + void put(const Raul::URI& uri, + const Properties& properties, + Resource::Graph ctx = Resource::Graph::DEFAULT) {} + + void delta(const Raul::URI& uri, + const Properties& remove, + const Properties& add) {} + + void copy(const Raul::URI& old_uri, + const Raul::URI& new_uri) {} + + void move(const Raul::Path& old_path, + const Raul::Path& new_path) {} + + void del(const Raul::URI& uri) {} + + void connect(const Raul::Path& tail, + const Raul::Path& head) {} + + void disconnect(const Raul::Path& tail, + const Raul::Path& head) {} + + void disconnect_all(const Raul::Path& parent_patch_path, + const Raul::Path& path) {} + + void set_property(const Raul::URI& subject, + const Raul::URI& predicate, + const Atom& value) {} + + void set_response_id(int32_t id) {} + + void get(const Raul::URI& uri) {} + + void undo() {} + + void redo() {} + + void response(int32_t id, Status status, const std::string& subject) { + if (status != Status::SUCCESS) { + _log.error(fmt("error on message %1%: %2% (%3%)\n") + % id % ingen_status_string(status) % subject); + exit(EXIT_FAILURE); + } + } + + void error(const std::string& msg) { + _log.error(fmt("error: %1%\n") % msg); + exit(EXIT_FAILURE); + } + +private: + Log& _log; +}; + +#endif // INGEN_TESTCLIENT_HPP diff --git a/tests/ingen_bench.cpp b/tests/ingen_bench.cpp new file mode 100644 index 00000000..e647a5d5 --- /dev/null +++ b/tests/ingen_bench.cpp @@ -0,0 +1,139 @@ +/* + This file is part of Ingen. + Copyright 2007-2017 David Robillard + + 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 . +*/ + +#include +#include +#include +#include + +#include "ingen/Clock.hpp" +#include "ingen/Configuration.hpp" +#include "ingen/EngineBase.hpp" +#include "ingen/Interface.hpp" +#include "ingen/Parser.hpp" +#include "ingen/World.hpp" +#include "ingen/runtime_paths.hpp" +#include "ingen/types.hpp" + +#include "TestClient.hpp" +#include "ingen_config.h" + +using namespace std; +using namespace Ingen; + +World* world = NULL; + +static void +ingen_try(bool cond, const char* msg) +{ + if (!cond) { + cerr << "ingen: Error: " << msg << endl; + delete world; + exit(EXIT_FAILURE); + } +} + +static std::string +real_path(const char* path) +{ + char* const c_real_path = realpath(path, NULL); + const std::string result(c_real_path ? c_real_path : ""); + free(c_real_path); + return result; +} + +int +main(int argc, char** argv) +{ + set_bundle_path_from_code((void*)&ingen_try); + + // Create world + try { + world = new World(NULL, NULL, NULL); + world->conf().add( + "output", "output", 'O', "File to write benchmark output", + Ingen::Configuration::SESSION, world->forge().String, Atom()); + world->load_configuration(argc, argv); + } catch (std::exception& e) { + cout << "ingen: " << e.what() << endl; + return EXIT_FAILURE; + } + + // Get mandatory command line arguments + const Atom& load = world->conf().option("load"); + const Atom& out = world->conf().option("output"); + if (!load.is_valid() || !out.is_valid()) { + cerr << "Usage: ingen_bench --load START_GRAPH --output OUT_FILE" << endl; + return EXIT_FAILURE; + } + + // Get start graph and output file options + const std::string start_graph = real_path((const char*)load.get_body()); + const std::string out_file = (const char*)out.get_body(); + if (start_graph.empty()) { + cerr << "error: initial graph '" + << ((const char*)load.get_body()) + << "' does not exist" << endl; + return EXIT_FAILURE; + } + + // Load modules + ingen_try(world->load_module("server_profiled"), + "Unable to load server module"); + + // Initialise engine + ingen_try(bool(world->engine()), + "Unable to create engine"); + world->engine()->init(48000.0, 4096, 4096); + world->engine()->activate(); + + // Load graph + if (!world->parser()->parse_file(world, world->interface().get(), start_graph)) { + cerr << "error: failed to load initial graph " << start_graph << endl; + return EXIT_FAILURE; + } + world->engine()->flush_events(std::chrono::milliseconds(20)); + + // Run benchmark + // TODO: Set up real-time scheduling for this and worker threads + Ingen::Clock clock; + const uint32_t n_test_frames = 1 << 20; + const uint32_t block_length = 4096; + const uint64_t t_start = clock.now_microseconds(); + for (uint32_t i = 0; i < n_test_frames; i += block_length) { + world->engine()->advance(block_length); + world->engine()->run(block_length); + //world->engine()->main_iteration(); + } + const uint64_t t_end = clock.now_microseconds(); + + // Write log output + FILE* log = fopen(out_file.c_str(), "a"); + if (ftell(log) == 0) { + fprintf(log, "# n_threads\trun_time\treal_time\n"); + } + fprintf(log, "%u\t%f\t%f\n", + world->conf().option("threads").get(), + (t_end - t_start) / 1000000.0, + (n_test_frames / 48000.0)); + fclose(log); + + // Shut down + world->engine()->deactivate(); + + delete world; + return EXIT_SUCCESS; +} -- cgit v1.2.1