add initial support for "SDR-like" operation (this currently doesn't support any specific targeted SDR, and currently generates 4FSK frames carried by ZeroMQ to a target application for mod/demod);

Author: gatekeep

Defines.h

@@ -5,7 +5,7 @@
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  *  Copyright (C) 2015,2016,2017 Jonathan Naylor, G4KLX
- *  Copyright (C) 2018 Bryan Biedenkapp, N2PLL
+ *  Copyright (C) 2018,2025 Bryan Biedenkapp, N2PLL
  *
  */
 /**
@@ -17,6 +17,8 @@
 
 #include <stdint.h>
 
+
+
 #if !defined(NATIVE_SDR)
 #if defined(__SAM3X8E__) && !defined(STM32F4XX)
 #define  ARM_MATH_CM3
@@ -31,7 +33,11 @@
 #include <cstring>
 #endif
 
+#if !defined(NATIVE_SDR)
 #include <arm_math.h>
+#else
+#include "sdr/arm_math.h"
+#endif
 
 // ---------------------------------------------------------------------------
 //  Types
@@ -150,6 +156,7 @@ const uint8_t BIT_MASK_TABLE[] = { 0x80U, 0x40U, 0x20U, 0x10U, 0x08U, 0x04U, 0x0
 #define CPU_TYPE_ARDUINO_DUE 0x00U
 #define CPU_TYPE_NXP 0x01U
 #define CPU_TYPE_STM32 0x02U
+#define CPU_TYPE_NATIVE_SDR 0xF0U
 
 // ---------------------------------------------------------------------------
 //  Macros

FirmwareMain.cpp

@@ -7,11 +7,35 @@
  *  Copyright (C) 2015,2016,2017,2018 Jonathan Naylor, G4KLX
  *  Copyright (C) 2016 Mathis Schmieder, DB9MAT
  *  Copyright (C) 2016 Colin Durbridge, G4EML
- *  Copyright (C) 2018,2024 Bryan Biedenkapp, N2PLL
+ *  Copyright (C) 2018,2024,2025 Bryan Biedenkapp, N2PLL
  *
  */
 #include "Globals.h"
 
+#if defined(NATIVE_SDR)
+#include "sdr/port/PseudoPTYPort.h"
+
+#include <sys/types.h>
+#include <unistd.h>
+#include <signal.h>
+#include <fcntl.h>
+#include <pwd.h>
+#include <cstdio>
+#include <cassert>
+#include <cstdlib>
+#include <cstring>
+
+#include <zmq.hpp>
+#endif
+
+// ---------------------------------------------------------------------------
+//	Macros
+// ---------------------------------------------------------------------------
+
+#if defined(NATIVE_SDR)
+#define IS(s) (::strcmp(argv[i], s) == 0)
+#endif
+
 // ---------------------------------------------------------------------------
 //  Globals Variables
 // ---------------------------------------------------------------------------
@@ -60,6 +84,29 @@ CWIdTX cwIdTX;
 SerialPort serial;
 IO io;
 
+#if defined(NATIVE_SDR)
+std::string g_progExe = std::string(__EXE_NAME__);
+
+std::string m_zmqRx = std::string("ipc:///tmp/dvm-rx.ipc");
+std::string m_zmqTx = std::string("ipc:///tmp/dvm-tx.ipc");
+
+std::string m_ptyPort = std::string("/dev/ptmx");
+
+std::string g_logFileName = std::string("dsp.log");
+
+bool g_debug = false;
+
+int g_signal = 0;
+bool g_killed = false;
+
+bool g_daemon = false;
+
+extern sdr::port::PseudoPTYPort* m_serialPort;
+
+extern zmq::socket_t m_zmqSocketTx;
+extern zmq::socket_t m_zmqSocketRx;
+#endif
+
 // ---------------------------------------------------------------------------
 //  Global Functions
 // ---------------------------------------------------------------------------
@@ -278,3 +325,263 @@ int main()
         loop();
 }
 #endif // defined(STM32F4XX)
