rename mana_nng.h -> mana_nng.hpp

This commit is contained in:
Florian Lüke 2024-12-27 19:13:13 +01:00
parent eedd95bd2f
commit 48d0a3d5c0
3 changed files with 52 additions and 24 deletions

1
src/internal/mana_nng.cc Normal file
View file

@ -0,0 +1 @@
#include "mana_nng.hpp"

View file

@ -1,24 +0,0 @@
#ifndef CF5E5AFF_F218_4A25_95DF_8097D7C5685B
#define CF5E5AFF_F218_4A25_95DF_8097D7C5685B
#include "mana_analysis.h"
#include <mesytec-mnode/mnode_nng.h>
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 */

51
src/internal/mana_nng.hpp Normal file
View file

@ -0,0 +1,51 @@
#ifndef CF5E5AFF_F218_4A25_95DF_8097D7C5685B
#define CF5E5AFF_F218_4A25_95DF_8097D7C5685B
#include "mana_analysis.h"
#include <mesytec-mnode/mnode_nng.h>
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 */