c - 通过未命名管道进行进程通信
问题描述
我想要做的是在子进程中读取一个文件并通过管道将它传递给父进程。它被修改并存储在另一个数组中,并通过另一个管道传递给子节点,它应该存储在更新的文件中。一切似乎都很好,直到它被修改并且我在父级中有一个修改后的字符串,但我无法将它传递回给子级。以下是代码。我在这里找不到问题,有人可以为我指出吗
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
andwrite
调用不正确。您传递的是指向缓冲区的指针,而不是缓冲区本身。例如,调用:
if(write(fd1[1],&message,size)==-1)
应该:
if(write(fd1[1],message,size)==-1)
与对管道的所有其他调用相同。
您可以考虑读取和写入管道,就像您正在读取和写入文件一样(这些操作在您的代码中是正确的,这就是我这么说的原因)。
推荐阅读
- c++ - Conditional Compile of const static arrays
- android - Android: runtime permission granted for writing in storage but still denied (onRequestPermissionsResult e.g.)
- mdx - 隐藏icCube中实用程序维度的默认成员
- node.js - Multiple condition with $lookup aggregation
- sql - 插入同一个表而不创建重复项或 NULLS?
- c++ - 如何在 C++ 中创建巨大的二维数组
- arduino - 蓝牙板不同步
- ssl - WebSphere 6.1 中的 www.google.com SSL 证书问题
- django - Django - PubSub 或工作流或组合?
- php - 如何在php中将数组存储在由array_chunk分割的表中?