xref: /openbmc/linux/fs/cachefiles/daemon.c (revision fe2140e2) 
1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /* Daemon interface
3  *
4  * Copyright (C) 2007, 2021 Red Hat, Inc. All Rights Reserved.
5  * Written by David Howells (dhowells@redhat.com)
6  */
7 
8 #include <linux/module.h>
9 #include <linux/init.h>
10 #include <linux/sched.h>
11 #include <linux/completion.h>
12 #include <linux/slab.h>
13 #include <linux/fs.h>
14 #include <linux/file.h>
15 #include <linux/namei.h>
16 #include <linux/poll.h>
17 #include <linux/mount.h>
18 #include <linux/statfs.h>
19 #include <linux/ctype.h>
20 #include <linux/string.h>
21 #include <linux/fs_struct.h>
22 #include "internal.h"
23 
24 static int cachefiles_daemon_open(struct inode *, struct file *);
25 static int cachefiles_daemon_release(struct inode *, struct file *);
26 static ssize_t cachefiles_daemon_read(struct file *, char __user *, size_t,
27 				      loff_t *);
28 static ssize_t cachefiles_daemon_write(struct file *, const char __user *,
29 				       size_t, loff_t *);
30 static __poll_t cachefiles_daemon_poll(struct file *,
31 					   struct poll_table_struct *);
32 static int cachefiles_daemon_frun(struct cachefiles_cache *, char *);
33 static int cachefiles_daemon_fcull(struct cachefiles_cache *, char *);
34 static int cachefiles_daemon_fstop(struct cachefiles_cache *, char *);
35 static int cachefiles_daemon_brun(struct cachefiles_cache *, char *);
36 static int cachefiles_daemon_bcull(struct cachefiles_cache *, char *);
37 static int cachefiles_daemon_bstop(struct cachefiles_cache *, char *);
38 static int cachefiles_daemon_cull(struct cachefiles_cache *, char *);
39 static int cachefiles_daemon_debug(struct cachefiles_cache *, char *);
40 static int cachefiles_daemon_dir(struct cachefiles_cache *, char *);
41 static int cachefiles_daemon_inuse(struct cachefiles_cache *, char *);
42 static int cachefiles_daemon_secctx(struct cachefiles_cache *, char *);
43 static int cachefiles_daemon_tag(struct cachefiles_cache *, char *);
44 static int cachefiles_daemon_bind(struct cachefiles_cache *, char *);
45 static void cachefiles_daemon_unbind(struct cachefiles_cache *);
46 
47 static unsigned long cachefiles_open;
48 
49 const struct file_operations cachefiles_daemon_fops = {
50 	.owner		= THIS_MODULE,
51 	.open		= cachefiles_daemon_open,
52 	.release	= cachefiles_daemon_release,
53 	.read		= cachefiles_daemon_read,
54 	.write		= cachefiles_daemon_write,
55 	.poll		= cachefiles_daemon_poll,
56 	.llseek		= noop_llseek,
57 };
58 
59 struct cachefiles_daemon_cmd {
60 	char name[8];
61 	int (*handler)(struct cachefiles_cache *cache, char *args);
62 };
63 
64 static const struct cachefiles_daemon_cmd cachefiles_daemon_cmds[] = {
65 	{ "bind",	cachefiles_daemon_bind		},
66 	{ "brun",	cachefiles_daemon_brun		},
67 	{ "bcull",	cachefiles_daemon_bcull		},
68 	{ "bstop",	cachefiles_daemon_bstop		},
69 	{ "cull",	cachefiles_daemon_cull		},
70 	{ "debug",	cachefiles_daemon_debug		},
71 	{ "dir",	cachefiles_daemon_dir		},
72 	{ "frun",	cachefiles_daemon_frun		},
73 	{ "fcull",	cachefiles_daemon_fcull		},
74 	{ "fstop",	cachefiles_daemon_fstop		},
75 	{ "inuse",	cachefiles_daemon_inuse		},
76 	{ "secctx",	cachefiles_daemon_secctx	},
77 	{ "tag",	cachefiles_daemon_tag		},
78 	{ "",		NULL				}
79 };
80 
81 
82 /*
83  * Prepare a cache for caching.
84  */
85 static int cachefiles_daemon_open(struct inode *inode, struct file *file)
86 {
87 	struct cachefiles_cache *cache;
88 
89 	_enter("");
90 
91 	/* only the superuser may do this */
92 	if (!capable(CAP_SYS_ADMIN))
93 		return -EPERM;
94 
95 	/* the cachefiles device may only be open once at a time */
96 	if (xchg(&cachefiles_open, 1) == 1)
97 		return -EBUSY;
98 
99 	/* allocate a cache record */
100 	cache = kzalloc(sizeof(struct cachefiles_cache), GFP_KERNEL);
101 	if (!cache) {
102 		cachefiles_open = 0;
103 		return -ENOMEM;
104 	}
105 
106 	mutex_init(&cache->daemon_mutex);
107 	init_waitqueue_head(&cache->daemon_pollwq);
108 	INIT_LIST_HEAD(&cache->volumes);
109 	spin_lock_init(&cache->object_list_lock);
110 
111 	/* set default caching limits
112 	 * - limit at 1% free space and/or free files
113 	 * - cull below 5% free space and/or free files
114 	 * - cease culling above 7% free space and/or free files
115 	 */
116 	cache->frun_percent = 7;
117 	cache->fcull_percent = 5;
118 	cache->fstop_percent = 1;
119 	cache->brun_percent = 7;
120 	cache->bcull_percent = 5;
121 	cache->bstop_percent = 1;
122 
123 	file->private_data = cache;
124 	cache->cachefilesd = file;
125 	return 0;
126 }
127 
128 /*
129  * Release a cache.
130  */
131 static int cachefiles_daemon_release(struct inode *inode, struct file *file)
132 {
133 	struct cachefiles_cache *cache = file->private_data;
134 
135 	_enter("");
136 
137 	ASSERT(cache);
138 
139 	set_bit(CACHEFILES_DEAD, &cache->flags);
140 
141 	cachefiles_daemon_unbind(cache);
142 
143 	/* clean up the control file interface */
144 	cache->cachefilesd = NULL;
145 	file->private_data = NULL;
146 	cachefiles_open = 0;
147 
148 	kfree(cache);
149 
150 	_leave("");
151 	return 0;
152 }
153 
154 /*
155  * Read the cache state.
156  */
157 static ssize_t cachefiles_daemon_read(struct file *file, char __user *_buffer,
158 				      size_t buflen, loff_t *pos)
159 {
160 	struct cachefiles_cache *cache = file->private_data;
161 	unsigned long long b_released;
162 	unsigned f_released;
163 	char buffer[256];
164 	int n;
165 
166 	//_enter(",,%zu,", buflen);
167 
168 	if (!test_bit(CACHEFILES_READY, &cache->flags))
169 		return 0;
170 
171 	/* check how much space the cache has */
172 	cachefiles_has_space(cache, 0, 0);
173 
174 	/* summarise */
175 	f_released = atomic_xchg(&cache->f_released, 0);
176 	b_released = atomic_long_xchg(&cache->b_released, 0);
177 	clear_bit(CACHEFILES_STATE_CHANGED, &cache->flags);
178 
179 	n = snprintf(buffer, sizeof(buffer),
180 		     "cull=%c"
181 		     " frun=%llx"
182 		     " fcull=%llx"
183 		     " fstop=%llx"
184 		     " brun=%llx"
185 		     " bcull=%llx"
186 		     " bstop=%llx"
187 		     " freleased=%x"
188 		     " breleased=%llx",
189 		     test_bit(CACHEFILES_CULLING, &cache->flags) ? '1' : '0',
190 		     (unsigned long long) cache->frun,
191 		     (unsigned long long) cache->fcull,
192 		     (unsigned long long) cache->fstop,
193 		     (unsigned long long) cache->brun,
194 		     (unsigned long long) cache->bcull,
195 		     (unsigned long long) cache->bstop,
196 		     f_released,
197 		     b_released);
198 
199 	if (n > buflen)
200 		return -EMSGSIZE;
201 
202 	if (copy_to_user(_buffer, buffer, n) != 0)
203 		return -EFAULT;
204 
205 	return n;
206 }
207 
208 /*
209  * Take a command from cachefilesd, parse it and act on it.
210  */
211 static ssize_t cachefiles_daemon_write(struct file *file,
212 				       const char __user *_data,
213 				       size_t datalen,
214 				       loff_t *pos)
215 {
216 	const struct cachefiles_daemon_cmd *cmd;
217 	struct cachefiles_cache *cache = file->private_data;
218 	ssize_t ret;
219 	char *data, *args, *cp;
220 
221 	//_enter(",,%zu,", datalen);
222 
223 	ASSERT(cache);
224 
225 	if (test_bit(CACHEFILES_DEAD, &cache->flags))
226 		return -EIO;
227 
228 	if (datalen > PAGE_SIZE - 1)
229 		return -EOPNOTSUPP;
230 
231 	/* drag the command string into the kernel so we can parse it */
232 	data = memdup_user_nul(_data, datalen);
233 	if (IS_ERR(data))
234 		return PTR_ERR(data);
235 
236 	ret = -EINVAL;
237 	if (memchr(data, '\0', datalen))
238 		goto error;
239 
240 	/* strip any newline */
241 	cp = memchr(data, '\n', datalen);
242 	if (cp) {
243 		if (cp == data)
244 			goto error;
245 
246 		*cp = '\0';
247 	}
248 
249 	/* parse the command */
250 	ret = -EOPNOTSUPP;
251 
252 	for (args = data; *args; args++)
253 		if (isspace(*args))
254 			break;
255 	if (*args) {
256 		if (args == data)
257 			goto error;
258 		*args = '\0';
259 		args = skip_spaces(++args);
260 	}
261 
262 	/* run the appropriate command handler */
263 	for (cmd = cachefiles_daemon_cmds; cmd->name[0]; cmd++)
264 		if (strcmp(cmd->name, data) == 0)
265 			goto found_command;
266 
267 error:
268 	kfree(data);
269 	//_leave(" = %zd", ret);
270 	return ret;
271 
272 found_command:
273 	mutex_lock(&cache->daemon_mutex);
274 
275 	ret = -EIO;
276 	if (!test_bit(CACHEFILES_DEAD, &cache->flags))
277 		ret = cmd->handler(cache, args);
278 
279 	mutex_unlock(&cache->daemon_mutex);
280 
281 	if (ret == 0)
282 		ret = datalen;
283 	goto error;
284 }
285 
286 /*
287  * Poll for culling state
288  * - use EPOLLOUT to indicate culling state
289  */
290 static __poll_t cachefiles_daemon_poll(struct file *file,
291 					   struct poll_table_struct *poll)
292 {
293 	struct cachefiles_cache *cache = file->private_data;
294 	__poll_t mask;
295 
296 	poll_wait(file, &cache->daemon_pollwq, poll);
297 	mask = 0;
298 
299 	if (test_bit(CACHEFILES_STATE_CHANGED, &cache->flags))
300 		mask |= EPOLLIN;
301 
302 	if (test_bit(CACHEFILES_CULLING, &cache->flags))
303 		mask |= EPOLLOUT;
304 
305 	return mask;
306 }
307 
308 /*
309  * Give a range error for cache space constraints
310  * - can be tail-called
311  */
312 static int cachefiles_daemon_range_error(struct cachefiles_cache *cache,
313 					 char *args)
314 {
315 	pr_err("Free space limits must be in range 0%%<=stop<cull<run<100%%\n");
316 
317 	return -EINVAL;
318 }
319 
320 /*
321  * Set the percentage of files at which to stop culling
322  * - command: "frun <N>%"
323  */
324 static int cachefiles_daemon_frun(struct cachefiles_cache *cache, char *args)
325 {
326 	unsigned long frun;
327 
328 	_enter(",%s", args);
329 
330 	if (!*args)
331 		return -EINVAL;
332 
333 	frun = simple_strtoul(args, &args, 10);
334 	if (args[0] != '%' || args[1] != '\0')
335 		return -EINVAL;
336 
337 	if (frun <= cache->fcull_percent || frun >= 100)
338 		return cachefiles_daemon_range_error(cache, args);
339 
340 	cache->frun_percent = frun;
341 	return 0;
342 }
343 
344 /*
345  * Set the percentage of files at which to start culling
346  * - command: "fcull <N>%"
347  */
348 static int cachefiles_daemon_fcull(struct cachefiles_cache *cache, char *args)
349 {
350 	unsigned long fcull;
351 
352 	_enter(",%s", args);
353 
354 	if (!*args)
355 		return -EINVAL;
356 
357 	fcull = simple_strtoul(args, &args, 10);
358 	if (args[0] != '%' || args[1] != '\0')
359 		return -EINVAL;
360 
361 	if (fcull <= cache->fstop_percent || fcull >= cache->frun_percent)
362 		return cachefiles_daemon_range_error(cache, args);
363 
364 	cache->fcull_percent = fcull;
365 	return 0;
366 }
367 
368 /*
369  * Set the percentage of files at which to stop allocating
370  * - command: "fstop <N>%"
371  */
372 static int cachefiles_daemon_fstop(struct cachefiles_cache *cache, char *args)
373 {
374 	unsigned long fstop;
375 
376 	_enter(",%s", args);
377 
378 	if (!*args)
379 		return -EINVAL;
380 
381 	fstop = simple_strtoul(args, &args, 10);
382 	if (args[0] != '%' || args[1] != '\0')
383 		return -EINVAL;
384 
385 	if (fstop >= cache->fcull_percent)
386 		return cachefiles_daemon_range_error(cache, args);
387 
388 	cache->fstop_percent = fstop;
389 	return 0;
390 }
391 
392 /*
393  * Set the percentage of blocks at which to stop culling
394  * - command: "brun <N>%"
395  */
396 static int cachefiles_daemon_brun(struct cachefiles_cache *cache, char *args)
397 {
398 	unsigned long brun;
399 
400 	_enter(",%s", args);
401 
402 	if (!*args)
403 		return -EINVAL;
404 
405 	brun = simple_strtoul(args, &args, 10);
406 	if (args[0] != '%' || args[1] != '\0')
407 		return -EINVAL;
408 
409 	if (brun <= cache->bcull_percent || brun >= 100)
410 		return cachefiles_daemon_range_error(cache, args);
411 
412 	cache->brun_percent = brun;
413 	return 0;
414 }
415 
416 /*
417  * Set the percentage of blocks at which to start culling
418  * - command: "bcull <N>%"
419  */
420 static int cachefiles_daemon_bcull(struct cachefiles_cache *cache, char *args)
421 {
422 	unsigned long bcull;
423 
424 	_enter(",%s", args);
425 
426 	if (!*args)
427 		return -EINVAL;
428 
429 	bcull = simple_strtoul(args, &args, 10);
430 	if (args[0] != '%' || args[1] != '\0')
431 		return -EINVAL;
432 
433 	if (bcull <= cache->bstop_percent || bcull >= cache->brun_percent)
434 		return cachefiles_daemon_range_error(cache, args);
435 
436 	cache->bcull_percent = bcull;
437 	return 0;
438 }
439 
440 /*
441  * Set the percentage of blocks at which to stop allocating
442  * - command: "bstop <N>%"
443  */
444 static int cachefiles_daemon_bstop(struct cachefiles_cache *cache, char *args)
445 {
446 	unsigned long bstop;
447 
448 	_enter(",%s", args);
449 
450 	if (!*args)
451 		return -EINVAL;
452 
453 	bstop = simple_strtoul(args, &args, 10);
454 	if (args[0] != '%' || args[1] != '\0')
455 		return -EINVAL;
456 
457 	if (bstop >= cache->bcull_percent)
458 		return cachefiles_daemon_range_error(cache, args);
459 
460 	cache->bstop_percent = bstop;
461 	return 0;
462 }
463 
464 /*
465  * Set the cache directory
466  * - command: "dir <name>"
467  */
468 static int cachefiles_daemon_dir(struct cachefiles_cache *cache, char *args)
469 {
470 	char *dir;
471 
472 	_enter(",%s", args);
473 
474 	if (!*args) {
475 		pr_err("Empty directory specified\n");
476 		return -EINVAL;
477 	}
478 
479 	if (cache->rootdirname) {
480 		pr_err("Second cache directory specified\n");
481 		return -EEXIST;
482 	}
483 
484 	dir = kstrdup(args, GFP_KERNEL);
485 	if (!dir)
486 		return -ENOMEM;
487 
488 	cache->rootdirname = dir;
489 	return 0;
490 }
491 
492 /*
493  * Set the cache security context
494  * - command: "secctx <ctx>"
495  */
496 static int cachefiles_daemon_secctx(struct cachefiles_cache *cache, char *args)
497 {
498 	char *secctx;
499 
500 	_enter(",%s", args);
501 
502 	if (!*args) {
503 		pr_err("Empty security context specified\n");
504 		return -EINVAL;
505 	}
506 
507 	if (cache->secctx) {
508 		pr_err("Second security context specified\n");
509 		return -EINVAL;
510 	}
511 
512 	secctx = kstrdup(args, GFP_KERNEL);
513 	if (!secctx)
514 		return -ENOMEM;
515 
516 	cache->secctx = secctx;
517 	return 0;
518 }
519 
520 /*
521  * Set the cache tag
522  * - command: "tag <name>"
523  */
524 static int cachefiles_daemon_tag(struct cachefiles_cache *cache, char *args)
525 {
526 	char *tag;
527 
528 	_enter(",%s", args);
529 
530 	if (!*args) {
531 		pr_err("Empty tag specified\n");
532 		return -EINVAL;
533 	}
534 
535 	if (cache->tag)
536 		return -EEXIST;
537 
538 	tag = kstrdup(args, GFP_KERNEL);
539 	if (!tag)
540 		return -ENOMEM;
541 
542 	cache->tag = tag;
543 	return 0;
544 }
545 
546 /*
547  * Request a node in the cache be culled from the current working directory
548  * - command: "cull <name>"
549  */
550 static int cachefiles_daemon_cull(struct cachefiles_cache *cache, char *args)
551 {
552 	struct path path;
553 	const struct cred *saved_cred;
554 	int ret;
555 
556 	_enter(",%s", args);
557 
558 	if (strchr(args, '/'))
559 		goto inval;
560 
561 	if (!test_bit(CACHEFILES_READY, &cache->flags)) {
562 		pr_err("cull applied to unready cache\n");
563 		return -EIO;
564 	}
565 
566 	if (test_bit(CACHEFILES_DEAD, &cache->flags)) {
567 		pr_err("cull applied to dead cache\n");
568 		return -EIO;
569 	}
570 
571 	get_fs_pwd(current->fs, &path);
572 
573 	if (!d_can_lookup(path.dentry))
574 		goto notdir;
575 
576 	cachefiles_begin_secure(cache, &saved_cred);
577 	ret = -ENOANO; // PLACEHOLDER: Do culling
578 	cachefiles_end_secure(cache, saved_cred);
579 
580 	path_put(&path);
581 	_leave(" = %d", ret);
582 	return ret;
583 
584 notdir:
585 	path_put(&path);
586 	pr_err("cull command requires dirfd to be a directory\n");
587 	return -ENOTDIR;
588 
589 inval:
590 	pr_err("cull command requires dirfd and filename\n");
591 	return -EINVAL;
592 }
593 
594 /*
595  * Set debugging mode
596  * - command: "debug <mask>"
597  */
598 static int cachefiles_daemon_debug(struct cachefiles_cache *cache, char *args)
599 {
600 	unsigned long mask;
601 
602 	_enter(",%s", args);
603 
604 	mask = simple_strtoul(args, &args, 0);
605 	if (args[0] != '\0')
606 		goto inval;
607 
608 	cachefiles_debug = mask;
609 	_leave(" = 0");
610 	return 0;
611 
612 inval:
613 	pr_err("debug command requires mask\n");
614 	return -EINVAL;
615 }
616 
617 /*
618  * Find out whether an object in the current working directory is in use or not
619  * - command: "inuse <name>"
620  */
621 static int cachefiles_daemon_inuse(struct cachefiles_cache *cache, char *args)
622 {
623 	struct path path;
624 	const struct cred *saved_cred;
625 	int ret;
626 
627 	//_enter(",%s", args);
628 
629 	if (strchr(args, '/'))
630 		goto inval;
631 
632 	if (!test_bit(CACHEFILES_READY, &cache->flags)) {
633 		pr_err("inuse applied to unready cache\n");
634 		return -EIO;
635 	}
636 
637 	if (test_bit(CACHEFILES_DEAD, &cache->flags)) {
638 		pr_err("inuse applied to dead cache\n");
639 		return -EIO;
640 	}
641 
642 	get_fs_pwd(current->fs, &path);
643 
644 	if (!d_can_lookup(path.dentry))
645 		goto notdir;
646 
647 	cachefiles_begin_secure(cache, &saved_cred);
648 	ret = -ENOANO; // PLACEHOLDER: Check if in use
649 	cachefiles_end_secure(cache, saved_cred);
650 
651 	path_put(&path);
652 	//_leave(" = %d", ret);
653 	return ret;
654 
655 notdir:
656 	path_put(&path);
657 	pr_err("inuse command requires dirfd to be a directory\n");
658 	return -ENOTDIR;
659 
660 inval:
661 	pr_err("inuse command requires dirfd and filename\n");
662 	return -EINVAL;
663 }
664 
665 /*
666  * Bind a directory as a cache
667  */
668 static int cachefiles_daemon_bind(struct cachefiles_cache *cache, char *args)
669 {
670 	_enter("{%u,%u,%u,%u,%u,%u},%s",
671 	       cache->frun_percent,
672 	       cache->fcull_percent,
673 	       cache->fstop_percent,
674 	       cache->brun_percent,
675 	       cache->bcull_percent,
676 	       cache->bstop_percent,
677 	       args);
678 
679 	if (cache->fstop_percent >= cache->fcull_percent ||
680 	    cache->fcull_percent >= cache->frun_percent ||
681 	    cache->frun_percent  >= 100)
682 		return -ERANGE;
683 
684 	if (cache->bstop_percent >= cache->bcull_percent ||
685 	    cache->bcull_percent >= cache->brun_percent ||
686 	    cache->brun_percent  >= 100)
687 		return -ERANGE;
688 
689 	if (*args) {
690 		pr_err("'bind' command doesn't take an argument\n");
691 		return -EINVAL;
692 	}
693 
694 	if (!cache->rootdirname) {
695 		pr_err("No cache directory specified\n");
696 		return -EINVAL;
697 	}
698 
699 	/* Don't permit already bound caches to be re-bound */
700 	if (test_bit(CACHEFILES_READY, &cache->flags)) {
701 		pr_err("Cache already bound\n");
702 		return -EBUSY;
703 	}
704 
705 	pr_warn("Cache is disabled for development\n");
706 	return -ENOANO; // Don't allow the cache to operate yet
707 	//return cachefiles_add_cache(cache);
708 }
709 
710 /*
711  * Unbind a cache.
712  */
713 static void cachefiles_daemon_unbind(struct cachefiles_cache *cache)
714 {
715 	_enter("");
716 
717 	if (test_bit(CACHEFILES_READY, &cache->flags))
718 		cachefiles_withdraw_cache(cache);
719 
720 	cachefiles_put_directory(cache->graveyard);
721 	cachefiles_put_directory(cache->store);
722 	mntput(cache->mnt);
723 
724 	kfree(cache->rootdirname);
725 	kfree(cache->secctx);
726 	kfree(cache->tag);
727 
728 	_leave("");
729 }
730