MIT6.S081Lab1： Xv6 and Unix utilities-编程知识

MIT6.S081 Lab1： Xv6 and Unix utilities

官方文档

一.Boot xv6

如何成功的boot xv6可以看之前的文章MIT6.S081实验环境搭建，只是多一个步骤，在clone的文件夹中执行

git checkout util

切换为util分支即可。

二.sleep

在user/sleep.c中编写程序完成用户可以指定tricks数目休眠的sleep程序。

step1

检查参数，转换参数

#include "kernel/types.h"
#include "user.h"int main(int argc, char* argv[]) {// 检查参数数量if (argc != 2) {fprintf(2, "输出参数数量错误!\n");exit(1);}// 转换参数数量int times = atoi(argv[1]);exit(0);
}

step2

调用user中的sleep从而触发系统调用

#include "kernel/types.h"
#include "user.h"int main(int argc, char* argv[]) {// 检查参数数量if (argc != 2) {fprintf(2, "输出参数数量错误!\n");exit(1);}// 转换参数数量int times = atoi(argv[1]);sleep(times);exit(0);
}

step3

进行xv6中运行sleep可观察到明显的延迟

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

在对应文件夹命令行执行

sudo ./grade-lab-util sleep

可看到

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

编写成功！

三.pingpong

父子进程互相发送一个字节并打印内容输出。

step1

创建两个管道

#include "kernel/types.h"
#include "user.h"int main() {// 用于接收一个字节char buf[1];// 两个管道，p1用于父写子读，p2用于子写父读int p1[2], p2[2];pipe(p1);pipe(p2);exit(0);
}

step2

fork一个子进程

#include "kernel/types.h"
#include "user.h"int main() {// 用于接收一个字节char buf[1];// 两个管道，p1用于父写子读，p2用于子写父读int p1[2], p2[2];pipe(p1);pipe(p2);int pid = fork();if (pid > 0) {} else if (pid == 0) {} else {printf(2, "fork error!\n");}exit(0);
}

step3

互相传递一个字节，注意写完后要及时关闭否则read会一直阻塞。

#include "kernel/types.h"
#include "user.h"int main() {// 用于接收一个字节char buf[1];// 两个管道，p1用于父写子读，p2用于子写父读int p1[2], p2[2];pipe(p1);pipe(p2);int pid = fork();if (pid > 0) {// 发送字节write(p1[1], "1", 1);close(p1[1]);// 接收字节read(p2[0], buf, 1);fprintf(1, "%d: received pong\n", getpid());exit(0);} else if (pid == 0) {read(p1[0], buf, 1);fprintf(1, "%d: received ping\n", getpid());write(p2[1], "1", 1);close(p2[1]);exit(0);} else {fprintf(2, "fork error!\n");exit(1);}exit(0);
}

step4

在xv6中运行可看到

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

在对应文件夹命令行中执行

sudo ./grade-lab-util pingpong

可看到

!外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

编写成功！

四.primes

利用fork和pipe组成一个pipeline，并进行2到35的素数筛选。

具体的解决方法可见官方教程。总结来说，就是从左邻居读取的第一个数打印出来作为自己的基数，此后循环从左邻居读取数，判断是否可以被基数整除，如果可以说明不是素数，如果不可以则移交给右邻居。循环这个过程就可以把素数筛选出来。

有两个关键点：1，左右邻居之间怎么通信；2，及时地关闭不需要的文件描述符，否则xv6支持不了这么多文件描述符。

左右邻居之间怎么通信：所谓左右邻居就是父子进程。对于每个素数，我们都要创建一个进程，也就是每个进程（除了最后一个）都要fork一次，在fork前我们要创建管道用于通信，但子进程并不知道管道的文件描述符，所以我们要把管道的读端传给子进程，而子进程又要复刻父进程的行为，很自然就想到要用递归函数，函数的参数就是管道的读端文件描述符。

及时地关闭文件描述符：fork之后父进程用不到读端关闭，子进程用不到写端关闭，子进程用不到父进程本来有的之前的读端关闭

然后注意每个进程只fork一次，如果fork了之后的循环就要判断不fork了。

其实这个最主要的就是利用fork和pipe组成一个pipeline，也就是每个线程要有一个读端一个写端，从父进程那里读，写向子进程，不需要的文件描述符关闭，读端来自于父进程的开辟，写端来自于自己的开辟，然后每个子进程要重复父进程的行为，所以用递归函数，参数传递的读端。

代码如下：