+
+#if defined(NATIVE_SDR)
+void fatal(const char* message)
+{
+    ::fprintf(stderr, "%s: %s\n", g_progExe.c_str(), message);
+    exit(EXIT_FAILURE);
+}
+
+void usage(const char* message, const char* arg)
+{
+    ::fprintf(stdout, "" DESCRIPTION " (built %s)\r\n", __BUILD__);
+    ::fprintf(stdout, "Copyright (c) 2025 Bryan Biedenkapp, N2PLL and DVMProject (https://github.com/dvmproject) Authors.\n");
+    ::fprintf(stdout, "Portions Copyright (c) 2015-2021 by Jonathan Naylor, G4KLX and others\n\n");
+    if (message != nullptr) {
+        ::fprintf(stderr, "%s: ", g_progExe.c_str());
+        ::fprintf(stderr, message, arg);
+        ::fprintf(stderr, "\n\n");
+    }
+
+    ::fprintf(stdout, 
+        "usage: %s [-bdvh]"
+        " [--syslog]" 
+        " [-r <ZeroMQ Rx IPC Endpoint>] [-t <ZeroMQ Tx IPC Endpoint>]"
+        " [-p <PTY port>]"
+        " [-l <log filename>]\n\n"
+        "  -b       background process\n"
+        "\n"
+        "  -d       enable debug\n"
+        "  -v       show version information\n"
+        "  -h       show this screen\n"
+        "\n"
+        "  --syslog  force logging to syslog\n"
+        "\n"
+        "  -r       ZeroMQ Rx IPC Endpoint\n"
+        "  -t       ZeroMQ Tx IPC Endpoint\n"
+        "\n"
+        "  -p       PTY Port\n"
+        "\n"
+        "  -l       Log Filename\n"
+        "\n"
+        "  --       stop handling options\n",
+        g_progExe.c_str());
+    exit(EXIT_FAILURE);
+}
+
+int checkArgs(int argc, char* argv[])
+{
+    int i, p = 0;
+
+    // iterate through arguments
+    for (i = 1; i <= argc; i++)
+    {
+        if (argv[i] == nullptr) {
+            break;
+        }
+
+        if (*argv[i] != '-') {
+            continue;
+        }
+        else if (IS("--")) {
+            ++p;
+            break;
+        }
+        else if (IS("-r")) {
+            if ((argc - 1) <= 0)
+                usage("error: %s", "must specify the ZeroMQ Rx IPC Endpoint");
+            m_zmqRx = std::string(argv[++i]);
+
+            if (m_zmqRx == "")
+                usage("error: %s", "IPC endpoint cannot be blank!");
+
+            p += 2;
+        }
+        else if (IS("-t")) {
+            if ((argc - 1) <= 0)
+                usage("error: %s", "must specify the ZeroMQ Tx IPC Endpoint");
+            m_zmqTx = std::string(argv[++i]);
+
+            if (m_zmqTx == "")
+                usage("error: %s", "IPC endpoint cannot be blank!");
+
+            p += 2;
+        }
+        else if (IS("-p")) {
+            if ((argc - 1) <= 0)
+                usage("error: %s", "must specify the PTY port");
+            m_ptyPort = std::string(argv[++i]);
+
+            if (m_ptyPort == "")
+                usage("error: %s", "PTY port cannot be blank!");
+
+            p += 2;
+        }
+        else if (IS("-l")) {
+            if ((argc - 1) <= 0)
+                usage("error: %s", "must specify the log filename");
+            g_logFileName = std::string(argv[++i]);
+
+            if (g_logFileName == "")
+                usage("error: %s", "log filename cannot be blank!");
+
+            p += 2;
+        }
+        else if (IS("-b")) {
+            ++p;
+            g_daemon = true;
+        }
+        else if (IS("-d")) {
+            ++p;
+            g_debug = true;
+        }
+        else if (IS("--syslog")) {
+            g_useSyslog = true;
+        }
+        else if (IS("-v")) {
+            ::fprintf(stdout, "" DESCRIPTION " (built %s)\r\n", __BUILD__);
+            ::fprintf(stdout, "Copyright (c) 2022 Bryan Biedenkapp, N2PLL and DVMProject (https://github.com/dvmproject) Authors.\r\n");
+            ::fprintf(stdout, "Portions Copyright (c) 2015-2021 by Jonathan Naylor, G4KLX and others\r\n");
+            if (argc == 2)
+                exit(EXIT_SUCCESS);
+        }
+        else if (IS("-h")) {
+            usage(nullptr, nullptr);
+            if (argc == 2)
+                exit(EXIT_SUCCESS);
+        }
+        else {
+            usage("unrecognized option `%s'", argv[i]);
+        }
+    }
+
+    if (p < 0 || p > argc) {
+        p = 0;
+    }
+
+    return ++p;
+}
+
+static void sigHandler(int signum)
+{
+    g_killed = true;
+    g_signal = signum;
+}
+
+// ---------------------------------------------------------------------------
+//  Program Entry Point
+// ---------------------------------------------------------------------------
+
+int main(int argc, char** argv)
+{
+    m_zmqRx = std::string("ipc:///tmp/dvm-rx.ipc");
+    m_zmqTx = std::string("ipc:///tmp/dvm-tx.ipc");
+
+    if (argv[0] != nullptr && *argv[0] != 0)
+        g_progExe = std::string(argv[0]);
+
+    if (argc > 1) {
+        // check arguments
+        int i = checkArgs(argc, argv);
+        if (i < argc) {
+            argc -= i;
+            argv += i;
+        }
+        else {
+            argc--;
+            argv++;
+        }
+    }
+
+    ::signal(SIGINT, sigHandler);
+    ::signal(SIGTERM, sigHandler);
+    ::signal(SIGHUP, sigHandler);
+
+    // initialize system logging
+    bool ret = ::LogInitialise(".", g_logFileName.c_str(), 1U, 1U);
+    if (!ret) {
+        ::fprintf(stderr, "unable to open the log file\n");
+        return 1;
+    }
+
+    // handle POSIX process forking
+    if (g_daemon) {
+        // create new process
+        pid_t pid = ::fork();
+        if (pid == -1) {
+            ::fprintf(stderr, "%s: Couldn't fork() , exiting\n", g_progExe.c_str());
+            ::LogFinalise();
+            return EXIT_FAILURE;
+        }
+        else if (pid != 0) {
+            ::LogFinalise();
+            exit(EXIT_SUCCESS);
+        }
+
+        // create new session and process group
+        if (::setsid() == -1) {
+            ::fprintf(stderr, "%s: Couldn't setsid(), exiting\n", g_progExe.c_str());
+            ::LogFinalise();
+            return EXIT_FAILURE;
+        }
+
+        // set the working directory to the root directory
+        if (::chdir("/") == -1) {
+            ::fprintf(stderr, "%s: Couldn't cd /, exiting\n", g_progExe.c_str());
+            ::LogFinalise();
+            return EXIT_FAILURE;
+        }
+
+        ::close(STDIN_FILENO);
+        ::close(STDOUT_FILENO);
+        ::close(STDERR_FILENO);
+    }
+
+    do {
+        g_signal = 0;
+
+        {
+            ::LogInfo("" DESCRIPTION " (built %s)", __BUILD__);
+            ::LogInfo("Copyright (c) 2017-2025 Bryan Biedenkapp, N2PLL and DVMProject (https://github.com/dvmproject) Authors.");
+            ::LogInfo("Portions Copyright (c) 2015-2021 by Jonathan Naylor, G4KLX and others");
+
+            ::LogInfoEx(LOG_DSP, "DSP is performing initialization and warmup");
+            setup();
+
+            ::LogInfoEx(LOG_DSP, "DSP is up and running");
+            while (!g_killed) {
+                loop();
+                ::usleep(1);
+            }
+        }
+
+        if (g_signal == 2)
+            ::LogInfoEx(LOG_DSP, "Exited on receipt of SIGINT");
+
+        if (g_signal == 15)
+            ::LogInfoEx(LOG_DSP, "Exited on receipt of SIGTERM");
+
+        if (g_signal == 1)
+            ::LogInfoEx(LOG_DSP, "Restarting on receipt of SIGHUP");
+    } while (g_signal == 1);
+
+    ::LogInfoEx(LOG_DSP, "DSP is shutting down");
+
+    if (m_serialPort != nullptr) {
+        m_serialPort->close();
+        delete m_serialPort;
+    }
+
+    try
+    {
+        m_zmqSocketTx.close();
+        m_zmqSocketRx.close();
+    }
+    catch(const zmq::error_t& zmqE) { /* stub */ }
+    catch(const std::exception& e) { /* stub */ }
+
+    ::LogFinalise();
+    return 0;
+}
+#endif // defined(NATIVE_SDR)