POSIX4 消息队列 "mq_open: No such file or directory"
POSIX4 messages queues "mq_open: No such file or directory"
我正在尝试使用 POSIX4 消息队列。所以我使用 mq_open
来创建队列,对于我给它的所有选项,我填充了 struct mq_attr
。
他找不到队列,而我放了O_CREATE
标志。
这是我的代码(没有缩进的行是调试代码):
...
/***
* Queues' names
*/
#define GUI_QUEUE "/guiQ"
...
struct mq_attr attrAct; /* Queue parameters */
/***
* Message queue to send action
*/
attrAct.mq_maxmsg=1;
attrAct.mq_msgsize=sizeof(gui_action);
attrAct.mq_flags=0;
attrAct.mq_curmsgs=0;
printf("serveur first sizeof(gui_action) : %lu\tmsgsize : %lu\n", sizeof(gui_action), attrAct.mq_msgsize);
if ((guiQue=mq_open(GUI_QUEUE, O_CREAT | O_NONBLOCK | O_WRONLY
, S_IWUSR | S_IRUSR , &attrAct))!=0) {
perror("mq_open");
exit(EXIT_FAILURE);
}
if (mq_getattr(guiQue, &attrAct)!=0) {
perror("mq_getattr");
}
else {
printf("serveur second sizeof(gui_action) : %lu\tmsgsize : %lu\n", sizeof(gui_action), attrAct.mq_msgsize);
}
struct mq_attr new;
new=attrAct;
new.mq_msgsize=sizeof(gui_action);
printf("serveur third sizeof(gui_action) : %lu\tmsgsize : %lu\n", sizeof(gui_action), new.mq_msgsize);
if (mq_setattr(guiQue, &new, &attrAct)!=0) perror("mq_setattr");
if (mq_getattr(guiQue, &attrAct)!=0) {
perror("mq_getattr");
}
else {
printf("serveur fourth sizeof(gui_action) : %lu\tmsgsize : %lu\n", sizeof(gui_action), attrAct.mq_msgsize);
}
...
这是输出:
serveur first sizeof(gui_action) : 16 msgsize : 16
mq_open: No such file or directory
我做错了什么?
mq_open
returns (mqd_t) -1
on failure and a message queue descriptor on success.
您将 mq_open
的成功 return(实际上是一个 >= 0 的整数)误认为是失败,并且 perror
正在报告之前的一些系统调用的 errno
.
我正在尝试使用 POSIX4 消息队列。所以我使用 mq_open
来创建队列,对于我给它的所有选项,我填充了 struct mq_attr
。
他找不到队列,而我放了O_CREATE
标志。
这是我的代码(没有缩进的行是调试代码):
...
/***
* Queues' names
*/
#define GUI_QUEUE "/guiQ"
...
struct mq_attr attrAct; /* Queue parameters */
/***
* Message queue to send action
*/
attrAct.mq_maxmsg=1;
attrAct.mq_msgsize=sizeof(gui_action);
attrAct.mq_flags=0;
attrAct.mq_curmsgs=0;
printf("serveur first sizeof(gui_action) : %lu\tmsgsize : %lu\n", sizeof(gui_action), attrAct.mq_msgsize);
if ((guiQue=mq_open(GUI_QUEUE, O_CREAT | O_NONBLOCK | O_WRONLY
, S_IWUSR | S_IRUSR , &attrAct))!=0) {
perror("mq_open");
exit(EXIT_FAILURE);
}
if (mq_getattr(guiQue, &attrAct)!=0) {
perror("mq_getattr");
}
else {
printf("serveur second sizeof(gui_action) : %lu\tmsgsize : %lu\n", sizeof(gui_action), attrAct.mq_msgsize);
}
struct mq_attr new;
new=attrAct;
new.mq_msgsize=sizeof(gui_action);
printf("serveur third sizeof(gui_action) : %lu\tmsgsize : %lu\n", sizeof(gui_action), new.mq_msgsize);
if (mq_setattr(guiQue, &new, &attrAct)!=0) perror("mq_setattr");
if (mq_getattr(guiQue, &attrAct)!=0) {
perror("mq_getattr");
}
else {
printf("serveur fourth sizeof(gui_action) : %lu\tmsgsize : %lu\n", sizeof(gui_action), attrAct.mq_msgsize);
}
...
这是输出:
serveur first sizeof(gui_action) : 16 msgsize : 16
mq_open: No such file or directory
我做错了什么?
mq_open
returns (mqd_t) -1
on failure and a message queue descriptor on success.
您将 mq_open
的成功 return(实际上是一个 >= 0 的整数)误认为是失败,并且 perror
正在报告之前的一些系统调用的 errno
.