下面的简短程序旨在迭代从命令行传递过来的argv并执行每个参数。这不是我的作业,而是我为准备做我的作业而做的事情。
第一个参数从STDIN和STDOUT获取输入,并写入管道。在每次迭代结束时(除了最后一次),文件描述符被交换,以便由最后一个exec写入的管道将被下一个读取。通过这种方式,例如,我打算让...
运行此程序并使用第一个示例(./a.out /bin/pwd /usr/bin/wc)的输出结果为:
第一个参数从STDIN和STDOUT获取输入,并写入管道。在每次迭代结束时(除了最后一次),文件描述符被交换,以便由最后一个exec写入的管道将被下一个读取。通过这种方式,例如,我打算让...
./a.out /bin/pwd /usr/bin/wc
只打印出工作目录的长度。代码如下
#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <stdlib.h>
#include <string.h>
main(int argc, char * argv[]) {
int i;
int left[2], right[2], nbytes; /* arrays for file descriptors */
/* pointers for swapping */
int (* temp);
int (* leftPipe) = left;
int (* rightPipe) = right;
pid_t childpid;
char readbuffer[80];
/* for the first iteration, leftPipe is STDIN */
leftPipe[0] = STDIN_FILENO;
leftPipe[1] = STDOUT_FILENO;
for (i = 1; i < argc; i++) {
/* reopen the right pipe (is this necessary?) */
pipe(rightPipe);
fprintf(stderr, "%d: %s\n", i, argv[i]);
fprintf(stderr, "%d %d %d %d\n", leftPipe[0], leftPipe[1], rightPipe[0], rightPipe[1]);
if ((childpid = fork()) == -1) {
perror("fork");
exit(1);
}
if (childpid == 0) {
/* read input from the left */
close(leftPipe[1]); /* close output */
dup2(leftPipe[0], STDIN_FILENO);
close(leftPipe[0]); /* is this necessary? A tutorial seemed to be doing this */
/* write output to the right */
close(rightPipe[0]); /* close input */
dup2(rightPipe[1], STDOUT_FILENO);
close(rightPipe[1]);
execl(argv[i], argv[i], NULL);
exit(0);
}
wait();
/* on all but the last iteration, swap the pipes */
if (i + 1 < argc) {
/* swap the pipes */
fprintf(stderr, "%d %d %d %d\n", leftPipe[0], leftPipe[1], rightPipe[0], rightPipe[1]);
temp = leftPipe;
leftPipe = rightPipe;
rightPipe = temp;
fprintf(stderr, "%d %d %d %d\n", leftPipe[0], leftPipe[1], rightPipe[0], rightPipe[1]);
}
}
/* read what was last written to the right pipe */
close(rightPipe[1]); /* the receiving process closes 1 */
nbytes = read(rightPipe[0], readbuffer, sizeof(readbuffer));
readbuffer[nbytes] = 0;
fprintf(stderr, "Received string: %s\n", readbuffer);
return 0;
}
更新: 在下面的所有测试用例中,我最初使用了/bin/wc,但 wc 揭示了厕所根本不在我想象的地方。我正在修正结果。
在一个简单的情况下(./a.out /bin/pwd),输出与预期相同:
1: /bin/pwd
Received string: /home/zeigfreid/Works/programmatical/Langara/spring_2012/OS/labs/lab02/play
运行此程序并使用第一个示例(./a.out /bin/pwd /usr/bin/wc)的输出结果为:
1: /bin/pwd
0 1 3 4
3 4 0 1
2: /bin/wc
在此时,终端会挂起(可能在等待输入)。
正如您所看到的,字符串并没有被接收到。我想象中是我在上面做了什么错误的事情,要么交换指针时出了问题,要么我不理解unix文件描述符。我的最终任务将是解释任意长度的管道,这是我解决问题的一个思路。我很难判断自己是否正确地理解了unix文件描述符。
更新:
将第二个参数设置为/bin/ls运行后,我得到了以下结果(数字是各个时间点的文件描述符):
1: /bin/pwd
0 1 3 4
0 1 3 4
3 4 0 1
2: /bin/ls
3 4 5 6
Received string: a.out
log
pipe2.c
play.c
@
这里仍然有一些垃圾,但我现在更担心自己不理解指针!这两个命令是独立的,它们并没有真正利用管道。
更新:垃圾字符是由于未关闭字符串引起的。现在我已经关闭了它,没有垃圾了。
printf(...)
调用更改为fprintf(stderr,...)
。混合使用标准 IO (printf(3)
) 和较低级别的例程 (pipe(2)
,dup2(2)
,close(2)
) 会带来更多麻烦,不值得冒险。 - sarnold