fs/fuse/control.c

26 	struct fuse_conn *fc;
28 	fc = file_inode(file)->i_private;
29 	if (fc)
30 		fc = fuse_conn_get(fc);
32 	return fc;
38 	struct fuse_conn *fc = fuse_ctl_file_conn_get(file);
39 	if (fc) {
40 		if (fc->abort_err)
41 			fc->aborted = true;
42 		fuse_abort_conn(fc);
43 		fuse_conn_put(fc);
56 		struct fuse_conn *fc = fuse_ctl_file_conn_get(file);
57 		if (!fc)
60 		value = atomic_read(&fc->num_waiting);
62 		fuse_conn_put(fc);
107 	struct fuse_conn *fc;
110 	fc = fuse_ctl_file_conn_get(file);
111 	if (!fc)
114 	val = READ_ONCE(fc->max_background);
115 	fuse_conn_put(fc);
130 		struct fuse_conn *fc = fuse_ctl_file_conn_get(file);
131 		if (fc) {
132 			spin_lock(&fc->bg_lock);
133 			fc->max_background = val;
134 			fc->blocked = fc->num_background >= fc->max_background;
135 			if (!fc->blocked)
136 				wake_up(&fc->blocked_waitq);
137 			spin_unlock(&fc->bg_lock);
138 			fuse_conn_put(fc);
149 	struct fuse_conn *fc;
152 	fc = fuse_ctl_file_conn_get(file);
153 	if (!fc)
156 	val = READ_ONCE(fc->congestion_threshold);
157 	fuse_conn_put(fc);
167 	struct fuse_conn *fc;
174 	fc = fuse_ctl_file_conn_get(file);
175 	if (!fc)
178 	WRITE_ONCE(fc->congestion_threshold, val);
179 	fuse_conn_put(fc);
207 					  struct fuse_conn *fc,
228 	inode->i_uid = fc->user_id;
229 	inode->i_gid = fc->group_id;
236 	inode->i_private = fc;
246 int fuse_ctl_add_conn(struct fuse_conn *fc)
251 	if (!fuse_control_sb || fc->no_control)
256 	sprintf(name, "%u", fc->dev);
257 	parent = fuse_ctl_add_dentry(parent, fc, name, S_IFDIR | 0500, 2,
263 	if (!fuse_ctl_add_dentry(parent, fc, "waiting", S_IFREG | 0400, 1,
265 	    !fuse_ctl_add_dentry(parent, fc, "abort", S_IFREG | 0200, 1,
267 	    !fuse_ctl_add_dentry(parent, fc, "max_background", S_IFREG | 0600,
269 	    !fuse_ctl_add_dentry(parent, fc, "congestion_threshold",
277 	fuse_ctl_remove_conn(fc);
290 void fuse_ctl_remove_conn(struct fuse_conn *fc)
295 	if (!fuse_control_sb || fc->no_control)
298 	sprintf(name, "%u", fc->dev);
309 	struct fuse_conn *fc;
319 	list_for_each_entry(fc, &fuse_conn_list, entry) {
320 		err = fuse_ctl_add_conn(fc);