首页 > 代码库 > 后台while收发过程
后台while收发过程
fuse_loop_mt.c 中fuse_do_work函数使用while循环在后台不断运行,每一个while循环中,主要有两个操作。
1. fuse_session_receive_buf(mt->se, &fbuf, &ch); fuse_session.c
2. fuse_session_process_buf(mt->se, &fbuf, ch);
操作1使用 se->receive_buf(se, buf, chp)读取buffer内容。
操作2使用se->process_buf(se->data, buf, ch);处理buffer内容。
receive_buf和process_buf是两个函数指针,属于fuse_i.h的struct fuse_session的成员。
搜索整个源文件,只发现在fuse_lowlevel.c中的struct fuse_session *fuse_lowlevel_new_common有一句
se->receive_buf = fuse_ll_receive_buf; //fuse_ll_receive_buf函数也在该源文件中。
经过打印发现,就是这个函数在处理接受。
//////fuse_ll_receive_buf函数有个重要的操作是创建pipe, 调用 llp = fuse_ll_get_pipe(f);
////static struct fuse_ll_pipe *fuse_ll_get_pipe(struct fuse_ll *f)函数使用
//// res = pipe(llp->pipe);
/////创建pipe。
这个函数会转到fallback标签,因为 !(f->conn.want & FUSE_CAP_SPLICE_READ) 为真,一个是16,一个是512,与以后为0,取反为真。
于是调用 fuse_chan_recv(struct fuse_chan **chp, char *buf, size_t size 函数。该函数在fuse_session.c中。
在一开始的两个操作中,都有if语句,else是进入 fuse_chan_recv函数,但是那里都没有进入else,而最终还是在这里进入了该函数。
然后调用int res=ch->op.receive(chp, buf, size);
其中ch是struct fuse_chan **类型,定义在fuse_session.c中。op是struct fuse_chan_ops类型,定义在fuse_lowlevel.h中。
但是无法得知receive函数定义在哪,这需要追中ch及op在哪里被赋值。
追踪:
1. ch 在fuse_chan_recv(fuse_session.c)中没有被修改,因此其值从fuse_ll_receive_buf(fuse_lowlevel.c)传递来.
2. 在fuse_ll_receive_buf中仍然没有被修改。
此处发现,struct fuse_session在fuse_i.h中声明,在fuse_lowlevel.c中给其成员函数指针赋值。
因此,值从fuse_session_receive_buf(fuse_session.c )中传来。
3. fuse_session_receive_buf是被fuse_do_work(fuse_loop_mt.c )调用的。
后台while收发过程