summaryrefslogtreecommitdiffstats
path: root/utils/hwstub/tools/hwstub_server.cpp
diff options
context:
space:
mode:
authorAmaury Pouly <amaury.pouly@gmail.com>2016-02-07 21:42:15 +0000
committerAmaury Pouly <amaury.pouly@gmail.com>2016-04-08 19:37:30 +0200
commit3d8a08ca25c3041ac677335e51341d966a9b370b (patch)
tree1bf06dea354e3ae95c1ec91b6ee259d0ac21659c /utils/hwstub/tools/hwstub_server.cpp
parent56dc54d38ac6c1d47ea6dbae88b1e5f7fee9f3ec (diff)
downloadrockbox-3d8a08ca25c3041ac677335e51341d966a9b370b.tar.gz
rockbox-3d8a08ca25c3041ac677335e51341d966a9b370b.zip
hwstub: rewrite and expand library
Rewrite the hwstub library in C++, with a clean and modular design. The library was designed from the ground up to be aware of multithreading issues and to handle memory allocation nicely with shared pointers. Compared to the original library, it brings the following major features: - support for JZ boot devices, it is very easy to add support for others - support for network transparent operations (through sockets): both tcp and unix domains are support Change-Id: I75899cb9c7aa938c17ede2bb3f468e7a55d625b4
Diffstat (limited to 'utils/hwstub/tools/hwstub_server.cpp')
-rw-r--r--utils/hwstub/tools/hwstub_server.cpp127
1 files changed, 127 insertions, 0 deletions
diff --git a/utils/hwstub/tools/hwstub_server.cpp b/utils/hwstub/tools/hwstub_server.cpp
new file mode 100644
index 0000000000..6cb8010897
--- /dev/null
+++ b/utils/hwstub/tools/hwstub_server.cpp
@@ -0,0 +1,127 @@
+/***************************************************************************
+ * __________ __ ___.
+ * Open \______ \ ____ ____ | | _\_ |__ _______ ___
+ * Source | _// _ \_/ ___\| |/ /| __ \ / _ \ \/ /
+ * Jukebox | | ( <_> ) \___| < | \_\ ( <_> > < <
+ * Firmware |____|_ /\____/ \___ >__|_ \|___ /\____/__/\_ \
+ * \/ \/ \/ \/ \/
+ * $Id$
+ *
+ * Copyright (C) 2016 by Amaury Pouly
+ *
+ * This program 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.
+ *
+ * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
+ * KIND, either express or implied.
+ *
+ ****************************************************************************/
+#include <cstdio>
+#include <thread>
+#include <chrono>
+#include <cstring>
+#include <iostream>
+#include "hwstub.hpp"
+#include "hwstub_usb.hpp"
+#include "hwstub_uri.hpp"
+#include "hwstub_net.hpp"
+#include <signal.h>
+#include <getopt.h>
+
+/* capture CTRL+C */
+volatile sig_atomic_t g_exit_loop = 0;
+
+void do_signal(int sig)
+{
+ g_exit_loop = 1;
+}
+
+std::shared_ptr<hwstub::context> g_ctx;
+std::shared_ptr<hwstub::net::server> g_srv;
+
+int usage()
+{
+ printf("usage: hwstub_server [options]\n");
+ printf(" --help/-h Display this help\n");
+ printf(" --verbose/-v Verbose output\n");
+ printf(" --context/-c <uri> Context URI (see below)\n");
+ printf(" --server/-s <uri> Server URI (see below)\n");
+ printf("\n");
+ hwstub::uri::print_usage(stdout, true, true);
+ return 1;
+}
+
+int main(int argc, char **argv)
+{
+ hwstub::uri::uri ctx_uri = hwstub::uri::default_uri();
+ hwstub::uri::uri srv_uri = hwstub::uri::default_server_uri();
+ bool verbose = false;
+
+ while(1)
+ {
+ static struct option long_options[] =
+ {
+ {"help", no_argument, 0, 'h'},
+ {"verbose", no_argument, 0, 'v'},
+ {"context", required_argument, 0, 'c'},
+ {"server", required_argument, 0, 's'},
+ {0, 0, 0, 0}
+ };
+
+ int c = getopt_long(argc, argv, "hvc:s:", long_options, NULL);
+ if(c == -1)
+ break;
+ switch(c)
+ {
+ case -1:
+ break;
+ case 'v':
+ verbose = true;
+ break;
+ case 'h':
+ return usage();
+ case 'c':
+ ctx_uri = hwstub::uri::uri(optarg);
+ break;
+ case 's':
+ srv_uri = hwstub::uri::uri(optarg);
+ break;
+ default:
+ abort();
+ }
+ }
+
+ if(optind != argc)
+ return usage();
+
+ /* intercept CTRL+C */
+ signal(SIGINT, do_signal);
+
+ std::string error;
+ g_ctx = hwstub::uri::create_context(ctx_uri, &error);
+ if(!g_ctx)
+ {
+ printf("Cannot create context: %s\n", error.c_str());
+ return 1;
+ }
+ g_ctx->start_polling();
+
+ g_srv = hwstub::uri::create_server(g_ctx, srv_uri, &error);
+ if(!g_srv)
+ {
+ printf("Cannot create server: %s\n", error.c_str());
+ return 1;
+ }
+ if(verbose)
+ g_srv->set_debug(std::cout);
+
+ while(!g_exit_loop)
+ std::this_thread::sleep_for(std::chrono::seconds(1));
+ printf("Shutting down...\n");
+ g_srv.reset(); /* will cleanup */
+ g_ctx.reset(); /* will cleanup */
+
+ return 0;
+}