cephfs kernel client针对dir的file

共计 3683 个字符，预计需要花费 10 分钟才能阅读完成。

这篇文章给大家分享的是有关 cephfs kernel client 针对 dir 的 file_operations 操作代码的内容。丸趣 TV 小编觉得挺实用的，因此分享给大家做个参考，一起跟随丸趣 TV 小编过来看看吧。

cephfs kernel client 针对 dir 的 file_operations 操作

const struct file_operations ceph_dir_fops = {

        .read = ceph_read_dir,

        .iterate = ceph_readdir,

        .llseek = ceph_dir_llseek,

        .open = ceph_open,

        .release = ceph_release,

        .unlocked_ioctl = ceph_ioctl,

        .fsync = ceph_fsync,

};

ceph_read_dir(struct file *file, char __user *buf, size_t size, loff_t *ppos)    只有在 mount 时带有参数 -o dirstat 时该函数才有效

|__调用 ceph_test_mount_opt() 函数检查 mount options 中是否包含 DIRSTAT，若不包含则直接返回

|__若 struct ceph_file_info 中的 dir_info 为空

   |__调用 kmalloc() 函数为 dir_info 分配空间

   |__使用 snprintf() 函数向 dir_info 的内存空间进行格式化输出

|__调用 copy_to_user() 函数将 dir_info 中的内容复制到用户态空间 buf 中

ceph_readdir(struct file *file, struct dir_context *ctx)

|__调用 dir_emit() 函数向外发布”.”和”..”信息

|__若 mount options 中包含 DCACHE 则说明应该尽可能的从 dcache 中读取 dir 的信息

   |__调用__dcache_readdir() 函数从 dcache 中读取 dir

   |__返回值不等于 EAGAIN

     |__直接返回

|__调用 need_send_readdir() 函数检查是否应该从集群中读取 dir 的内容

   |__得到操作码 op=CEPH_MDS_OP_LSSNAP 或者 CEPH_MDS_OP_READDIR

   |__调用 ceph_mdsc_create_request() 函数创建 mds 请求

   |__调用 ceph_alloc_readdir_reply_buffer() 函数为从集群中读取到的 dir 内容分配内存空间

   |__调用 ceph_mdsc_do_request() 函数将请求同步发送给 mds 进程

|__遍历 struct ceph_file_info- last_readdir- r_reply_info- dir_nr

   |__调用 dir_emit() 函数向外发布 dir 信息

ceph_dir_llseek(struct file *file, loff_t offset, int whence)

|__根据 whence 的不同值更新 offset 的值

|__若 offset =0

   |__调用 need_reset_readdir() 函数检查是否需要 reset readdir

     |__调用 reset_readdir() 函数

   |__调整 file- f_pos 值为 offset 值

ceph_open(struct inode *inode, struct file *file)    该函数在打开文件时被调用

|__调用 prepare_open_request() 函数来创建 ceph_mds_request 请求

|__调用 ceph_mdsc_do_request() 函数将 ceph_mds_request 请求同步的发送给 mds 进程

|__调用 ceph_init_file() 函数创建 ceph_file_info 数据结构且将该数据结构放入到 file- private_data 中

ceph_release(struct inode *inode, struct file *file)    该函数在关闭文件时被调用

|__调用 ceph_put_fmode() 函数减少打开文件的引用次数，若引用次数为 0，则从本地 cache 中删除该文件

ceph_ioctl(struct file *file, unsigned int cmd, unsigned long arg)

|__根据 cmd 的值做不同的处理

   |__cmd==CEPH_IOC_GET_LAYOUT

     |__ceph_ioctl_get_layout()

       |__ceph_do_getattr(CEPH_STAT_CAP_LAYOUT) 从 mds 集群中读取 file 对应的 inode 的 layout 信息到 ceph_inode_info 的 i_layout 中

       |__将 i_layout 信息写入到 struct ceph_ioctl_layout 数据结构中且通过 copy_to_user() 函数将数据返回给用户态

   |__cmd==CEPH_IOC_SET_LAYOUT

     |__ceph_ioctl_set_layout()

       |__调用 copy_from_user() 函数将新的 layout 信息从用户态复制到内核态

       |__调用 ceph_do_getattr() 函数从 mds 集群中读取当前的 layout 信息

       |__调用__validate_layout() 函数检查新设置的 layout 是否有效

       |__调用 ceph_mdsc_create_request() 函数创建 request 请求

       |__调用 ceph_mdsc_do_request() 函数同步的发送 request 请求到 mds 集群

   |__cmd==CEPH_IOC_SET_LAYOUT_POLICY

     |__ceph_ioctl_set_layout_policy()

       |__调用 copy_from_user() 函数将新的 layout 信息从用户态复制到内核态

       |__调用__validate_layout() 函数检查新设置的 layout 是否有效

       |__调用 ceph_mdsc_create_request() 函数创建 request 请求

       |__调用 ceph_mdsc_do_request() 函数同步的发送 request 请求到 mds 集群

   |__cmd==CEPH_IOC_GET_DATALOC          计算 data 所在的 ceph 集群中的位置信息

     |__ceph_ioctl_get_dataloc()

       |__调用 copy_from_user() 函数将 ceph_ioctl_dataloc 信息复制到内核态

       |__调用 ceph_calc_file_object_mapping() 函数计算 ceph_ioctl_dataloc 信息中指定文件所在的 oid 等信息

       |__调用 ceph_object_locator_to_pg() 函数计算出 oid 所在的 pg 信息

       |__调用 ceph_pg_to_acting_primary() 函数计算出 pg 所在的主 osd 信息

       |__调用 copy_to_user() 函数将计算出来的信息发送回给用户态

   |__cmd==CEPH_IOC_LAZYIO              设置 LAZYIO 标识

     |__ceph_ioctl_lazyio()

       |__ 判断 struct ceph_file_info 中的 fmode 是否未设置 CEPH_FILE_MODE_LAZY

         |__设置 struct ceph_file_info 中的 fmode 拥有 CEPH_FILE_MODE_LAZY 标识

         |__更新 ceph_inode_info 中的 i_nr_by_mode 数组

         |__调用 ceph_check_caps() 函数更新 caps

   |__cmd==CEPH_IOC_SYNCIO

     |__ceph_ioctl_syncio()

       |__设置 struct ceph_file_info 结构中的 flags 的 CEPH_F_SYNC 位

ceph_fsync(struct file *file, loff_t start , loff_t end, int datasync)

|__调用 ceph_sync_write_wait() 函数等待 inode 上所有未完成的 osd 请求执行完毕

|__调用 try_flush_caps() 函数将所有 dirty 的 caps 刷回到 mds

|__调用 unsafe_request_wait() 函数等待 inode 上所有针对 mds 请求执行完毕

感谢各位的阅读！关于“cephfs kernel client 针对 dir 的 file_operations 操作代码”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！