cephfslinuxkernelclient针对linuxpagecache的操作代码

这篇文章主要介绍cephfs linux kernel client针对linux page cache的操作代码，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！

专注于为中小企业提供成都网站设计、网站建设服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业永安免费做网站提供优质的服务。我们立足成都，凝聚了一批互联网行业人才，有力地推动了上千余家企业的稳健成长，帮助中小企业通过网站建设实现规模扩充和转变。

针对linux page cache的操作主要体现在struct address_space_operations数据结构中，cephfs处理linux page cache的函数集合如下：

const struct address_space_operations ceph_aops = {

        .readpage = ceph_readpage,

        .readpages = ceph_readpages,

        .writepage = ceph_writepage,

        .writepages = ceph_writepages_start,

        .write_begin = ceph_write_begin,

        .write_end = ceph_write_end,

        .set_page_dirty = ceph_set_page_dirty,

        .invalidatepage = ceph_invalidatepage,

        .releasepage = ceph_releasepage,

        .direct_IO = ceph_direct_io,

};

ceph_readpage(struct file *filp, struct page *page)

|__调用readpage_nounlock(filep, page)     在加锁的情况下读取一个物理内存页的数据

    |__确定page的offset没有超出inode的总长度

    |__调用ceph_readpage_from_fscache()函数尝试从fscache中读取一个物理内存页的数据

        |__若读取成功则直接返回

    |__调用ceph_osdc_readpages()函数从ceph集群中读取一个物理内存页的数据

        |__调用ceph_osdc_new_reqeust()函数创建一个读请求

        |__调用osd_req_op_extent_osd_data_pages()函数为读请求的返回内容分配内存空间

        |__调用ceph_osdc_start_request()函数将读请求同步发送给ceph集群

    |__调用flush_dcache_page()函数刷page到dcache中

    |__调用SetPageUptodate()函数设置物理内存页的状态是update的

    |__调用ceph_readpage_to_fscache()函数将新读到的物理内存页更新到fscache中

|__调用unlock_page(page)

    |__调用clear_bit_unlock()函数为page解锁

    |__调用wake_up_page()函数唤醒等待该page的相关进程

ceph_readpages(struct file *file, struct address_space *mapping, struct list_head *page_list, unsigned nr_pages)    读取多个页

|__调用ceph_readpages_from_fscache()函数尝试从fscache中读取多个物理内存页的数据

    |__若读取成功则直接返回

|__遍历page_list

    |__调用start_read()函数读取数据到page_list所包含的物理内存页

        |__调用ceph_osdc_new_reqeust()函数创建一个读请求

        |__调用calc_pages_for(0, len)函数得到读取指定长度len的数据需要的物理内存页数

        |__从page_list中摘下指定数量的物理内存页

        |__调用osd_req_op_extent_osd_data_pages()函数将从page_list中摘下的物理内存页作为读请求的接收缓冲

        |__设置读请求完成后的回调函数为finish_read()

        |__调用ceph_osdc_start_request()函数将读请求同步发送给ceph集群

finish_read(struct ceph_osd_request *req)        从ceph集群中读操作结束后的回调函数

|__遍历读取到的所有物理内存页

    |__调用flush_dcache_page()函数将page中的内存刷到dcache中

    |__调用SetPageUptodate()函数设置page的状态是uptodate的

    |__调用ceph_readpage_to_fscache()函数将读取到的page内存同步到fscache中

ceph_writepage(struct page *page, struct writeback_control *wbc)

|__调用writepage_nounlock(page,wbc)函数同步page信息到ceph集群

    |__调用page_snap_context()函数得到page的snap context信息(page将CephSnapContext信息写入到page的private中)

    |__调用set_page_writeback(page)函数设置page writeback标识

    |__调用ceph_osdc_writepages()函数将page信息同步写到ceph集群

        |__调用ceph_osdc_new_reqeust()函数创建一个写请求

        |__调用osd_req_op_extent_osd_data_pages()函数为写请求设置写内容物理内存页

        |__调用ceph_osdc_start_request()函数将写请求同步发送给ceph集群

    |__设置page->private=0，即：删除page的CephSnapContext信息

    |__调用ClearPagePrivate(page)函数清空page的private

    |__调用end_page_writeback()函数

        |__调用wake_up_page(page, PG_writeback)函数唤醒在page上等待writeback完成的进程

ceph_writepages_start(struct address_space *mapping, struct writeback_control *wbc)

|__调用pagevec_init(&pvec, 0)函数初始化struct pagevec实例pvec

