#include <signal.h>          //退出信号

/*====================== 主函数 ======================*/
int main(void)
{
    // 重定向 stderr 以屏蔽 HMP 驱动的警告输出 (如 timer lost)
    //freopen("/dev/null", "w", stderr); //写这句退出信号就不能被补获到ExitSys()不能被执行

    sigset_t wait_sigset;
    siginfo_t sig_info;
    struct timespec zero_ts = {0, 0};
    int caught_sig;

    // 阻塞SIGINT/SIGTERM，子线程全部继承屏蔽，信号只留在主线程
    sigemptyset(&wait_sigset);
    sigaddset(&wait_sigset, SIGINT);
    sigaddset(&wait_sigset, SIGTERM);
    pthread_sigmask(SIG_BLOCK, &wait_sigset, NULL);

    // 仅屏蔽管道破裂信号，不处理退出信号
    signal(SIGPIPE, SIG_IGN);

    // 初始化日志
    Log_Init();
    Log_Write("=======================================");
    Log_Write("======== ShPbxServer v1.8 启动 ========");
    Log_Write("=======================================");

    if (InitSys() != 0)
    {
        Log_Write("[ShPbxServer][错误] 系统初始化失败");
        Log_Close();
        return -1;
    }
    Log_Write("[ShPbxServer][信息] 系统初始化成功，通道数：%d", nTotCh);
// ===================== 服务后台专用死循环（不退出、不阻塞、不占CPU） =====================
    //// 后台循环：只做非阻塞业务，不阻塞等待信号
    while (1)
    {// 后台死循环，微小sleep降低CPU，同时保证信号标记生效
        //sleep(1); // 每秒休眠一次，程序保持运行
        usleep(500000); // 500ms，比sleep(1)响应更快
        // 非阻塞检测是否收到退出信号
        // 正确传参：第二个参数 &sig_info 匹配 siginfo_t*
        caught_sig = sigtimedwait(&wait_sigset, &sig_info, &zero_ts);
        if (caught_sig > 0)
        {
            break;
        }
    }
    Log_Write("[ShPbxServer][信息] 收到停止信号，准备优雅退出...");
    ExitSys();
    Log_Close();// 关闭日志
    return 0;
}

/*====================== 系统退出 ======================*/
void ExitSys(void)
{
    //Log_Write("[ShPbxServer][信息] 正在关闭系统...");
// 1. 先关闭ZeroMQ（内部等待服务线程退出）
    Zmq_Cleanup();
    Log_Write("[ShPbxServer][信息] ZeroMQ 服务已关闭");

    // 2. 关闭音频推送ZeroMQ
    ZeroMQAudio_Cleanup();
    Log_Write("[ShPbxServer][信息] 音频流推送服务已关闭");

    // 3. 停止定时器线程
    if (bSetTime == 1)
    {
        KillTimer(Th);
        Log_Write("[ShPbxServer][信息] Timer定时器已停止");
    }

    // 4. 关闭CTI硬件，停止所有异步回调线程
    Api_SsmCloseCti();
    Log_Write("[ShPbxServer][信息] CTI 系统已关闭板卡SsmCloseCti()");
    usleep(200000);  // 延长等待，让回调函数全部执行完毕退出

    // 最后销毁互斥锁
    pthread_mutex_destroy(&g_TrkChMutex);
 
}