From 3d8a08ca25c3041ac677335e51341d966a9b370b Mon Sep 17 00:00:00 2001
From: Amaury Pouly <amaury.pouly@gmail.com>
Date: Sun, 7 Feb 2016 21:42:15 +0000
Subject: 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
---
 utils/hwstub/tools/hwstub_server.cpp | 127 +++++++++++++++++++++++++++++++++++
 1 file changed, 127 insertions(+)
 create mode 100644 utils/hwstub/tools/hwstub_server.cpp

(limited to 'utils/hwstub/tools/hwstub_server.cpp')

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;
+}
-- 
cgit v1.2.3