添加g_unix_signal_add后SIGINT中断处理函数未触发求助

我来帮你排查这个问题，你遇到的情况在GStreamer结合GLib信号处理时挺常见的，咱们一步步拆解原因和解决方案：

最可能的核心原因：GLib主循环未运行 #

g_unix_signal_add() 是将信号处理逻辑注册到GLib主事件循环中的，也就是说，如果你的程序没有启动主循环（g_main_loop_run()），这个信号源根本不会被GLib的事件循环调度，自然不会触发你的intr_handler函数。

gst-launch源码里自带了主循环逻辑，但自己写简易程序时很容易忽略这一步——这大概率是你按下Ctrl+C没反应的关键原因。

其他需要排查的细节点 #

除了主循环问题，还有几个细节要确认：

• 变量作用域：signal_watch_intr_id如果是局部变量，可能会在注册后被销毁，导致后续处理函数无法正确修改它，建议把它放到你的data结构体里，确保生命周期覆盖整个程序运行过程。
• 信号抢占：检查程序中是否用signal()或sigaction()提前注册过SIGINT的处理函数，GLib的信号处理是基于sigaction实现的，如果已有其他处理函数覆盖，会导致冲突。
• 数据传递正确性：确认data.pipeline是有效的GstElement指针，没有空指针或类型转换错误，可以在注册信号前和处理函数里分别打印指针地址，验证是否一致。

修复后的完整示例代码 #

下面是整合了主循环、信号注册、消息处理的完整代码，你可以参考调整：

#include <gst/gst.h>
#include <glib-unix.h>

// 自定义数据结构体，包含管道和信号ID
typedef struct {
    GstElement *pipeline;
    guint signal_watch_intr_id;
} AppData;

// SIGINT信号处理函数
static gboolean intr_handler(gpointer user_data) {
    printf("handling interrupt.\n");
    AppData *data = (AppData*)user_data;
    GstElement *pipeline = data->pipeline;

    if (pipeline) {
        // 发送自定义应用消息
        gst_element_post_message(GST_ELEMENT(pipeline),
            gst_message_new_application(GST_OBJECT(pipeline),
                gst_structure_new("GstLaunchInterrupt",
                    "message", G_TYPE_STRING, "Pipeline interrupted",
                    NULL)));
    }

    data->signal_watch_intr_id = 0;
    return G_SOURCE_REMOVE;
}

// 总线消息处理函数，用于捕获自定义应用消息
static gboolean bus_handler(GstBus *bus, GstMessage *msg, gpointer user_data) {
    GMainLoop *loop = (GMainLoop*)user_data;

    switch (GST_MESSAGE_TYPE(msg)) {
        case GST_MESSAGE_APPLICATION: {
            const GstStructure *s = gst_message_get_structure(msg);
            if (gst_structure_has_name(s, "GstLaunchInterrupt")) {
                g_print("Received interrupt message, stopping pipeline...\n");
                // 停止管道并退出主循环
                gst_element_set_state(GST_ELEMENT(msg->src), GST_STATE_NULL);
                g_main_loop_quit(loop);
            }
            break;
        }
        case GST_MESSAGE_ERROR: {
            // 处理管道错误，避免程序崩溃
            GError *err;
            gchar *debug;
            gst_message_parse_error(msg, &err, &debug);
            g_printerr("Pipeline error: %s\n", err->message);
            g_error_free(err);
            g_free(debug);
            g_main_loop_quit(loop);
            break;
        }
        default:
            break;
    }

    return TRUE;
}

int main(int argc, char *argv[]) {
    // 初始化GStreamer
    gst_init(&argc, &argv);

    AppData data = {0};
    // 创建测试管道（你可以替换成自己的管道逻辑）
    data.pipeline = gst_parse_launch("videotestsrc ! autovideosink", NULL);

    // 注册SIGINT信号处理
    data.signal_watch_intr_id = g_unix_signal_add(SIGINT, intr_handler, &data);

    // 为管道添加总线监听，捕获自定义消息
    GstBus *bus = gst_element_get_bus(data.pipeline);
    GMainLoop *loop = g_main_loop_new(NULL, FALSE);
    gst_bus_add_watch(bus, bus_handler, loop);
    gst_object_unref(bus);

    // 启动管道
    gst_element_set_state(data.pipeline, GST_STATE_PLAYING);

    // 启动GLib主循环——这一步必须有！
    g_main_loop_run(loop);

    // 清理资源
    gst_element_set_state(data.pipeline, GST_STATE_NULL);
    gst_object_unref(data.pipeline);
    g_main_loop_unref(loop);

    return 0;
}

关键说明 #

1. 必须调用g_main_loop_run()启动主循环，GLib才会处理注册的信号源；
2. 通过总线监听捕获自定义的GST_MESSAGE_APPLICATION消息，才能真正实现管道的优雅停止；
3. 把信号ID放到结构体里，避免作用域问题，确保处理函数能正确修改它。

内容的提问来源于stack exchange，提问作者Kumsaati