Lines Matching refs:fc
148 static void fuse_cleanup_submount_lookup(struct fuse_conn *fc, in fuse_cleanup_submount_lookup() argument
154 fuse_queue_forget(fc, sl->forget, sl->nodeid, 1); in fuse_cleanup_submount_lookup()
172 struct fuse_conn *fc = get_fuse_conn(inode); in fuse_evict_inode() local
177 fuse_queue_forget(fc, fi->forget, fi->nodeid, in fuse_evict_inode()
183 fuse_cleanup_submount_lookup(fc, fi->submount_lookup); in fuse_evict_inode()
193 atomic64_inc(&fc->evict_ctr); in fuse_evict_inode()
230 struct fuse_conn *fc = get_fuse_conn(inode); in fuse_change_attributes_common() local
246 if (!evict_ctr || fi->attr_version || evict_ctr == fuse_get_evict_ctr(fc)) in fuse_change_attributes_common()
249 fi->attr_version = atomic64_inc_return(&fc->attr_version); in fuse_change_attributes_common()
255 inode->i_uid = make_kuid(fc->user_ns, attr->uid); in fuse_change_attributes_common()
256 inode->i_gid = make_kgid(fc->user_ns, attr->gid); in fuse_change_attributes_common()
298 if (!fc->default_permissions) in fuse_change_attributes_common()
316 struct fuse_conn *fc = get_fuse_conn(inode); in fuse_get_cache_mask() local
318 if (!fc->writeback_cache || !S_ISREG(inode->i_mode)) in fuse_get_cache_mask()
328 struct fuse_conn *fc = get_fuse_conn(inode); in fuse_change_attributes_i() local
378 if (!fc->explicit_inval_data) in fuse_change_attributes_i()
380 } else if (fc->auto_inval_data) { in fuse_change_attributes_i()
417 struct fuse_conn *fc) in fuse_init_inode() argument
441 if (!fc->posix_acl) in fuse_init_inode()
468 struct fuse_conn *fc = get_fuse_conn_super(sb); in fuse_iget() local
477 if (fc->auto_submounts && (attr->flags & FUSE_ATTR_SUBMOUNT) && in fuse_iget()
485 fuse_init_inode(inode, attr, fc); in fuse_iget()
506 if (!fc->writeback_cache || !S_ISREG(attr->mode)) in fuse_iget()
509 fuse_init_inode(inode, attr, fc); in fuse_iget()
530 struct inode *fuse_ilookup(struct fuse_conn *fc, u64 nodeid, in fuse_ilookup() argument
536 WARN_ON(!rwsem_is_locked(&fc->killsb)); in fuse_ilookup()
537 list_for_each_entry(fm_iter, &fc->mounts, fc_entry) { in fuse_ilookup()
552 int fuse_reverse_inval_inode(struct fuse_conn *fc, u64 nodeid, in fuse_reverse_inval_inode() argument
560 inode = fuse_ilookup(fc, nodeid, NULL); in fuse_reverse_inval_inode()
566 fi->attr_version = atomic64_inc_return(&fc->attr_version); in fuse_reverse_inval_inode()
604 struct fuse_conn *fc = get_fuse_conn_super(sb); in fuse_umount_begin() local
606 if (fc->no_force_umount) in fuse_umount_begin()
609 fuse_abort_conn(fc); in fuse_umount_begin()
618 if (fm->fc->conn_init) { in fuse_send_destroy()
650 if (!fuse_allow_current_process(fm->fc)) { in fuse_statfs()
681 static void fuse_sync_fs_writes(struct fuse_conn *fc) in fuse_sync_fs_writes() argument
687 spin_lock(&fc->lock); in fuse_sync_fs_writes()
688 bucket = rcu_dereference_protected(fc->curr_bucket, 1); in fuse_sync_fs_writes()
693 spin_unlock(&fc->lock); in fuse_sync_fs_writes()
703 rcu_assign_pointer(fc->curr_bucket, new_bucket); in fuse_sync_fs_writes()
704 spin_unlock(&fc->lock); in fuse_sync_fs_writes()
722 struct fuse_conn *fc = fm->fc; in fuse_sync_fs() local
738 if (!fc->sync_fs) in fuse_sync_fs()
741 fuse_sync_fs_writes(fc); in fuse_sync_fs()
753 fc->sync_fs = 0; in fuse_sync_fs()
900 struct fuse_conn *fc = get_fuse_conn_super(sb); in fuse_show_options() local
902 if (fc->legacy_opts_show) { in fuse_show_options()
904 from_kuid_munged(fc->user_ns, fc->user_id)); in fuse_show_options()
906 from_kgid_munged(fc->user_ns, fc->group_id)); in fuse_show_options()
907 if (fc->default_permissions) in fuse_show_options()
909 if (fc->allow_other) in fuse_show_options()
911 if (fc->max_read != ~0) in fuse_show_options()
912 seq_printf(m, ",max_read=%u", fc->max_read); in fuse_show_options()
917 if (fc->dax_mode == FUSE_DAX_ALWAYS) in fuse_show_options()
919 else if (fc->dax_mode == FUSE_DAX_NEVER) in fuse_show_options()
921 else if (fc->dax_mode == FUSE_DAX_INODE_USER) in fuse_show_options()
954 void fuse_conn_init(struct fuse_conn *fc, struct fuse_mount *fm, in fuse_conn_init() argument
958 memset(fc, 0, sizeof(*fc)); in fuse_conn_init()
959 spin_lock_init(&fc->lock); in fuse_conn_init()
960 spin_lock_init(&fc->bg_lock); in fuse_conn_init()
961 init_rwsem(&fc->killsb); in fuse_conn_init()
962 refcount_set(&fc->count, 1); in fuse_conn_init()
963 atomic_set(&fc->dev_count, 1); in fuse_conn_init()
964 atomic_set(&fc->epoch, 1); in fuse_conn_init()
965 init_waitqueue_head(&fc->blocked_waitq); in fuse_conn_init()
966 fuse_iqueue_init(&fc->iq, fiq_ops, fiq_priv); in fuse_conn_init()
967 INIT_LIST_HEAD(&fc->bg_queue); in fuse_conn_init()
968 INIT_LIST_HEAD(&fc->entry); in fuse_conn_init()
969 INIT_LIST_HEAD(&fc->devices); in fuse_conn_init()
970 atomic_set(&fc->num_waiting, 0); in fuse_conn_init()
971 fc->max_background = FUSE_DEFAULT_MAX_BACKGROUND; in fuse_conn_init()
972 fc->congestion_threshold = FUSE_DEFAULT_CONGESTION_THRESHOLD; in fuse_conn_init()
973 atomic64_set(&fc->khctr, 0); in fuse_conn_init()
974 fc->polled_files = RB_ROOT; in fuse_conn_init()
975 fc->blocked = 0; in fuse_conn_init()
976 fc->initialized = 0; in fuse_conn_init()
977 fc->connected = 1; in fuse_conn_init()
978 atomic64_set(&fc->attr_version, 1); in fuse_conn_init()
979 atomic64_set(&fc->evict_ctr, 1); in fuse_conn_init()
980 get_random_bytes(&fc->scramble_key, sizeof(fc->scramble_key)); in fuse_conn_init()
981 fc->pid_ns = get_pid_ns(task_active_pid_ns(current)); in fuse_conn_init()
982 fc->user_ns = get_user_ns(user_ns); in fuse_conn_init()
983 fc->max_pages = FUSE_DEFAULT_MAX_PAGES_PER_REQ; in fuse_conn_init()
984 fc->max_pages_limit = fuse_max_pages_limit; in fuse_conn_init()
985 fc->name_max = FUSE_NAME_LOW_MAX; in fuse_conn_init()
986 fc->timeout.req_timeout = 0; in fuse_conn_init()
989 fuse_backing_files_init(fc); in fuse_conn_init()
991 INIT_LIST_HEAD(&fc->mounts); in fuse_conn_init()
992 list_add(&fm->fc_entry, &fc->mounts); in fuse_conn_init()
993 fm->fc = fc; in fuse_conn_init()
999 struct fuse_conn *fc = container_of(p, struct fuse_conn, rcu); in delayed_release() local
1001 fuse_uring_destruct(fc); in delayed_release()
1003 put_user_ns(fc->user_ns); in delayed_release()
1004 fc->release(fc); in delayed_release()
1007 void fuse_conn_put(struct fuse_conn *fc) in fuse_conn_put() argument
1009 if (refcount_dec_and_test(&fc->count)) { in fuse_conn_put()
1010 struct fuse_iqueue *fiq = &fc->iq; in fuse_conn_put()
1014 fuse_dax_conn_free(fc); in fuse_conn_put()
1015 if (fc->timeout.req_timeout) in fuse_conn_put()
1016 cancel_delayed_work_sync(&fc->timeout.work); in fuse_conn_put()
1019 put_pid_ns(fc->pid_ns); in fuse_conn_put()
1020 bucket = rcu_dereference_protected(fc->curr_bucket, 1); in fuse_conn_put()
1026 fuse_backing_files_free(fc); in fuse_conn_put()
1027 call_rcu(&fc->rcu, delayed_release); in fuse_conn_put()
1032 struct fuse_conn *fuse_conn_get(struct fuse_conn *fc) in fuse_conn_get() argument
1034 refcount_inc(&fc->count); in fuse_conn_get()
1035 return fc; in fuse_conn_get()
1058 struct fuse_conn *fc = get_fuse_conn_super(sb); in fuse_get_dentry() local
1071 if (!fc->export_support) in fuse_get_dentry()
1166 struct fuse_conn *fc = get_fuse_conn(child_inode); in fuse_get_parent() local
1172 if (!fc->export_support) in fuse_get_parent()
1240 static void process_init_limits(struct fuse_conn *fc, struct fuse_init_out *arg) in process_init_limits() argument
1250 spin_lock(&fc->bg_lock); in process_init_limits()
1252 fc->max_background = arg->max_background; in process_init_limits()
1254 if (!cap_sys_admin && fc->max_background > max_user_bgreq) in process_init_limits()
1255 fc->max_background = max_user_bgreq; in process_init_limits()
1258 fc->congestion_threshold = arg->congestion_threshold; in process_init_limits()
1261 fc->congestion_threshold > max_user_congthresh) in process_init_limits()
1262 fc->congestion_threshold = max_user_congthresh; in process_init_limits()
1264 spin_unlock(&fc->bg_lock); in process_init_limits()
1267 static void set_request_timeout(struct fuse_conn *fc, unsigned int timeout) in set_request_timeout() argument
1269 fc->timeout.req_timeout = secs_to_jiffies(timeout); in set_request_timeout()
1270 INIT_DELAYED_WORK(&fc->timeout.work, fuse_check_timeout); in set_request_timeout()
1271 queue_delayed_work(system_wq, &fc->timeout.work, in set_request_timeout()
1275 static void init_server_timeout(struct fuse_conn *fc, unsigned int timeout) in init_server_timeout() argument
1292 set_request_timeout(fc, timeout); in init_server_timeout()
1304 struct fuse_conn *fc = fm->fc; in process_init_reply() local
1315 process_init_limits(fc, arg); in process_init_reply()
1325 fc->async_read = 1; in process_init_reply()
1327 fc->no_lock = 1; in process_init_reply()
1330 fc->no_flock = 1; in process_init_reply()
1333 fc->no_flock = 1; in process_init_reply()
1336 fc->atomic_o_trunc = 1; in process_init_reply()
1340 fc->export_support = 1; in process_init_reply()
1343 fc->big_writes = 1; in process_init_reply()
1345 fc->dont_mask = 1; in process_init_reply()
1347 fc->auto_inval_data = 1; in process_init_reply()
1349 fc->explicit_inval_data = 1; in process_init_reply()
1351 fc->do_readdirplus = 1; in process_init_reply()
1353 fc->readdirplus_auto = 1; in process_init_reply()
1356 fc->async_dio = 1; in process_init_reply()
1358 fc->writeback_cache = 1; in process_init_reply()
1360 fc->parallel_dirops = 1; in process_init_reply()
1362 fc->handle_killpriv = 1; in process_init_reply()
1366 fc->default_permissions = 1; in process_init_reply()
1367 fc->posix_acl = 1; in process_init_reply()
1370 fc->cache_symlinks = 1; in process_init_reply()
1372 fc->abort_err = 1; in process_init_reply()
1374 fc->max_pages = in process_init_reply()
1375 min_t(unsigned int, fc->max_pages_limit, in process_init_reply()
1382 if (fc->max_pages > 1) in process_init_reply()
1383 fc->name_max = FUSE_NAME_MAX; in process_init_reply()
1387 !fuse_dax_check_alignment(fc, arg->map_alignment)) { in process_init_reply()
1391 fc->inode_dax = 1; in process_init_reply()
1394 fc->handle_killpriv_v2 = 1; in process_init_reply()
1398 fc->setxattr_ext = 1; in process_init_reply()
1400 fc->init_security = 1; in process_init_reply()
1402 fc->create_supp_group = 1; in process_init_reply()
1404 fc->direct_io_allow_mmap = 1; in process_init_reply()
1424 fc->passthrough = 1; in process_init_reply()
1425 fc->max_stack_depth = arg->max_stack_depth; in process_init_reply()
1431 if (fc->default_permissions) in process_init_reply()
1437 fc->io_uring = 1; in process_init_reply()
1442 ra_pages = fc->max_read / PAGE_SIZE; in process_init_reply()
1443 fc->no_lock = 1; in process_init_reply()
1444 fc->no_flock = 1; in process_init_reply()
1447 init_server_timeout(fc, timeout); in process_init_reply()
1451 fc->minor = arg->minor; in process_init_reply()
1452 fc->max_write = arg->minor < 5 ? 4096 : arg->max_write; in process_init_reply()
1453 fc->max_write = max_t(unsigned, 4096, fc->max_write); in process_init_reply()
1454 fc->conn_init = 1; in process_init_reply()
1459 fc->conn_init = 0; in process_init_reply()
1460 fc->conn_error = 1; in process_init_reply()
1463 fuse_set_initialized(fc); in process_init_reply()
1464 wake_up_all(&fc->blocked_waitq); in process_init_reply()
1493 if (fm->fc->dax) in fuse_send_init()
1495 if (fuse_is_inode_dax_mode(fm->fc->dax_mode)) in fuse_send_init()
1498 if (fm->fc->auto_submounts) in fuse_send_init()
1533 void fuse_free_conn(struct fuse_conn *fc) in fuse_free_conn() argument
1535 WARN_ON(!list_empty(&fc->devices)); in fuse_free_conn()
1536 kfree(fc); in fuse_free_conn()
1540 static int fuse_bdi_init(struct fuse_conn *fc, struct super_block *sb) in fuse_bdi_init() argument
1554 err = super_setup_bdi_name(sb, "%u:%u%s", MAJOR(fc->dev), in fuse_bdi_init()
1555 MINOR(fc->dev), suffix); in fuse_bdi_init()
1602 void fuse_dev_install(struct fuse_dev *fud, struct fuse_conn *fc) in fuse_dev_install() argument
1604 fud->fc = fuse_conn_get(fc); in fuse_dev_install()
1605 spin_lock(&fc->lock); in fuse_dev_install()
1606 list_add_tail(&fud->entry, &fc->devices); in fuse_dev_install()
1607 spin_unlock(&fc->lock); in fuse_dev_install()
1611 struct fuse_dev *fuse_dev_alloc_install(struct fuse_conn *fc) in fuse_dev_alloc_install() argument
1619 fuse_dev_install(fud, fc); in fuse_dev_alloc_install()
1626 struct fuse_conn *fc = fud->fc; in fuse_dev_free() local
1628 if (fc) { in fuse_dev_free()
1629 spin_lock(&fc->lock); in fuse_dev_free()
1631 spin_unlock(&fc->lock); in fuse_dev_free()
1633 fuse_conn_put(fc); in fuse_dev_free()
1708 fuse_get_evict_ctr(fm->fc)); in fuse_fill_super_submount()
1743 struct fuse_conn *fc = get_fuse_conn(&mp_fi->inode); in fuse_get_tree_submount() local
1751 fm->fc = fuse_conn_get(fc); in fuse_get_tree_submount()
1766 down_write(&fc->killsb); in fuse_get_tree_submount()
1767 list_add_tail(&fm->fc_entry, &fc->mounts); in fuse_get_tree_submount()
1768 up_write(&fc->killsb); in fuse_get_tree_submount()
1791 struct fuse_conn *fc = fm->fc; in fuse_fill_super_common() local
1800 rcu_assign_pointer(fc->curr_bucket, fuse_sync_bucket_alloc()); in fuse_fill_super_common()
1817 err = fuse_dax_conn_alloc(fc, ctx->dax_mode, ctx->dax_dev); in fuse_fill_super_common()
1824 fud = fuse_dev_alloc_install(fc); in fuse_fill_super_common()
1829 fc->dev = sb->s_dev; in fuse_fill_super_common()
1831 err = fuse_bdi_init(fc, sb); in fuse_fill_super_common()
1837 fc->dont_mask = 1; in fuse_fill_super_common()
1840 fc->default_permissions = ctx->default_permissions; in fuse_fill_super_common()
1841 fc->allow_other = ctx->allow_other; in fuse_fill_super_common()
1842 fc->user_id = ctx->user_id; in fuse_fill_super_common()
1843 fc->group_id = ctx->group_id; in fuse_fill_super_common()
1844 fc->legacy_opts_show = ctx->legacy_opts_show; in fuse_fill_super_common()
1845 fc->max_read = max_t(unsigned int, 4096, ctx->max_read); in fuse_fill_super_common()
1846 fc->destroy = ctx->destroy; in fuse_fill_super_common()
1847 fc->no_control = ctx->no_control; in fuse_fill_super_common()
1848 fc->no_force_umount = ctx->no_force_umount; in fuse_fill_super_common()
1862 err = fuse_ctl_add_conn(fc); in fuse_fill_super_common()
1866 list_add_tail(&fc->entry, &fuse_conn_list); in fuse_fill_super_common()
1881 fuse_dax_conn_free(fc); in fuse_fill_super_common()
1933 struct fuse_conn *fc; in fuse_get_tree() local
1938 fc = kmalloc(sizeof(*fc), GFP_KERNEL); in fuse_get_tree()
1939 if (!fc) in fuse_get_tree()
1944 kfree(fc); in fuse_get_tree()
1948 fuse_conn_init(fc, fm, fsc->user_ns, &fuse_dev_fiq_ops, NULL); in fuse_get_tree()
1949 fc->release = fuse_free_conn; in fuse_get_tree()
1974 fsc->sget_key = fud->fc; in fuse_get_tree()
2026 struct fuse_conn *fc = fm->fc; in fuse_mount_remove() local
2029 down_write(&fc->killsb); in fuse_mount_remove()
2031 if (list_empty(&fc->mounts)) in fuse_mount_remove()
2033 up_write(&fc->killsb); in fuse_mount_remove()
2041 struct fuse_conn *fc = fm->fc; in fuse_conn_destroy() local
2043 if (fc->destroy) in fuse_conn_destroy()
2046 fuse_abort_conn(fc); in fuse_conn_destroy()
2047 fuse_wait_aborted(fc); in fuse_conn_destroy()
2049 if (!list_empty(&fc->entry)) { in fuse_conn_destroy()
2051 list_del(&fc->entry); in fuse_conn_destroy()
2052 fuse_ctl_remove_conn(fc); in fuse_conn_destroy()
2072 fuse_conn_put(fm->fc); in fuse_mount_destroy()