msgsnd () и msgrcv () находятся в одной и той же функции, она работает как первый пример.
main.c
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
int main(int argc, char *argv[])
{
pid_t pid1;
pid_t pid2;
pid_t pid3;
pid_t pid4;
if ((pid1 = fork()) < 0) {
printf("fork error\n");
} else if (pid1 == 0){
printf("I am in First process\n");
int nodeId = 1;
//cmc_init(nodeId);
test2(nodeId);
return 0;
}
if ((pid2 = fork()) < 0) {
printf("fork error\n");
} else if (pid2 == 0){
printf("I am in second process\n");
int nodeId = 2;
//cmc_init(nodeId);
test2(nodeId);
return 0;
}
if ((pid3 = fork()) < 0) {
printf("pid3 fork error\n");
} else if (pid3 == 0) {
printf("I am in Third process\n");
int nodeId = 3;
//cmc_init(nodeId);
test2(nodeId);
return 0;
}
if ((pid4 = fork()) < 0) {
printf("pid4 fork error\n");
} else if (pid4 == 0) {
printf("I am in Fourth process\n");
int nodeId = 4;
//cmc_init(nodeId);
//test2(nodeId);
return 0;
}
if (waitpid(-1, NULL, 0) < 0) {
printf("wait1 error\n");
}
sleep(3);
return 0;
}
comproc.c
typedef struct Msg_context {
int nodeId;
} Msg_context;
void test2(int nodeId)
{
int i = 1;
for (i = 1; i <= 3; i++) {
if (i == nodeId) {
continue;
}
int msgid = -1;
Msg_context msgSend;
msgid = msgget((key_t)i, 0666 | IPC_CREAT);
if (msgid == -1) {
printf("msgid == -1\n");
}
msgSend.nodeId = nodeId;
if (msgsnd(msgid, (void *)&msgSend, 4, 0) == -1) {
printf("send message error\n");
}
}
//com_process_send(nodeId);
sleep(1);
while (1) {
//com_process_recv(nodeId);
int msgrecvId = -1;
Msg_context msgRecv;
msgrecvId = msgget((key_t)nodeId, 0666 | IPC_CREAT);
if (msgrecvId == -1) {
printf("msgrecvId == -1\n");
}
if (msgrcv(msgrecvId, (void *)&msgRecv, BUFSIZ, 0, 0) == -1) {
printf("send message error\n");
}
printf("[recv] nodeId = %d, recv.nodeId = %d\n", nodeId, msgRecv.nodeId);
}
}
Работает хорошо, результат:
I am in First process
[recv] nodeId = 2, recv.nodeId = 1
[recv] nodeId = 3, recv.nodeId = 1
I am in second process
[recv] nodeId = 1, recv.nodeId = 2
[recv] nodeId = 3, recv.nodeId = 2
I am in Third process
[recv] nodeId = 1, recv.nodeId = 3
[recv] nodeId = 2, recv.nodeId = 3
I am in Fourth process
, но когда я помещаю msgrcv () в другую функцию, она не работает хорошо.Примерно так:
comproc.c
typedef struct Msg_context {
int nodeId;
} Msg_context;
int com_process_recv(int nodeId)
{
int msgrecvId = -1;
Msg_context msgRecv;
msgrecvId = msgget((key_t)nodeId, 0666 | IPC_CREAT);
if (msgrecvId == -1) {
printf("msgrecvId == -1\n");
}
if (msgrcv(msgrecvId, (void *)&msgRecv, BUFSIZ, 0, 0) == -1) {
printf("send message error\n");
}
printf("[recv] nodeId = %d, recv.nodeId = %d\n", nodeId, msgRecv.nodeId);
}
void test2(int nodeId)
{
int i = 1;
for (i = 1; i <= 3; i++) {
if (i == nodeId) {
continue;
}
int msgid = -1;
Msg_context msgSend;
msgid = msgget((key_t)i, 0666 | IPC_CREAT);
if (msgid == -1) {
printf("msgid == -1\n");
}
msgSend.nodeId = nodeId;
if (msgsnd(msgid, (void *)&msgSend, 4, 0) == -1) {
printf("send message error\n");
}
}
//com_process_send(nodeId);
sleep(1);
while (1) {
com_process_recv(nodeId);
}
}
Результат примерно такой:
I am in First process
[recv] nodeId = 2, recv.nodeId = 1
I am in second process
[recv] nodeId = 1, recv.nodeId = 2
[recv] nodeId = 3, recv.nodeId = 2
I am in Third process
[recv] nodeId = 2, recv.nodeId = 3
[recv] nodeId = 1, recv.nodeId = 3
I am in Fourth process
или примерно так:
I am in First process
[recv] nodeId = 2, recv.nodeId = 1
[recv] nodeId = 3, recv.nodeId = 3, ret = 4
I am in second process
[recv] nodeId = 1, recv.nodeId = 2
[recv] nodeId = 3, recv.nodeId = 2
I am in Third process
[recv] nodeId = 1, recv.nodeId = 3
[recv] nodeId = 2, recv.nodeId = 3
I am in Fourth process
но, но, если я добавлю msgsnd () в другую функцию, она снова будет работать хорошо.
comproc.c
typedef struct Msg_context {
int nodeId;
} Msg_context;
int com_process_send(int nodeId)
{
int i = 1;
for (i = 1; i <= 3; i++) {
if (i == nodeId) {
continue;
}
int msgid = -1;
Msg_context msgSend;
msgid = msgget((key_t)i, 0666 | IPC_CREAT);
if (msgid == -1) {
printf("msgid == -1 in %s with nodeId = %d\n", __FUNCTION__, nodeId);
}
msgSend.nodeId = nodeId;
//int length = sizeof(msgSend.nodeId);
int ret = msgsnd(msgid, (void *)&msgSend, 4, 0);
if (ret == -1) {
printf("send message error in %s with nodeId = %d\n", __FUNCTION__, nodeId);
}
printf("[send] nodeId = %d, dest msg = %d\n", nodeId, i);
}
return 0;
}
int com_process_recv(int nodeId)
{
int msgrecvId = -1;
Msg_context msgRecv;
msgrecvId = msgget((key_t)nodeId, 0666 | IPC_CREAT);
if (msgrecvId == -1) {
printf("msgrecvId == -1\n");
}
if (msgrcv(msgrecvId, (void *)&msgRecv, BUFSIZ, 0, 0) == -1) {
printf("send message error\n");
}
printf("[recv] nodeId = %d, recv.nodeId = %d\n", nodeId, msgRecv.nodeId);
}
void test2(int nodeId)
{
com_process_send(nodeId);
sleep(1);
while (1) {
com_process_recv(nodeId);
}
}
Так что это очень странно, верно?Я не понимаю, почему это произошло.Поэтому я очень надеюсь, что вы, ребята, сможете помочь мне понять это.Большое вам спасибо !!!