c - 两个派生进程之间的消息队列导致msgsnd的参数无效

程序创建两个子进程。第一个子进程（1）从stdin读取文本，删除任何特殊字符，并插入到单词中。这部分程序运行得很好然后，当子（1）正在拆分单词时，它正在通过消息队列发送每个单词此部分导致无效参数错误。第二个孩子应该把收到的信息打印到屏幕上。
至少我是这么计划的我有点困了，不知道如何调试消息队列现在它抛出了一个错误

#include <signal.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <error.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <ctype.h>

# define QUEUE_PERMS 0644

static int message_queue = (int) 0;
static key_t key = (key_t) 0;

typedef struct message
{
  long mtype;
  char msg[100];
} mess_t;

int main(int argc, char *argv[]){

  const char delimiters[] = " ,.-!?()1234567890@#$%^&*\n";
  char *word = NULL;
  size_t buffer = 100;
  char *token;
  mess_t message;
  mess_t message2;
  int i;


  // set up a message queue
   key = ftok(__FILE__,'x');

  // create queue
   message_queue = msgget(key, QUEUE_PERMS | IPC_CREAT);
   if(message_queue == -1){
    perror("creating message queue");
   }

  // create parcer process. This tokenizes the strings
  // and send each work to the sort function(s)
  switch(fork()){
    case 0:
      // child process # 1 starts here
      key = ftok(__FILE__,'x');
      message_queue = msgget(key, QUEUE_PERMS);

      // splitting the words up here, this works fine
      while(getline(&word, &buffer, stdin) != EOF){
        token = strtok(word, delimiters);
        while(token != NULL){
          for(i = 0; token[i]; i++){
            token[i] = tolower(token[i]);
          }
          // set type to 1 to send
          message.mtype = 1;
          // copy the word (token) over to the message struct
          strcpy(message.msg,token);

          // **** I get a send failed: Invalid argument here  *****
          if(msgsnd(key, &message, sizeof(message), MSG_NOERROR) == -1){
            perror("send failed");
          }
          token = strtok(NULL, delimiters);
        }
      }
      break;

    case -1:
      perror("error fork\n");
      break;

    default:
      wait(NULL);
      break;
  }

  // this process should read the message an print it out
  switch(fork()){
    case 0:
    // child process # 2 starts here
      key = ftok(__FILE__,'x');
      message_queue = msgget(key, QUEUE_PERMS );
      msgrcv(key, &message2, sizeof(message),1, MSG_NOERROR);
      printf("child process got %s\n", message2.msg);
      break;

    case -1:
      perror("error fork\n");
      break;

    default:
      wait(NULL);
      break;
  }

  return 0;
}

最佳答案

您可以使用message_queue设置msgget()消息队列ID，但随后尝试使用msgsnd()而不是消息队列ID发送到key。
你对msgrcv()也有同样的问题。
当我解决这两个问题时，我可以运行程序：

$ ./mq
abelone apathy
child process got abelone
child process got apathy
$

我在一行输入abelone apathy，然后用Control-D表示EOF。
由于您已经对其进行了组织，因此在启用读取过程之前，写入过程将填充消息队列只要输入不太大，就行。但是，您可能真的希望这两个进程同时运行。您需要移动wait()调用以获得并发性。（将代码正确地分成函数的另一个优点是，如果尽可能多地隐藏，则更容易发现此类问题。）

关于c - 两个派生进程之间的消息队列导致msgsnd的参数无效，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/23506603/