|__从wbc的range_start和range_end中得到start和end

|__调用pagevec_lookup_tag(&pvec, mapping, PAGECACHE_TAG_DIRTY…)函数从mapping中radix tree中找到tags==PAGECACHE_TAG_DIRTY的所有pages且将所有pages写入到pvec中

|__遍历所有PAGECACHE_TAG_DIRTY的pages

    |__调用page_offset()函数得到page所在的offset值

    |__调用ceph_calc_file_object_mapping()函数得到从offset开始，长度是len的文件所占用的objects个数以及在object中的偏移

    |__将page添加到pages数组中

|__从pages数组中得到offset值，即：offset=page_offset(pages[0])

|__调用ceph_osdc_new_request()函数创建一个写数据请求

|__设置写数据请求的回调函数为writepages_finish

|__调用osd_req_op_extent_osd_data_pages()函数添加写请求额外的数据

|__调用ceph_osdc_start_request()函数将写请求同步发送到ceph集群

writepages_finish(struct ceph_osd_request *req)

|__清除所有在发送写请求过程中产生的内存

ceph_write_begin(struct file *file, struct address_space *mapping, loff_t pos, unsigned len, unsigend flags, staruct page **pagep, void **fsdata)

|__得到pos所在的page位置，即：index=pos >> PAGE_SHIFT

|__调用grab_cache_page_write_begin(mapping, index, flags)函数在pagecache中指定位置index出获取或创建一个物理内存页page

    |__调用pagecache_get_page()函数在pagecache中指定位置index出获取或创建一个物理内存页page

    |__调用wait_for_stable_page(page)函数等待该page上的writeback函数返回

|__调用ceph_update_writeable_page(file, pos, len, page)函数只允许往clean page里写入数据或者已经dirty的snap context里写入数据

    |__调用wait_on_page_writeback(page)函数等待page的writeback完成

    |__调用page_snap_context(page)函数得到该page的snap context

    |__若snap context的seq > oldest->seq

        |__调用ceph_queue_writeback(inode)函数将inode放入到writeback队列中

    |__调用clear_page_dirty_for_io(page)函数清除page上的dirty标识

    |__调用writepage_nounlock(page, NULL)函数将page数据同步的写入到ceph集群

    |__调用PageUptodate(page)检查page是否是uptodate的

        |__是则直接返回

    |__若page已经满了

        |__直接返回

    |__调用i_size_read(inode)函数得到inode的读数据的大小

    |__调用readpage_nounlock(file, page)函数从ceph集群中读取数据到page中

ceph_write_end(struct file *file, struct address_space *mapping, loff_t pos, unsigned len, unsigned copied, struct page **page, void *fsdata)

|__若copied < len

    |__调用zero_user_segment(page, from+copied, len)函数将page中从from+copied一直到from+copied+len的内存空间置0

|__若pos+copied > i_size_read(inode)

    |__调用ceph_inode_set_size()函数设置inode的size为pos+copied

|__若Page不是uptodate的

    |__调用SetPageUptodate(page)函数设置page是uptodate的

|__调用set_page_dirty(page)函数设置page是dirty的

ceph_set_page_dirty(struct page *page)

|__若PageDirty(page)

    |__直接返回

|__通过mapping的到struct ceph_inode_info结构

|__调用__ceph_have_pending_cap_snap()函数检查cephfs是否有snaps

    |__从struct ceph_inode_info结构中的i_cap_snaps列表中得到struct ceph_cap_snap结构

    |__从struct ceph_cap_snap结构中得到struct ceph_snap_context结构

|__若cephfs没有snaps

    |__调用ceph_get_snap_context()函数从struct ceph_inode_info的i_head_spapc中得到struct ceph_snap_context结构

|__将struct ceph_snap_context结构设置到page的private中，即：page->private=snapc

|__调用__set_page_dirty_nobuffers()函数将page在address_spaces中的radix tree中设置成dirty

ceph_invalidatepage(struct page *page, unsigned int offset, unsigned int length)

|__调用ceph_invalidate_fscache_page()函数使得page在fscache中无效

|__若page没有private

    |__直接返回

|__设置page->private=0清除page的snaps

|__调用ClearPagePriavte(page)

ceph_releasepage(struct page *page, gfp_t g)

|__调用ceph_release_fscache_page()函数在fscache中删除page

|__返回!PagePrivate(page)

ceph_direct_io(struct kiocb *iocb, struct iov_iter *iter)

|__返回-EINVAL

以上是“cephfs linux kernel client针对linux page cache的操作代码”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注创新互联行业资讯频道！