当我运行以下程序时,我总是收到错误消息“消息太长”。为什么?
这是来源:
#define NAME "/q"
#define SIZE 16
void main()
{
mqd_t mq;
char buffer[SIZE+1];
struct mq_attr attr;
attr.mq_flags = 0;
attr.mq_maxmsg = 10;
attr.mq_msgsize = SIZE;
attr.mq_curmsgs = 0;
mq = mq_open(NAME, O_CREAT | O_RDWR, 0644, &attr);
printf ("opening mqueue: %s\n", strerror(errno));
mq_receive(mq, buffer, strlen(buffer), NULL);
printf ("receiving: %s\n", strerror(errno));
printf ("message: %s\n", buffer);
unlink(NAME);
}
这是输出:
opening mqueue: Success
receiving: Message too long
message:
/ **新编辑** /
好的,我更改了代码以更好地消除一些歧义
#define NAME "/q"
#define SIZE 1024
int main()
{
mqd_t mq;
char buffer[SIZE+1] = {0};
struct mq_attr attr = {0};
attr.mq_flags = 0;
attr.mq_maxmsg = 10;
attr.mq_msgsize = SIZE;
attr.mq_curmsgs = 0;
if ((mqd_t) -1 == (mq = mq_open(NAME, O_CREAT | O_RDWR, 0644, &attr)))
printf("opening mqueue: %s\n", strerror(errno));
if (-1 == mq_receive(mq, buffer, SIZE+1, NULL))
printf("receiving: %s\n", strerror(errno));
printf("message: %s\n", buffer);
if (-1 == unlink(NAME))
perror("unlink() failed");
return 0;
}
输出
receiving: Message too long
message:
unlink() failed: No such file or directory