scottk/UltraGrid
1
0
Fork 0
mirror of https://github.com/outbackdingo/UltraGrid.git synced 2026-03-21 14:40:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

control_socket: add magic + asserts

Browse Source
This commit is contained in:
Martin Pulec
2025-06-17 15:31:34 +02:00
parent 69a4a4ab2d
commit 5c103173b1
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/control_socket.cpp
View File

@@ -42,6 +42,7 @@
#include "compat/platform_pipe.h"
#include <condition_variable>
#include <cstdint> // for uint32_t
#include <mutex>
#include <queue>
#include <string>
@@ -54,10 +55,12 @@
#include "rtp/net_udp.h" // socket_error
#include "tv.h"
#include "utils/net.h"
#include "utils/macros.h" // for MODULE_MAGIC
#include "utils/thread.h"
#define MAX_CLIENTS 16
#define MOD_NAME "[control_socket] "
#define MODULE_MAGIC to_fourcc('c', 't', 'r', 'l')
#ifdef _WIN32
typedef const char *sso_val_type;
@@ -84,6 +87,7 @@ enum connection_type {
#define MAX_STAT_EVENT_QUEUE 100
struct control_state {
const uint32_t magic = MODULE_MAGIC;
struct module mod;
thread control_thread_id;
/// @var internal_fd is used for internal communication
@@ -954,6 +958,7 @@ void control_done(struct control_state *s)
if(!s) {
return;
}
assert(s->magic == MODULE_MAGIC);
module_done(&s->mod);
@@ -983,6 +988,7 @@ void control_done(struct control_state *s)
static void control_report_stats_event(struct control_state *s, const std::string &report_line)
{
assert(s->magic == MODULE_MAGIC);
std::unique_lock<std::mutex> lk(s->stats_lock);
if (s->stat_event_queue.size() < MAX_STAT_EVENT_QUEUE) {