1

我需要编写一个简单的程序：将有一个 Parent 和一些程序 [children]（通过execlParent 开始）。孩子们以这种方式相互交流：孩子我感知到父母编号 J，父母向 J 发送消息（类似于 - “有消息给你”），J 发送给父母编号 K 等等。

还有一个问题——我的程序（通过strace命令测试）试图向孩子发送一条消息，然后出现了损坏的管道错误。

如果有人查看代码并告诉我出了什么问题，我将不胜感激：

这是代码：

/**
 * Arbiter zabawy w Losia
 *

 wersja: Alfa 3b
 początek edycji 25.01.2009
 */

#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include "err.h"

pid_t pid;
FILE *a;

int main ()
{
    // my N players
    int N;
    N = 10;
    //write -- writing from parent to child 
    //read -- reading from child
    int rurka_write[N+1][2]; 
    int rurka_read[N+1][2];
    //initiation of N players
    int i;
    for(i = 1; i <= N; i++)
    {
        //tworze lacza
        if (pipe(rurka_write[i]) == -1)
            printf("wystapil blad przy rurce %d\n", i);
        if (pipe(rurka_read[i]) == -1)
            printf("wystapil blad przy rurce %d\n", i); 
    }
    for(i = 1; i <= N; i++)
    {
        switch(pid = fork())
        {
            case -1: 
                printf("wystapil blad przy forkowaniu");
            case 0:
                printf("potomek numer %d\n", i);
                if (close(rurka_write[i][1]) == -1)
                    printf("zle zamykanie");
                if (close(rurka_read[i][0]) == -1)
                    printf("zle zamykanie");

                //closing useless descriptors
                int j;
                for(j = 1; j <= N; j++)
                {
                    if (j != i)
                    {
                        close(rurka_read[j][0]);
                        close(rurka_read[j][1]);
                        close(rurka_write[j][0]);
                        close(rurka_write[j][1]);
                    }
                }   

                char str_N[20];
                char str_i[20];
                char str_0[20];
                char str_1[20];

                sprintf(str_N, "%d", N);
                sprintf(str_i, "%d", i);
                sprintf(str_0, "%d", rurka_write[i][0]);
                sprintf(str_1, "%d", rurka_read[i][1]);

                printf("%d Executing execl\n", i);
                execl("./ucz", str_N, str_i, str_0, str_1, NULL);
                printf("execl executed\n");
//              execv("./ucz", str_N, str_i, str_0, str_1, NULL);
                //exit(0);
            default:
                //closing useless pipes
                if (close(rurka_read[i][1]) == -1)
                    printf("zle zamykanie rurki do czytania z potomkna\n");
                if (close(rurka_write[i][0]) == -1)
                    printf("zle zamykanie rurki do pisania do potomka\n");
        } //end of switch

    } //end of for
    //if I am in parent, I'm starting the game
    if (pid != 0)
//  delay(100);
    {
        printf("PLAY\n");
        int l = 1;
        while(l > 0)
        {
            printf("sending to player %d\n", l);
            a = fdopen(rurka_write[l][1], "w");
            printf("sending: Wake up");
            fprintf(a, "Wake up\n");
            printf("flushing");
            fflush(a);
            char k[20];
            printf("reading");
            read(rurka_read[l][0], k, 20);
            l = k;
        }
    }
}
4

2 回答 2

2

除了您没有以 a 结束您的案件break（正如 strager 所指出的那样）之外，主要问题是语句l = k;. 请注意，它k是 achar[20]并且，当分配给 a 时int，您不会将任何内容分配给kto l。而是l包含指向数组的指针（的值）。您将不得不在这里做一些不同的事情来获取数组中的值；究竟是什么取决于ucz发回。

修复此问题并自己制作后ucz，该程序似乎可以正常工作。当然，也可能是你的ucz.

于 2009-01-26T18:26:53.287 回答
0

关于 ./ucz -- 它需要 4 个参数 -- 1st -- 玩家数量，2nd -- 玩家数量，3rd -- 从父级读取的描述符数， 4th -- 要写入父级的描述符数。

在 exec 之后添加 exit(0)、return(0)、break （或在“case：0”的末尾）没有帮助。

于 2009-01-26T09:40:25.690 回答