Chinaunix

标题: fuse是并发处理I/O请求的 [打印本页]

作者: wcw 时间: 2008-08-04 10:16
标题: fuse是并发处理I/O请求的

测试方法：
在xmp_readdir函数中加入一下代码
static int i = 0;
if (i == 0) {
printf("have a break here...\n", i);
getchar();
}
i++;
以上代码的作用是，当第一次调用（比如ls会调用）时，会产生一次中断，在fuse端会等待用户输入。
实验1：
1$： ./fusetest -d /mnt/osd/，这样就把文件系统挂载到/mnt/osd中
2$： cd /mnt/osd/home/wcw/
3$： cd /mnt/osd/home/wcw
2$: ls
3$： ls
可以看到，终端2和3都被阻塞了，从一下终端1的输出中则可以发现2阻塞的原因是我们加入的那块代码（要求在终端1中输入）；3阻塞的原因则是由于fuse自己（有可能，也可能是其它的，像vfs）的某种锁机制，使得3在进入xmp_readdir的调用之前就被锁住了，因为2还没完成
unique: 14, opcode: OPENDIR (27), nodeid: 3, insize: 48
unique: 14, error: 0 (Success), outsize: 32
unique: 15, opcode: GETATTR (3), nodeid: 3, insize: 56
/home/wcw
unique: 15, error: 0 (Success), outsize: 112
unique: 16, opcode: READDIR (28), nodeid: 3, insize: 80
/home/wcw
have a break here... /*2阻塞的原因*/
unique: 17, opcode: OPENDIR (27), nodeid: 3, insize: 48
unique: 17, error: 0 (Success), outsize: 32
unique: 18, opcode: GETATTR (3), nodeid: 3, insize: 56
/home/wcw /* 3阻塞的地方 */
unique: 18, error: 0 (Success), outsize: 112
上面实验是对同一目录的操作，下面是对不同目录的操作：
实验2：
1$： ./fusetest -d /mnt/osd/
2$： cd /mnt/osd/home/wcw/
3$： cd /mnt/osd/home/wcw/bb
2$: ls
3$： ls
结果同样是2和3都被阻塞：
unique: 16, opcode: OPENDIR (27), nodeid: 3, insize: 48
unique: 16, error: 0 (Success), outsize: 32
unique: 17, opcode: GETATTR (3), nodeid: 3, insize: 56
/home/wcw
unique: 17, error: 0 (Success), outsize: 112
unique: 18, opcode: READDIR (28), nodeid: 3, insize: 80
/home/wcw
have a break here...
unique: 19, opcode: OPENDIR (27), nodeid: 4, insize: 48
unique: 19, error: 0 (Success), outsize: 32
unique: 20, opcode: GETATTR (3), nodeid: 4, insize: 56
/home/wcw/bb
unique: 20, error: 0 (Success), outsize: 112
unique: 21, opcode: READDIR (28), nodeid: 4, insize: 80
/home/wcw/bb
have a break here...
阻塞的原因都是上面加入的代码片段。3被阻塞并不是像像实验1中因为fuse上锁机制，大概是因为访问的并不是同一个目录（资源），因此不会造成竞争的原因。
实验结论：
fuse是并行的发送I/O请求的。这里的并行指的是，fuse对I/O操作用了多线程（应该不会是多进程），即为每个I/O操作创建一个独立的线程（如上面的readdir函数）。fuse（或者vfs等）提供了某种琐机制，对竞争资源做出同步（如实验1）。

本文来自ChinaUnix博客，如果查看原文请点：http://blog.chinaunix.net/u1/37472/showart_1103987.html

作者: cjfeii 时间: 2017-01-19 17:52
大致处理逻辑是这样的：

fuse_do_work {
loop {
// 接受请求：阻塞read，fuse_kern_chan.c:fuse_kern_chan_receive:read 没有加任何锁
fuse_session_receive_buf
pthread_mutex_lock(&mt->lock);
// 判断是否有可用的worker
if (mt->numavail <= 1) fuse_loop_start_thread();
pthread_mutex_unlock(&mt->lock);
// 处理请求
fuse_session_process_buf
pthread_mutex_lock(&mt->lock);
// 判断 worker 线程是不是太多
if (mt->numavail > 50) {
// 释放一个worker
list_del_worker
}
pthread_mutex_unlock(&mt->lock);
}
}

复制代码

欢迎光临 Chinaunix (http://bbs.chinaunix.net/)