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

1

Browse Source
This commit is contained in:
cxh 2025-10-17 15:29:38 +08:00
parent 118b727f51
commit fa56cc6eee
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/main.cpp
View File

@ -22,7 +22,7 @@ static void signal_handler(int signum)
int main() int main()
{ {
// 安装信号处理器 // ---------- 信号处理 ----------
struct sigaction sa{}; struct sigaction sa{};
sa.sa_handler = signal_handler; sa.sa_handler = signal_handler;
sigemptyset(&sa.sa_mask); sigemptyset(&sa.sa_mask);
@ -31,9 +31,9 @@ int main()
sigaction(SIGTERM, &sa, nullptr); sigaction(SIGTERM, &sa, nullptr);
signal(SIGPIPE, SIG_IGN); signal(SIGPIPE, SIG_IGN);
// 初始化日志 // ---------- 初始化日志 ----------
Logger::set_log_to_file(get_executable_dir_file_path("app.log")); Logger::set_log_to_file(get_executable_dir_file_path("app.log"));
LOG_INFO("[MAIN] Application starting..."); LOG_INFO("[MAIN] ===== Vehicle Video Service Starting =====");
try try
{ {
@ -47,8 +47,11 @@ int main()
return -1; return -1;
} }
// 初始化 GStreamer // ---------- 初始化 GStreamer ----------
RTMPManager::init(); RTMPManager::init();
// ---------- 自动推流（8 路录像守护） ----------
LOG_INFO("[MAIN] Starting all record streams...");
RTMPManager::start_all_record_streams(); RTMPManager::start_all_record_streams();
// 启动 MQTT 线程 // 启动 MQTT 线程
@ -70,18 +73,16 @@ int main()
// 主循环，仅等待退出信号 // 主循环，仅等待退出信号
while (g_running.load(std::memory_order_relaxed)) std::this_thread::sleep_for(std::chrono::milliseconds(200)); while (g_running.load(std::memory_order_relaxed)) std::this_thread::sleep_for(std::chrono::milliseconds(200));
LOG_INFO("[MAIN] Shutdown requested. Cleaning up..."); // ---------- 退出清理 ----------
LOG_INFO("[MAIN] Shutdown requested. Stopping RTMP streams...");
// 停止所有 RTMP 流
RTMPManager::stop_all(); RTMPManager::stop_all();
// 等待 MQTT 线程退出
if (mqtt_thread.joinable()) if (mqtt_thread.joinable())
{ {
mqtt_thread.join(); mqtt_thread.join();
LOG_INFO("[MAIN] MQTT thread joined."); LOG_INFO("[MAIN] MQTT thread joined.");
} }
LOG_INFO("[MAIN] Application exited cleanly."); LOG_INFO("[MAIN] ===== Vehicle Video Service Exited Cleanly =====");
return 0; return 0;
} }