cxh/kunlang_video
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

first commit

Browse Source
This commit is contained in:
cxh 2025-09-10 10:45:06 +08:00
parent b829514079
commit a28b9b78d6
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/main.cpp
View File

@ -9,16 +9,16 @@
std::atomic<bool> g_running(true); std::atomic<bool> g_running(true);
void signalHandler(int signum) void signalHandler(int)
{ {
g_running = false; g_running = false;
RTSPManager::stop(); RTSPManager::stop(); // 停止 RTSP loop
MQTTClientWrapper::stop(); // 停止 MQTT loop
} }
int main() int main()
{ {
signal(SIGINT, [](int) signal(SIGINT, signalHandler);
{ g_running = false; RTSPManager::stop(); });
signal(SIGPIPE, SIG_IGN); signal(SIGPIPE, SIG_IGN);
// 初始化日志文件 // 初始化日志文件
@ -38,11 +38,8 @@ int main()
// 先在主线程初始化 GStreamer // 先在主线程初始化 GStreamer
RTSPManager::init(); RTSPManager::init();
// 启动 RTSP server（loop 可在子线程）
std::thread rtsp_thread([&]() std::thread rtsp_thread([&]()
{ RTSPManager::start(g_app_config.cameras); }); { RTSPManager::start(g_app_config.cameras); });
// 启动 MQTT 客户端线程
std::thread mqtt_thread(mqtt_client_thread_func); std::thread mqtt_thread(mqtt_client_thread_func);
// 等待退出信号 // 等待退出信号