如何解决关于发送消息的Posix消息队列问题
我正在尝试使用POSIX消息队列将消息从子进程发送到父进程。我在使用fork()创建子级之前创建了消息队列。我的代码应该从链接列表中提取单词并将其发送给父代。但是,当我调用mq_send函数发送数据时,程序陷入该函数中,试图从控制台获取输入,并且永不停止。我一直在解决这个问题超过一天,但我不知道该怎么做。我检查了代码的其他部分,它们都起作用。仅mq_send函数会导致问题。有人可以告诉我这是什么问题吗?也许我缺少了一些东西。代码如下。
注意:我不能在此处包括所有代码。这里只有与问题相关的部分。另外,这是我在stackoverflow中遇到的第一个问题,因此对可能出现的格式错误感到抱歉。
编辑:因为我没有添加所有部分,所以代码无法编译。我的问题仅基于发送消息的代码的最后一个while循环。那就是代码卡住的地方。
#include <stdio.h>
#include <stdlib.h>
#include <stddef.h>
#include <math.h>
#include <string.h>
#include <sys/types.h>
#include <mqueue.h>
#include <sys/wait.h>
#include <fcntl.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <unistd.h>
struct Node {
char value[1024];
int count;
struct Node* next;
};
struct dataPackage {
char word[1024];
int count;
};
int main(int argcount,char** argvalues) {
struct Node* headList[atoi(argvalues[1])]; // an array to hold linked lists
// creating fileCount number of linked lists and storing them
for ( int i = 0; i < atoi(argvalues[1]); i++ ) {
headList[i] = NULL;
}
// creating message queues
mqd_t mqList[fileCount];
char queueNames[5][1024];
int n;
// creating different names for different message queues
strcpy(queueNames[0],"/queue1");
strcpy(queueNames[1],"/queue2");
strcpy(queueNames[2],"/queue3");
strcpy(queueNames[3],"/queue4");
strcpy(queueNames[4],"/queue5");
// creating the message queues
for (int i = 0; i < atoi(argvalues[1]); i++ ) {
mqList[i] = mq_open(queueNames[i],O_RDWR | O_CREAT,0666,NULL );
printf("%i\n",mqList[i]);
}
// creating child processes to process input files
for (int i = 0; i < atoi(argvalues[1]); i++ ) {
// creating a child process
pid_t pid = fork();
// child processes process seperate files
if (pid == 0 ) {
//printf("Before file process\n");
// processing the file and creating the sorted linked lists
processFile(fileNames[i],&headList[i]);
// send linked list contents to parent process below
struct dataPackage package;
struct Node* tempHead = headList[i];
while (tempHead != NULL) {
// creating a package to send it to the parent process
package.count = tempHead->count;
strcpy(package.word,tempHead->value);
// !!!!!this is the part where the program gets stuck!!!!!!!!
n = mq_send(mqList[i],(char*) &package,sizeof(struct dataPackage),0);
tempHead = tempHead -> next;
}
// creating a message that will indicate the end of message queue
package.count = -10;
strcpy(package.word,"stop");
n = mq_send(mqList[i],(char *) &package,0);
exit(0);
}
else {
wait(NULL);
}
}
解决方法
行
struct Node* headList[argvalues[1]];
让我想知道您想要实现什么。 argvalues[1]
是指向字符的指针,而不是数字。您的编译器应该已经告诉您了。
如果要将第一个参数转换为数字,则应使用类似的
int count;
if (sscanf(argvalues[1],"%d",&count) != 1) {
/* does not look like a number */
exit(1);
}
/* use count */
,
我看不到mq_receive调用。系统设置了队列限制,一旦确定了消息队列,您应该可以通过执行cat / dev / mqueue / mymq之类的操作来查看该限制。也就是说,我将检查您是否正确使用了消息。我看到您的代码正在执行的操作与产生子级mq_send的argvalues [1]中的值一样,产生了许多子级,但是父级只是在不消耗消息的情况下等待子级死亡。
https://linux.die.net/man/7/mq_overview
,确保您尝试访问的队列中没有消息。
使用mq_getattr()
和mq_curmsgs
确定当前的邮件数量。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。