hc
2024-05-10 9999e48639b3cecb08ffb37358bcba3b48161b29
kernel/fs/fuse/cuse.c
....@@ -1,10 +1,9 @@
1
+// SPDX-License-Identifier: GPL-2.0-only
12 /*
23 * CUSE: Character device in Userspace
34 *
45 * Copyright (C) 2008-2009 SUSE Linux Products GmbH
56 * Copyright (C) 2008-2009 Tejun Heo <tj@kernel.org>
6
- *
7
- * This file is released under the GPLv2.
87 *
98 * CUSE enables character devices to be implemented from userland much
109 * like FUSE allows filesystems. On initialization /dev/cuse is
....@@ -33,6 +32,8 @@
3332 * closed.
3433 */
3534
35
+#define pr_fmt(fmt) "CUSE: " fmt
36
+
3637 #include <linux/fuse.h>
3738 #include <linux/cdev.h>
3839 #include <linux/device.h>
....@@ -56,6 +57,7 @@
5657
5758 struct cuse_conn {
5859 struct list_head list; /* linked on cuse_conntbl */
60
+ struct fuse_mount fm; /* Dummy mount referencing fc */
5961 struct fuse_conn fc; /* fuse connection */
6062 struct cdev *cdev; /* associated character device */
6163 struct device *dev; /* device representing @cdev */
....@@ -133,7 +135,7 @@
133135 * Generic permission check is already done against the chrdev
134136 * file, proceed to open.
135137 */
136
- rc = fuse_do_open(&cc->fc, 0, file, 0);
138
+ rc = fuse_do_open(&cc->fm, 0, file, 0);
137139 if (rc)
138140 fuse_conn_put(&cc->fc);
139141 return rc;
....@@ -142,10 +144,10 @@
142144 static int cuse_release(struct inode *inode, struct file *file)
143145 {
144146 struct fuse_file *ff = file->private_data;
145
- struct fuse_conn *fc = ff->fc;
147
+ struct fuse_mount *fm = ff->fm;
146148
147
- fuse_sync_release(ff, file->f_flags);
148
- fuse_conn_put(fc);
149
+ fuse_sync_release(NULL, ff, file->f_flags);
150
+ fuse_conn_put(fm->fc);
149151
150152 return 0;
151153 }
....@@ -154,7 +156,7 @@
154156 unsigned long arg)
155157 {
156158 struct fuse_file *ff = file->private_data;
157
- struct cuse_conn *cc = fc_to_cc(ff->fc);
159
+ struct cuse_conn *cc = fc_to_cc(ff->fm->fc);
158160 unsigned int flags = 0;
159161
160162 if (cc->unrestricted_ioctl)
....@@ -167,7 +169,7 @@
167169 unsigned long arg)
168170 {
169171 struct fuse_file *ff = file->private_data;
170
- struct cuse_conn *cc = fc_to_cc(ff->fc);
172
+ struct cuse_conn *cc = fc_to_cc(ff->fm->fc);
171173 unsigned int flags = FUSE_IOCTL_COMPAT;
172174
173175 if (cc->unrestricted_ioctl)
....@@ -224,7 +226,7 @@
224226 return 0;
225227
226228 if (end[-1] != '\0') {
227
- printk(KERN_ERR "CUSE: info not properly terminated\n");
229
+ pr_err("info not properly terminated\n");
228230 return -EINVAL;
229231 }
230232
....@@ -241,7 +243,7 @@
241243 key = strstrip(key);
242244
243245 if (!strlen(key)) {
244
- printk(KERN_ERR "CUSE: zero length info key specified\n");
246
+ pr_err("zero length info key specified\n");
245247 return -EINVAL;
246248 }
247249
....@@ -269,7 +271,7 @@
269271 static int cuse_parse_devinfo(char *p, size_t len, struct cuse_devinfo *devinfo)
270272 {
271273 char *end = p + len;
272
- char *uninitialized_var(key), *uninitialized_var(val);
274
+ char *key, *val;
273275 int rc;
274276
275277 while (true) {
....@@ -281,12 +283,11 @@
281283 if (strcmp(key, "DEVNAME") == 0)
282284 devinfo->name = val;
283285 else
284
- printk(KERN_WARNING "CUSE: unknown device info \"%s\"\n",
285
- key);
286
+ pr_warn("unknown device info \"%s\"\n", key);
286287 }
287288
288289 if (!devinfo->name || !strlen(devinfo->name)) {
289
- printk(KERN_ERR "CUSE: DEVNAME unspecified\n");
290
+ pr_err("DEVNAME unspecified\n");
290291 return -EINVAL;
291292 }
292293
....@@ -298,6 +299,14 @@
298299 kfree(dev);
299300 }
300301
302
+struct cuse_init_args {
303
+ struct fuse_args_pages ap;
304
+ struct cuse_init_in in;
305
+ struct cuse_init_out out;
306
+ struct page *page;
307
+ struct fuse_page_desc desc;
308
+};
309
+
301310 /**
302311 * cuse_process_init_reply - finish initializing CUSE channel
303312 *
....@@ -305,21 +314,23 @@
305314 * required data structures for it. Please read the comment at the
306315 * top of this file for high level overview.
307316 */
308
-static void cuse_process_init_reply(struct fuse_conn *fc, struct fuse_req *req)
317
+static void cuse_process_init_reply(struct fuse_mount *fm,
318
+ struct fuse_args *args, int error)
309319 {
320
+ struct fuse_conn *fc = fm->fc;
321
+ struct cuse_init_args *ia = container_of(args, typeof(*ia), ap.args);
322
+ struct fuse_args_pages *ap = &ia->ap;
310323 struct cuse_conn *cc = fc_to_cc(fc), *pos;
311
- struct cuse_init_out *arg = req->out.args[0].value;
312
- struct page *page = req->pages[0];
324
+ struct cuse_init_out *arg = &ia->out;
325
+ struct page *page = ap->pages[0];
313326 struct cuse_devinfo devinfo = { };
314327 struct device *dev;
315328 struct cdev *cdev;
316329 dev_t devt;
317330 int rc, i;
318331
319
- if (req->out.h.error ||
320
- arg->major != FUSE_KERNEL_VERSION || arg->minor < 11) {
332
+ if (error || arg->major != FUSE_KERNEL_VERSION || arg->minor < 11)
321333 goto err;
322
- }
323334
324335 fc->minor = arg->minor;
325336 fc->max_read = max_t(unsigned, arg->max_read, 4096);
....@@ -328,7 +339,7 @@
328339 /* parse init reply */
329340 cc->unrestricted_ioctl = arg->flags & CUSE_UNRESTRICTED_IOCTL;
330341
331
- rc = cuse_parse_devinfo(page_address(page), req->out.args[1].size,
342
+ rc = cuse_parse_devinfo(page_address(page), ap->args.out_args[1].size,
332343 &devinfo);
333344 if (rc)
334345 goto err;
....@@ -340,7 +351,7 @@
340351 else
341352 rc = register_chrdev_region(devt, 1, devinfo.name);
342353 if (rc) {
343
- printk(KERN_ERR "CUSE: failed to register chrdev region\n");
354
+ pr_err("failed to register chrdev region\n");
344355 goto err;
345356 }
346357
....@@ -395,7 +406,7 @@
395406 dev_set_uevent_suppress(dev, 0);
396407 kobject_uevent(&dev->kobj, KOBJ_ADD);
397408 out:
398
- kfree(arg);
409
+ kfree(ia);
399410 __free_page(page);
400411 return;
401412
....@@ -407,62 +418,56 @@
407418 err_region:
408419 unregister_chrdev_region(devt, 1);
409420 err:
410
- fuse_abort_conn(fc, false);
421
+ fuse_abort_conn(fc);
411422 goto out;
412423 }
413424
414425 static int cuse_send_init(struct cuse_conn *cc)
415426 {
416427 int rc;
417
- struct fuse_req *req;
418428 struct page *page;
419
- struct fuse_conn *fc = &cc->fc;
420
- struct cuse_init_in *arg;
421
- void *outarg;
429
+ struct fuse_mount *fm = &cc->fm;
430
+ struct cuse_init_args *ia;
431
+ struct fuse_args_pages *ap;
422432
423433 BUILD_BUG_ON(CUSE_INIT_INFO_MAX > PAGE_SIZE);
424
-
425
- req = fuse_get_req_for_background(fc, 1);
426
- if (IS_ERR(req)) {
427
- rc = PTR_ERR(req);
428
- goto err;
429
- }
430434
431435 rc = -ENOMEM;
432436 page = alloc_page(GFP_KERNEL | __GFP_ZERO);
433437 if (!page)
434
- goto err_put_req;
438
+ goto err;
435439
436
- outarg = kzalloc(sizeof(struct cuse_init_out), GFP_KERNEL);
437
- if (!outarg)
440
+ ia = kzalloc(sizeof(*ia), GFP_KERNEL);
441
+ if (!ia)
438442 goto err_free_page;
439443
440
- arg = &req->misc.cuse_init_in;
441
- arg->major = FUSE_KERNEL_VERSION;
442
- arg->minor = FUSE_KERNEL_MINOR_VERSION;
443
- arg->flags |= CUSE_UNRESTRICTED_IOCTL;
444
- req->in.h.opcode = CUSE_INIT;
445
- req->in.numargs = 1;
446
- req->in.args[0].size = sizeof(struct cuse_init_in);
447
- req->in.args[0].value = arg;
448
- req->out.numargs = 2;
449
- req->out.args[0].size = sizeof(struct cuse_init_out);
450
- req->out.args[0].value = outarg;
451
- req->out.args[1].size = CUSE_INIT_INFO_MAX;
452
- req->out.argvar = 1;
453
- req->out.argpages = 1;
454
- req->pages[0] = page;
455
- req->page_descs[0].length = req->out.args[1].size;
456
- req->num_pages = 1;
457
- req->end = cuse_process_init_reply;
458
- fuse_request_send_background(fc, req);
444
+ ap = &ia->ap;
445
+ ia->in.major = FUSE_KERNEL_VERSION;
446
+ ia->in.minor = FUSE_KERNEL_MINOR_VERSION;
447
+ ia->in.flags |= CUSE_UNRESTRICTED_IOCTL;
448
+ ap->args.opcode = CUSE_INIT;
449
+ ap->args.in_numargs = 1;
450
+ ap->args.in_args[0].size = sizeof(ia->in);
451
+ ap->args.in_args[0].value = &ia->in;
452
+ ap->args.out_numargs = 2;
453
+ ap->args.out_args[0].size = sizeof(ia->out);
454
+ ap->args.out_args[0].value = &ia->out;
455
+ ap->args.out_args[1].size = CUSE_INIT_INFO_MAX;
456
+ ap->args.out_argvar = true;
457
+ ap->args.out_pages = true;
458
+ ap->num_pages = 1;
459
+ ap->pages = &ia->page;
460
+ ap->descs = &ia->desc;
461
+ ia->page = page;
462
+ ia->desc.length = ap->args.out_args[1].size;
463
+ ap->args.end = cuse_process_init_reply;
459464
460
- return 0;
461
-
465
+ rc = fuse_simple_background(fm, &ap->args, GFP_KERNEL);
466
+ if (rc) {
467
+ kfree(ia);
462468 err_free_page:
463
- __free_page(page);
464
-err_put_req:
465
- fuse_put_request(fc, req);
469
+ __free_page(page);
470
+ }
466471 err:
467472 return rc;
468473 }
....@@ -503,9 +508,10 @@
503508 * Limit the cuse channel to requests that can
504509 * be represented in file->f_cred->user_ns.
505510 */
506
- fuse_conn_init(&cc->fc, file->f_cred->user_ns);
511
+ fuse_conn_init(&cc->fc, &cc->fm, file->f_cred->user_ns,
512
+ &fuse_dev_fiq_ops, NULL);
507513
508
- fud = fuse_dev_alloc(&cc->fc);
514
+ fud = fuse_dev_alloc_install(&cc->fc);
509515 if (!fud) {
510516 kfree(cc);
511517 return -ENOMEM;
....@@ -587,7 +593,7 @@
587593 {
588594 struct cuse_conn *cc = dev_get_drvdata(dev);
589595
590
- fuse_abort_conn(&cc->fc, false);
596
+ fuse_abort_conn(&cc->fc);
591597 return count;
592598 }
593599 static DEVICE_ATTR(abort, 0200, NULL, cuse_class_abort_store);