通过未命名管道进行进程通信
Process Communication via unnamed pipes
我想做的是在 child 进程中读取文件并通过管道将其传递给 parent。它被修改并存储在另一个数组中,并通过另一个管道传递到 child,它将存储在更新的文件中。一切似乎都很好,直到它被修改,我在 parent 中有一个修改过的字符串,但我无法将它传回 child。以下是代码。我在这里找不到问题,有人能帮我指出吗
int main(int argc,char ** argv)
{int fd1[2];
int fd2[2];
int fdo,fdi;
long int size=findSize(argv[1]);
if(pipe(fd1)==-1)
{write(1,"Error",5);
return 2;}
if(pipe(fd2)==-1)
{write(1,"Error",5);
return 1;}
fdi=open(argv[1],O_RDONLY);
fdo=open(argv[2],O_WRONLY);
int e=fork();
//_______________________________________________________
if(e==0)
{//close(fd1[0]);
//close(fd2[1]);
char * message;
char * message2;
message=malloc(size);
message2=malloc(size);
if(fdi!=-1)
{
if(read(fdi,message,size)==-1)
{
write(1,"Error",5);
return 0;
}}
//printf("%s",message);
if(write(fd1[1],&message,size)==-1)
printf("error agya paiin\n");
//wait(NULL);
read(fd2[0],&message2,size);
printf("__________________________________________\n %s",message2);
if(fdo!=-1)
{
if(write(fdo,message2,size)==-1)
{
write(1,"Error",5);
return 0;
}}
close(fd1[1]);
close(fd2[0]);
}
//_______________________________________________
if(e>0)
{
close(fd1[1]);
close(fd2[0]);
char * message;
char * message2;
message=malloc(size);
message2=malloc(size);
for(int i=0;i<size;i++)
{
message2[i]=32;
}
if(read(fd1[0],&message,size)==-1)
printf("error\n");
int j=0;
for(int i=0;i<size;i++)
{
if((message[i]<48) || (message[i]>57))
{
message2[j]=message[i];
if((message[i]>64) && (message[i]<91))
{
message2[j]+=32;
}
else if((message[i]>96) && (message[i]<123))
{
message2[j]-=32;
}
j++;
}
}
message2[j]=0;
if(write(fd2[1],&message2,size)==-1)
{printf("could not pass\n");
return 1;}
close(fd1[0]);
close(fd2[1]);
}
return 0;
}```
您在管道上进行的 read
和 write
调用不正确。您正在传递一个指向缓冲区的指针而不是缓冲区本身。例如,调用:
if(write(fd1[1],&message,size)==-1)
应该是:
if(write(fd1[1],message,size)==-1)
与所有其他管道调用相同。
你可以把对管道的读写想象成对文件的读写(这些操作在你的代码中是正确的,这就是我这么说的原因)。
我想做的是在 child 进程中读取文件并通过管道将其传递给 parent。它被修改并存储在另一个数组中,并通过另一个管道传递到 child,它将存储在更新的文件中。一切似乎都很好,直到它被修改,我在 parent 中有一个修改过的字符串,但我无法将它传回 child。以下是代码。我在这里找不到问题,有人能帮我指出吗
int main(int argc,char ** argv)
{int fd1[2];
int fd2[2];
int fdo,fdi;
long int size=findSize(argv[1]);
if(pipe(fd1)==-1)
{write(1,"Error",5);
return 2;}
if(pipe(fd2)==-1)
{write(1,"Error",5);
return 1;}
fdi=open(argv[1],O_RDONLY);
fdo=open(argv[2],O_WRONLY);
int e=fork();
//_______________________________________________________
if(e==0)
{//close(fd1[0]);
//close(fd2[1]);
char * message;
char * message2;
message=malloc(size);
message2=malloc(size);
if(fdi!=-1)
{
if(read(fdi,message,size)==-1)
{
write(1,"Error",5);
return 0;
}}
//printf("%s",message);
if(write(fd1[1],&message,size)==-1)
printf("error agya paiin\n");
//wait(NULL);
read(fd2[0],&message2,size);
printf("__________________________________________\n %s",message2);
if(fdo!=-1)
{
if(write(fdo,message2,size)==-1)
{
write(1,"Error",5);
return 0;
}}
close(fd1[1]);
close(fd2[0]);
}
//_______________________________________________
if(e>0)
{
close(fd1[1]);
close(fd2[0]);
char * message;
char * message2;
message=malloc(size);
message2=malloc(size);
for(int i=0;i<size;i++)
{
message2[i]=32;
}
if(read(fd1[0],&message,size)==-1)
printf("error\n");
int j=0;
for(int i=0;i<size;i++)
{
if((message[i]<48) || (message[i]>57))
{
message2[j]=message[i];
if((message[i]>64) && (message[i]<91))
{
message2[j]+=32;
}
else if((message[i]>96) && (message[i]<123))
{
message2[j]-=32;
}
j++;
}
}
message2[j]=0;
if(write(fd2[1],&message2,size)==-1)
{printf("could not pass\n");
return 1;}
close(fd1[0]);
close(fd2[1]);
}
return 0;
}```
您在管道上进行的 read
和 write
调用不正确。您正在传递一个指向缓冲区的指针而不是缓冲区本身。例如,调用:
if(write(fd1[1],&message,size)==-1)
应该是:
if(write(fd1[1],message,size)==-1)
与所有其他管道调用相同。
你可以把对管道的读写想象成对文件的读写(这些操作在你的代码中是正确的,这就是我这么说的原因)。