diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2025-03-11 16:35:08 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2025-03-11 16:36:06 +0100 |
| commit | 6517cc3078eba96ea96e085d033a4b8a96eb7151 (patch) | |
| tree | 6a8d2aee0cf00cd76263bfdca58da6a934547b40 /src/DabMultiplexer.cpp | |
| parent | 84a7a40492b3db9f204f48262481e60a1268f469 (diff) | |
| download | dabmux-6517cc3078eba96ea96e085d033a4b8a96eb7151.tar.gz dabmux-6517cc3078eba96ea96e085d033a4b8a96eb7151.tar.bz2 dabmux-6517cc3078eba96ea96e085d033a4b8a96eb7151.zip | |
Add EDI/TCP number of active connections statistics
Diffstat (limited to 'src/DabMultiplexer.cpp')
| -rw-r--r-- | src/DabMultiplexer.cpp | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/DabMultiplexer.cpp b/src/DabMultiplexer.cpp index a68f09a..b9575fc 100644 --- a/src/DabMultiplexer.cpp +++ b/src/DabMultiplexer.cpp @@ -28,6 +28,7 @@ #include <memory> #include "DabMultiplexer.h" #include "ConfigParser.h" +#include "ManagementServer.h" #include "crc.h" #include "utils.h" @@ -795,6 +796,12 @@ void DabMultiplexer::mux_frame(std::vector<std::shared_ptr<DabOutput> >& outputs } edi_sender->write(edi_tagpacket); + + for (const auto& stat : edi_sender->get_tcp_server_stats()) { + get_mgmt_server().update_edi_tcp_output_stat( + stat.listen_port, + stat.stats.size()); + } } #if _DEBUG |