2

我有两个进程 server.c 和 client.c 它们通过 POSIX 消息队列进行通信。客户端向队列发送一条消息，mq_notify 告诉服务器一条消息已添加到队列中。然后信号处理程序将接收并处理该消息。但是，我无法让它正常工作。从 client.c 添加消息永远不会发送信号处理程序（但是，如果我从 server.c 添加消息，它会设置处理程序）。服务器仍然可以接收来自客户端的放在队列中的消息，但是由于某种原因，这不会触发 server.c 的 mq_notify 中使用的处理程序。有人知道这是什么吗？这是来自每一方的相关示例代码：

客户端.c

/* queue has already been created, this opens it*/
msgq_id = mq_open(MSGQOBJ_NAME, O_RDWR);

if (msgq_id == (mqd_t)-1) {
    perror("In mq_open()");
    exit(1);
}

/* sending the message      --  mq_send() */
mq_send(msgq_id, packet.mesg_data, strlen(packet.mesg_data), msgprio);

/* closing the queue        -- mq_close() */
mq_close(msgq_id);

服务器.c

void handler()
{
    /*for now it just prints that the signal was recieved*/
}
/*i opening the queue        --  mq_open() */
msgq_id = mq_open(MSGQOBJ_NAME, O_RDWR);
if (msgq_id == (mqd_t)-1) {
        perror("In mq_open()");
        exit(1);
}



int main(){
    . 
    . 
    .
    .
    /*Set up to be notifed when the queue gets something in it*/
    signal(SIGUSR1, handler);
    sigevent.sigev_signo = SIGUSR1;;
    if(mq_notify (msgq_id, &sigevent) == -1)
    {
        if(errno == EBUSY)
                printf("Another process has registered for notifications.\n");
        _exit (EXIT_FAILURE);
    }
    //strcpy(packet2.mesg_data, "Hello world!");
    //mq_send(msgq_id, packet2.mesg_data, strlen(packet2.mesg_data), 0);

    while(1)
    {
        /*wait to be notified*/
    }
    .
    .
    . 
}

这是否与它们是单独的进程有关？

4

1 回答 1

1

啊哈！弄清楚了。通知被阻止，因为 server.c 在 mq_receive 中等待。这意味着信号未被确认，因为进程正忙于等待 mq_receive。感谢任何看过我问题的人。

于 2013-02-28T08:22:45.887 回答