Lines Matching refs:mi
42 struct mount_info *mi = get_mount_info(file_superblock(f)); in pending_reads_read() local
54 if (!mi) in pending_reads_read()
57 report_uid = mi->mi_options.report_uid; in pending_reads_read()
61 if (!incfs_fresh_pending_reads_exist(mi, last_known_read_sn)) in pending_reads_read()
76 reads_collected = incfs_collect_pending_reads(mi, last_known_read_sn, in pending_reads_read()
109 struct mount_info *mi = get_mount_info(file_superblock(file)); in pending_reads_poll() local
112 poll_wait(file, &mi->mi_pending_reads_notif_wq, wait); in pending_reads_poll()
113 if (incfs_fresh_pending_reads_exist(mi, in pending_reads_poll()
236 struct mount_info *mi, in dir_relative_path_resolve() argument
246 base_path = &mi->mi_backing_dir_path; in dir_relative_path_resolve()
299 static int init_new_file(struct mount_info *mi, struct dentry *dentry, in init_new_file() argument
311 if (!mi || !dentry || !uuid) in init_new_file()
316 .mnt = mi->mi_backing_dir_path.mnt, in init_new_file()
328 bfc = incfs_alloc_bfc(mi, new_file); in init_new_file()
393 struct mount_info *mi = in notify_create() local
404 error = dir_relative_path_resolve(mi, dir_name, &dir_path, &base_path); in notify_create()
468 struct mount_info *mi = get_mount_info(file_superblock(file)); in ioctl_create_file() local
485 if (!mi || !mi->mi_index_dir || !mi->mi_incomplete_dir) { in ioctl_create_file()
512 error = mutex_lock_interruptible(&mi->mi_dir_struct_mutex); in ioctl_create_file()
518 error = dir_relative_path_resolve(mi, in ioctl_create_file()
524 if (parent_dir_path.dentry == mi->mi_index_dir) { in ioctl_create_file()
530 if (parent_dir_path.dentry == mi->mi_incomplete_dir) { in ioctl_create_file()
555 incomplete_file_dentry = incfs_lookup_dentry(mi->mi_incomplete_dir, in ioctl_create_file()
573 index_file_dentry = incfs_lookup_dentry(mi->mi_index_dir, file_id_str); in ioctl_create_file()
590 index_dir_inode = d_inode(mi->mi_index_dir); in ioctl_create_file()
657 error = init_new_file(mi, index_file_dentry, &args.file_id, args.size, in ioctl_create_file()
701 mutex_unlock(&mi->mi_dir_struct_mutex); in ioctl_create_file()
706 static int init_new_mapped_file(struct mount_info *mi, struct dentry *dentry, in init_new_mapped_file() argument
714 if (!mi || !dentry || !uuid) in init_new_mapped_file()
719 .mnt = mi->mi_backing_dir_path.mnt, in init_new_mapped_file()
730 bfc = incfs_alloc_bfc(mi, new_file); in init_new_mapped_file()
756 struct mount_info *mi = get_mount_info(file_superblock(file)); in ioctl_create_mapped_file() local
796 source_file_dentry = incfs_lookup_dentry(mi->mi_index_dir, in ioctl_create_mapped_file()
834 error = dir_relative_path_resolve(mi, in ioctl_create_mapped_file()
840 if (parent_dir_path.dentry == mi->mi_index_dir) { in ioctl_create_mapped_file()
886 error = init_new_mapped_file(mi, file_dentry, &args.source_file_id, in ioctl_create_mapped_file()
908 static long ioctl_get_read_timeouts(struct mount_info *mi, void __user *arg) in ioctl_get_read_timeouts() argument
926 spin_lock(&mi->mi_per_uid_read_timeouts_lock); in ioctl_get_read_timeouts()
927 size = mi->mi_per_uid_read_timeouts_size; in ioctl_get_read_timeouts()
931 memcpy(buffer, mi->mi_per_uid_read_timeouts, size); in ioctl_get_read_timeouts()
932 spin_unlock(&mi->mi_per_uid_read_timeouts_lock); in ioctl_get_read_timeouts()
948 static long ioctl_set_read_timeouts(struct mount_info *mi, void __user *arg) in ioctl_set_read_timeouts() argument
986 spin_lock(&mi->mi_per_uid_read_timeouts_lock); in ioctl_set_read_timeouts()
987 mi->mi_per_uid_read_timeouts_size = size; in ioctl_set_read_timeouts()
988 tmp = mi->mi_per_uid_read_timeouts; in ioctl_set_read_timeouts()
989 mi->mi_per_uid_read_timeouts = buffer; in ioctl_set_read_timeouts()
991 spin_unlock(&mi->mi_per_uid_read_timeouts_lock); in ioctl_set_read_timeouts()
998 static long ioctl_get_last_read_error(struct mount_info *mi, void __user *arg) in ioctl_get_last_read_error() argument
1004 error = mutex_lock_interruptible(&mi->mi_le_mutex); in ioctl_get_last_read_error()
1008 args.file_id_out = mi->mi_le_file_id; in ioctl_get_last_read_error()
1009 args.time_us_out = mi->mi_le_time_us; in ioctl_get_last_read_error()
1010 args.page_out = mi->mi_le_page; in ioctl_get_last_read_error()
1011 args.errno_out = mi->mi_le_errno; in ioctl_get_last_read_error()
1012 args.uid_out = mi->mi_le_uid; in ioctl_get_last_read_error()
1014 mutex_unlock(&mi->mi_le_mutex); in ioctl_get_last_read_error()
1024 struct mount_info *mi = get_mount_info(file_superblock(f)); in pending_reads_dispatch_ioctl() local
1034 return ioctl_get_read_timeouts(mi, (void __user *)arg); in pending_reads_dispatch_ioctl()
1036 return ioctl_set_read_timeouts(mi, (void __user *)arg); in pending_reads_dispatch_ioctl()
1038 return ioctl_get_last_read_error(mi, (void __user *)arg); in pending_reads_dispatch_ioctl()
1069 struct mount_info *mi = get_mount_info(file_superblock(f)); in log_read() local
1081 if (!mi) in log_read()
1084 report_uid = mi->mi_options.report_uid; in log_read()
1089 rl_size = READ_ONCE(mi->mi_log.rl_size); in log_read()
1109 mi, &next_state, reads_buf, reads_buf2, in log_read()
1141 struct mount_info *mi = get_mount_info(file_superblock(file)); in log_poll() local
1145 poll_wait(file, &mi->mi_log.ml_notif_wq, wait); in log_poll()
1146 count = incfs_get_uncollected_logs_count(mi, &log_state->state); in log_poll()
1147 if (count >= mi->mi_options.read_log_wakeup_count) in log_poll()
1156 struct mount_info *mi = get_mount_info(file_superblock(file)); in log_open() local
1162 log_state->state = incfs_get_log_state(mi); in log_open()
1195 struct mount_info *mi = get_mount_info(file_superblock(f)); in blocks_written_read() local
1201 if (!mi) in blocks_written_read()
1204 blocks_written = atomic_read(&mi->mi_blocks_written); in blocks_written_read()
1220 struct mount_info *mi = get_mount_info(file_superblock(f)); in blocks_written_poll() local
1224 if (!mi) in blocks_written_poll()
1227 poll_wait(f, &mi->mi_blocks_written_notif_wq, wait); in blocks_written_poll()
1228 blocks_written = atomic_read(&mi->mi_blocks_written); in blocks_written_poll()