fuse是并发处理I/O请求的

wcw

                                测试方法：
在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

大致处理逻辑是这样的：

1. fuse_do_work {
   
2.    
   
3.     loop {
   
4.         // 接受请求：阻塞read，fuse_kern_chan.c:fuse_kern_chan_receive:read 没有加任何锁
   
5.         fuse_session_receive_buf
   
6.         
   
7.         pthread_mutex_lock(&mt->lock);
   
8.         
   
9.         // 判断是否有可用的worker
   
10.         if (mt->numavail <= 1) fuse_loop_start_thread();
    
11.         
    
12.         pthread_mutex_unlock(&mt->lock);
    
13.         
    
14.         // 处理请求
    
15.         fuse_session_process_buf
    
16.         
    
17.         pthread_mutex_lock(&mt->lock);
    
18.         
    
19.         // 判断 worker 线程是不是太多
    
20.         if (mt->numavail > 50) {
    
21.             // 释放一个worker
    
22.             list_del_worker
    
23.         }
    
24.         pthread_mutex_unlock(&mt->lock);
    
25.     }
    
26. }

复制代码