fs/fuse/control.c

25 	struct fuse_conn *fc;
27 	fc = file_inode(file)->i_private;
28 	if (fc)
29 		fc = fuse_conn_get(fc);
31 	return fc;
37 	struct fuse_conn *fc = fuse_ctl_file_conn_get(file);
38 	if (fc) {
39 		if (fc->abort_err)
40 			fc->aborted = true;
41 		fuse_abort_conn(fc);
42 		fuse_conn_put(fc);
55 		struct fuse_conn *fc = fuse_ctl_file_conn_get(file);
56 		if (!fc)
59 		value = atomic_read(&fc->num_waiting);
61 		fuse_conn_put(fc);
106 	struct fuse_conn *fc;
109 	fc = fuse_ctl_file_conn_get(file);
110 	if (!fc)
113 	val = READ_ONCE(fc->max_background);
114 	fuse_conn_put(fc);
129 		struct fuse_conn *fc = fuse_ctl_file_conn_get(file);
130 		if (fc) {
131 			spin_lock(&fc->bg_lock);
132 			fc->max_background = val;
133 			fc->blocked = fc->num_background >= fc->max_background;
134 			if (!fc->blocked)
135 				wake_up(&fc->blocked_waitq);
136 			spin_unlock(&fc->bg_lock);
137 			fuse_conn_put(fc);
148 	struct fuse_conn *fc;
151 	fc = fuse_ctl_file_conn_get(file);
152 	if (!fc)
155 	val = READ_ONCE(fc->congestion_threshold);
156 	fuse_conn_put(fc);
166 	struct fuse_conn *fc;
173 	fc = fuse_ctl_file_conn_get(file);
174 	if (!fc)
177 	WRITE_ONCE(fc->congestion_threshold, val);
178 	fuse_conn_put(fc);
210 					  struct fuse_conn *fc,
219 	BUG_ON(fc->ctl_ndents >= FUSE_CTL_NUM_DENTRIES);
232 	inode->i_uid = fc->user_id;
233 	inode->i_gid = fc->group_id;
240 	inode->i_private = fc;
243 	fc->ctl_dentry[fc->ctl_ndents++] = dentry;
252 int fuse_ctl_add_conn(struct fuse_conn *fc)
257 	if (!fuse_control_sb || fc->no_control)
262 	sprintf(name, "%u", fc->dev);
263 	parent = fuse_ctl_add_dentry(parent, fc, name, S_IFDIR | 0500, 2,
269 	if (!fuse_ctl_add_dentry(parent, fc, "waiting", S_IFREG | 0400, 1,
271 	    !fuse_ctl_add_dentry(parent, fc, "abort", S_IFREG | 0200, 1,
273 	    !fuse_ctl_add_dentry(parent, fc, "max_background", S_IFREG | 0600,
275 	    !fuse_ctl_add_dentry(parent, fc, "congestion_threshold",
283 	fuse_ctl_remove_conn(fc);
291 void fuse_ctl_remove_conn(struct fuse_conn *fc)
295 	if (!fuse_control_sb || fc->no_control)
298 	for (i = fc->ctl_ndents - 1; i >= 0; i--) {
299 		struct dentry *dentry = fc->ctl_dentry[i];
313 	struct fuse_conn *fc;
323 	list_for_each_entry(fc, &fuse_conn_list, entry) {
324 		err = fuse_ctl_add_conn(fc);
353 	struct fuse_conn *fc;
357 	list_for_each_entry(fc, &fuse_conn_list, entry)
358 		fc->ctl_ndents = 0;