diff --git a/src/internal/mana_nng.cc b/src/internal/mana_nng.cc new file mode 100644 index 0000000..12327a2 --- /dev/null +++ b/src/internal/mana_nng.cc @@ -0,0 +1 @@ +#include "mana_nng.hpp" diff --git a/src/internal/mana_nng.h b/src/internal/mana_nng.h deleted file mode 100644 index cb786ed..0000000 --- a/src/internal/mana_nng.h +++ /dev/null @@ -1,24 +0,0 @@ -#ifndef CF5E5AFF_F218_4A25_95DF_8097D7C5685B -#define CF5E5AFF_F218_4A25_95DF_8097D7C5685B - -#include "mana_analysis.h" -#include - -namespace mesytec::mnode::mana -{ - -class NngServer: public IManaSink -{ - public: - explicit NngServer(nng_socket socket) - : socket_(socket) - { - } - - private: - nng_socket socket_; -}; - -} // namespace mesytec::mnode::mana - -#endif /* CF5E5AFF_F218_4A25_95DF_8097D7C5685B */ diff --git a/src/internal/mana_nng.hpp b/src/internal/mana_nng.hpp new file mode 100644 index 0000000..69cd1a1 --- /dev/null +++ b/src/internal/mana_nng.hpp @@ -0,0 +1,51 @@ +#ifndef CF5E5AFF_F218_4A25_95DF_8097D7C5685B +#define CF5E5AFF_F218_4A25_95DF_8097D7C5685B + +#include "mana_analysis.h" +#include + +namespace mesytec::mnode::mana +{ + +class NngServer: public IManaSink +{ + public: + explicit NngServer(nng_socket socket) + : socket_(socket) + { + } + + void init(int plugin_argc, const char **plugin_argv) override + { + (void)plugin_argc; + (void)plugin_argv; + } + + void shutdown() override { nng_close(socket_); } + + void begin_run(const char *descriptor_json) override { (void)descriptor_json; } + + void end_run(const char *descriptor_json) override { (void)descriptor_json; } + + void process_event(uint16_t eventIndex, mana_offset_array_t *arrays, size_t arrayCount, + size_t totalBytes) override + { + (void)eventIndex; + (void)arrays; + (void)arrayCount; + (void)totalBytes; + } + + void process_system_event(const uint32_t *data, size_t size) override + { + (void)data; + (void)size; + } + + private: + nng_socket socket_; +}; + +} // namespace mesytec::mnode::mana + +#endif /* CF5E5AFF_F218_4A25_95DF_8097D7C5685B */