#include "kernel/types.h"
#include "user.h"// 每个进程都要执行的操作
void ProcessOperate(int listen_fd) {// 把第一个读取的数作为基数并打印出来int base = -1;if (read(listen_fd, &base, 4) == -1) {fprintf(2, "%d read listen_fd error!\n", getpid());exit(-1);}fprintf(1, "prime %d\n", base);int is_fork = 0; // 判断当前线程是否已经fork过// 持续读取数据并处理int num = -1;int pipes[2]; // 用于父子进程通信while (read(listen_fd, &num, 4)) {if (num % base != 0) {if (!is_fork) {is_fork = 1;if (pipe(pipes) == -1) {fprintf(2, "%d process create pipe error!\n", getpid());exit(-1);}int pid = fork();if (pid > 0) {close(pipes[0]);} else if (pid == 0) {close(pipes[1]);close(listen_fd);ProcessOperate(pipes[0]);} else {fprintf(2, "%d process fork error\n", getpid());exit(-1);}}write(pipes[1], &num, 4);}}close(listen_fd);close(pipes[1]);wait(0);exit(0);
}int main() {int pipes[2];if (pipe(pipes) == -1) {fprintf(2, "main process create pipe error!\n");exit(-1);}// 先把所有数据写到第一个管道里面for (int i = 2; i <= 35; ++i) {if (write(pipes[1], &i, 4) == -1) {fprintf(2, "main process write pipe error!\n");exit(-1);}}// 关闭不需要的写端close(pipes[1]);// 传递读端，从第一个进程开始筛选素数ProcessOperate(pipes[0]);exit(0);
}

在命令行中运行

sudo ./grade-lab-util primes

可看到

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

成功！

五.find

写一个简化版本的UNIX的find程序：查找目录树中具有特定名称的所有文件。

这个程序其实只要看懂了ls程序是怎么写的基本就会写了。

具体的思路就是对我们输入的目录中的文件或目录进行循环遍历，当遍历到文件，就比较文件的名字和我们要找的名字；当遍历到目录，就递归这个过程。其中用到的函数接口在ls中也会用到，所以看懂了ls程序就知道那些接口怎么用了。

有几点需要注意的地方：

比较文件的名字和我们要找的名字的时候，我们需要提取简化文件的名字，我们当然可以用ls中的fmtname函数，但是注意fmtname中有一个memset(buf+strlen§, ’ ', DIRSIZ-strlen§); 这个是我们不需要的，因为这个是补空方便输出，我们加上这个名字比较就不对了。
每个目录开头的是两个目录".“和”…"，如果不加以排除的话会无限递归，所以要注意
对我来说还有一个，exit是让程序直接退出了，在函数里面还是用return（这个错误找了好久，晕）。

代码如下：

#include "kernel/types.h"
#include "kernel/stat.h"
#include "user/user.h"
#include "kernel/fs.h"// 获取名称
char* fmtname(char *path)
{static char buf[512];char *p;// 提取最后一个/跟的名字for(p=path+strlen(path); p >= path && *p != '/'; p--);p++;memmove(buf, p, strlen(p));buf[strlen(p)] = 0;return buf;
}void find(char *path, char *name) {char buf[512], *p;int fd;struct dirent de;struct stat st;// 打开目录if ((fd = open(path, 0)) < 0) {fprintf(2, "ls: cannot open %s!\n", path);exit(-1);}// 复制路径strcpy(buf, path);p = buf + strlen(buf);*p++ = '/';// 循环判断目录下的文件或目录while (read(fd, &de, sizeof(de)) == sizeof(de)) {if (de.inum == 0) {continue;}// 排除目录开头的.和..if (!strcmp(de.name, ".") || !strcmp(de.name, "..")) {continue;}// 把文件或目录名加到buf后面memmove(p, de.name, strlen(de.name));p[strlen(de.name)] = 0;if (stat(buf, &st) < 0) {fprintf(1, "ls: cannot stat %s \n", buf);continue;}switch(st.type) {case T_FILE:// 如果是文件直接比较if (!strcmp(fmtname(buf), name)) {fprintf(1, "%s\n", buf);}break;case T_DIR:// 目录递归find(buf, name);break;}}close(fd);return;}int main(int argc, char* argv[]) {// 调用函数进行递归查找if (argc < 3) {find(".", argv[1]);exit(0);}find(argv[1], argv[2]);exit(0);
}

六.xargs

编写一个简化版UNIX的xargs程序：它从标准输入中按行读取，并且为每一行执行一个命令，将行作为参数提供给命令。

说明白点，xargs就是执行命令，命令的参数即来自于自身的参数，也来自于标准输入，为标准输入中每一行都执行这样的命令和自身的参数。

那其实就很简单了，就直接从标准输入中读取数据，然后根据\n来划分行，每找到一行就fork一次让子进程exec来执行它。父进程调整一下指针的位置继续执行。

代码如下：

#include "kernel/types.h"
#include "kernel/param.h"
#include "user.h"int main(int argc, char* argv[]) {if (argc > MAXARG) {fprintf(2, "argc > MAXARG\n");exit(-1);}// xargs自身输入的命令及参数char* new_argv[MAXARG];for (int i = 0; i < argc - 1; ++i) {new_argv[i] = argv[i + 1];}char buf[32];char *p = buf;// 读取命令行的输入read(0, buf, 32);int pid;for (int i = 0; i < 32; ++i) {// 如果检测到换行符说明遇到了新的一行，那么就fork让子进程execif (buf[i] == '\n') {pid = fork();if (pid == 0) {// 设定结尾buf[i] = 0;// 设定标准输入作为一个参数new_argv[argc - 1] = p;exec(new_argv[0], new_argv);fprintf(2, "exec error\n");} else {// 更新指针，指向下一行p = &buf[i + 1];wait(0);}}}wait(0);exit(0);
}