0
私は2つのプロセスをC++で通信しようとしていますが、動作していないようです。C++ - msgsnd＆msgrcvは通信していないようです
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>
#include <iostream>
#include <unistd.h>
#include <sys/wait.h>
#include <stdlib.h>
void sender(int qid)
{
// declare my message buffer
struct buf {
long mtype; // required
char greeting[50]; // mesg content
};
buf msg;
int size = sizeof(msg)-sizeof(long);
std::cout << "Type [exit] to stop the program." << std::endl;
bool exit = false;
while (!exit)
{
std::cout << getpid() << ": ";
std::cin.getline(msg.greeting, 50, '\n');
//std::cout << msg.greeting << std::endl;
msg.mtype = 23;
if (strcmp(msg.greeting, "exit") == 0)
exit = true;
msgsnd(qid, (struct msgbuf *)&msg, size, 0);
}
}
void receiver(int qid)
{
// declare my message buffer
struct buf {
long mtype;
char greeting[50];
};
buf msg;
int size = sizeof(msg)-sizeof(long);
bool exit = false;
while (!exit)
{
msgrcv(qid, (struct msgbuf *)&msg, size, 23, 0);
if (strcmp(msg.greeting, "exit") == 0)
exit = true;
std::cout << getpid() << ": " << msg.greeting << std::endl;
}
}
int main(int ac, char **av) {
//spawning two child processes
pid_t cpid = fork();
int qid = msgget(IPC_PRIVATE, IPC_EXCL|IPC_CREAT|0600);
if (cpid == 0) {
// execv("./sender", av);
sender(qid);
exit(0);
}
cpid = fork();
if (cpid == 0) {
//execv("./receiver", av);
receiver(qid);
exit(0);
}
while (wait(NULL) != -1); // waiting for both children to terminate
msgctl(qid, IPC_RMID, NULL);
std::cout << "END" << std::endl;
exit(0);
}
だから、あなたが見ることができるように、sender()ユーザーの入力を待つ：私はこのコードを持っています。 receiver()は待機しているので、すべてが問題ありません。しかし、ユーザーが入力を完了すると、[Enter]を押しますが、受信者は何も取得しません。
これらのメッセージは同じQID、同じサイズのmsg、同じID（23）を持っています。なぜ動作しないのですか？私は多くの例を見て、私のために、それは論理そうだ、問題は何ですか？このコードでは、あなたの助け