Dev/matterhornserver (#1396)

* added fetch fmt server library * added first draft of matterhorn * added enum ReturnCode * added cpp TCP Interface to slsDetectorServer * added fmt to workflows * bug: added std::signal for proper handling of ctr+c * added compile option to set log level * WIP * dont use c project settings when building matterhornserver * updated logger * WIP * WIP * linked fmt to slsProjectOptions * solved merge conflict * some refactoring * cleaned up logs * added fmt to workflow * WIP * generated register defs from csv file * oops given in hex * properly added fmt as a dependency * add fmt to conda recipe * some format changes * dont use public headers of fmt * WIP * used CRTP for virtual detector * WIP * added udp functions to matterhornserver * Matterhorn in tostring * warning unused variable from other PR * fixed build * updated cmake * added Server class usable for all detectors * removed stopserver * added some more functions * wrong overload * porper cleanup of matterhorn app * PR Review * refactored directory structure * used pause insetad of sleep --------- Co-authored-by: Dhanya Thattil <dhanya.thattil@psi.ch>
2026-08-01 01:43:38 +02:00 · 2026-05-06 13:33:35 +02:00
parent 4ffb81e7ff
commit bb1a73d718
37 changed files with 1640 additions and 97 deletions
@@ -0,0 +1,95 @@
+#include "TCPInterface.h"
+
+#include "fmt/format.h"
+#include "sls/logger.h"
+#include "sls/string_utils.h"
+#include <unistd.h>
+
+namespace sls {
+
+TCPInterface::TCPInterface(
+    std::function<ReturnCode(const detFuncs &, ServerInterface &)>
+        &processFunction_,
+    const uint16_t portNumber_)
+    : processFunction(processFunction_), portNumber(portNumber_),
+      server(portNumber_) {
+    // validatePortNumber(portNumber); TODO: where to validate?
+}
+
+TCPInterface::~TCPInterface() {
+    killTcpThread = true; // mmh but if the receiver is stuck in a function,
+                          // this will be of no help
+    LOG(logINFO) << "Shutting down TCP Socket on port " << portNumber;
+    server.shutdown();
+    LOG(logDEBUG) << "TCP Socket closed on port " << portNumber;
+    if (tcpThread && tcpThread->joinable()) {
+        tcpThread->join();
+    }
+}
+
+void TCPInterface::startTCPServer() {
+
+    tcpThread = std::make_unique<std::thread>(
+        &TCPInterface::startTCPServerClientConnection, this);
+}
+
+void TCPInterface::startTCPServerClientConnection() {
+
+    LOG(logINFO) << "SLS Server starting TCP Server on port " << portNumber
+                 << '\n';
+
+    int function_id{}; // TODO should it be an enum type
+    while (!killTcpThread) {
+        try {
+            auto socket = server.accept();
+            try {
+
+                socket.Receive(function_id);
+                if (function_id < 0 || function_id >= NUM_DET_FUNCTIONS) {
+                    throw RuntimeError(fmt::format(
+                        "{}:{}", UNRECOGNIZED_FNUM_ENUM,
+                        getFunctionNameFromEnum((enum detFuncs)function_id)));
+                }
+                auto returncode = processReceivedData(
+                    static_cast<detFuncs>(function_id), socket);
+
+                if (returncode == FAIL) {
+                    throw RuntimeError(fmt::format(
+                        "Error processing command with fnum: {}",
+                        getFunctionNameFromEnum((enum detFuncs)function_id)));
+                }
+
+            } catch (const RuntimeError &e) {
+                // We had an error needs to be sent to client
+                char mess[MAX_STR_LENGTH]{};
+                LOG(logERROR) << "Error processing command: " << e.what();
+                strcpy_safe(mess, e.what());
+                socket.Send(slsDetectorDefs::FAIL);
+                socket.Send(mess);
+            }
+            // TODO handle exiting server if tcp command was to exit server
+        } catch (const RuntimeError &e) {
+            LOG(logERROR) << "Accept failed: " << e.what();
+        }
+    }
+
+    LOG(logINFOBLUE) << "Exiting TCP Server";
+}
+
+ReturnCode TCPInterface::processReceivedData(const detFuncs function_id,
+                                             ServerInterface &socket) {
+
+    LOG(logDEBUG1) << "calling function fnum: " << function_id << " ("
+                   << getFunctionNameFromEnum((enum detFuncs)function_id)
+                   << ")";
+
+    ReturnCode returncode = processFunction(function_id, socket);
+
+    LOG(logDEBUG1) << "Function "
+                   << getFunctionNameFromEnum((enum detFuncs)function_id)
+                   << " finished";
+
+    return returncode;
+}
+
+} // namespace sls