aboutsummaryrefslogtreecommitdiffstats
path: root/drivers/xen/balloon.c
diff options
context:
space:
mode:
Diffstat (limited to 'drivers/xen/balloon.c')
-rw-r--r--drivers/xen/balloon.c229
1 files changed, 6 insertions, 223 deletions
diff --git a/drivers/xen/balloon.c b/drivers/xen/balloon.c
index 77e6ad38c0b..7497041d063 100644
--- a/drivers/xen/balloon.c
+++ b/drivers/xen/balloon.c
@@ -1,6 +1,4 @@
1/****************************************************************************** 1/******************************************************************************
2 * balloon.c
3 *
4 * Xen balloon driver - enables returning/claiming memory to/from Xen. 2 * Xen balloon driver - enables returning/claiming memory to/from Xen.
5 * 3 *
6 * Copyright (c) 2003, B Dragovic 4 * Copyright (c) 2003, B Dragovic
@@ -33,7 +31,6 @@
33 */ 31 */
34 32
35#include <linux/kernel.h> 33#include <linux/kernel.h>
36#include <linux/module.h>
37#include <linux/sched.h> 34#include <linux/sched.h>
38#include <linux/errno.h> 35#include <linux/errno.h>
39#include <linux/mm.h> 36#include <linux/mm.h>
@@ -42,13 +39,11 @@
42#include <linux/highmem.h> 39#include <linux/highmem.h>
43#include <linux/mutex.h> 40#include <linux/mutex.h>
44#include <linux/list.h> 41#include <linux/list.h>
45#include <linux/sysdev.h>
46#include <linux/gfp.h> 42#include <linux/gfp.h>
47 43
48#include <asm/page.h> 44#include <asm/page.h>
49#include <asm/pgalloc.h> 45#include <asm/pgalloc.h>
50#include <asm/pgtable.h> 46#include <asm/pgtable.h>
51#include <asm/uaccess.h>
52#include <asm/tlb.h> 47#include <asm/tlb.h>
53#include <asm/e820.h> 48#include <asm/e820.h>
54 49
@@ -58,14 +53,10 @@
58#include <xen/xen.h> 53#include <xen/xen.h>
59#include <xen/interface/xen.h> 54#include <xen/interface/xen.h>
60#include <xen/interface/memory.h> 55#include <xen/interface/memory.h>
61#include <xen/xenbus.h> 56#include <xen/balloon.h>
62#include <xen/features.h> 57#include <xen/features.h>
63#include <xen/page.h> 58#include <xen/page.h>
64 59
65#define PAGES2KB(_p) ((_p)<<(PAGE_SHIFT-10))
66
67#define BALLOON_CLASS_NAME "xen_memory"
68
69/* 60/*
70 * balloon_process() state: 61 * balloon_process() state:
71 * 62 *
@@ -80,28 +71,11 @@ enum bp_state {
80 BP_ECANCELED 71 BP_ECANCELED
81}; 72};
82 73
83#define RETRY_UNLIMITED 0
84
85struct balloon_stats {
86 /* We aim for 'current allocation' == 'target allocation'. */
87 unsigned long current_pages;
88 unsigned long target_pages;
89 /* Number of pages in high- and low-memory balloons. */
90 unsigned long balloon_low;
91 unsigned long balloon_high;
92 unsigned long schedule_delay;
93 unsigned long max_schedule_delay;
94 unsigned long retry_count;
95 unsigned long max_retry_count;
96};
97 74
98static DEFINE_MUTEX(balloon_mutex); 75static DEFINE_MUTEX(balloon_mutex);
99 76
100static struct sys_device balloon_sysdev; 77struct balloon_stats balloon_stats;
101 78EXPORT_SYMBOL_GPL(balloon_stats);
102static int register_balloon(struct sys_device *sysdev);
103
104static struct balloon_stats balloon_stats;
105 79
106/* We increase/decrease in batches which fit in a page */ 80/* We increase/decrease in batches which fit in a page */
107static unsigned long frame_list[PAGE_SIZE / sizeof(unsigned long)]; 81static unsigned long frame_list[PAGE_SIZE / sizeof(unsigned long)];
@@ -384,51 +358,13 @@ static void balloon_process(struct work_struct *work)
384} 358}
385 359
386/* Resets the Xen limit, sets new target, and kicks off processing. */ 360/* Resets the Xen limit, sets new target, and kicks off processing. */
387static void balloon_set_new_target(unsigned long target) 361void balloon_set_new_target(unsigned long target)
388{ 362{
389 /* No need for lock. Not read-modify-write updates. */ 363 /* No need for lock. Not read-modify-write updates. */
390 balloon_stats.target_pages = target; 364 balloon_stats.target_pages = target;
391 schedule_delayed_work(&balloon_worker, 0); 365 schedule_delayed_work(&balloon_worker, 0);
392} 366}
393 367EXPORT_SYMBOL_GPL(balloon_set_new_target);
394static struct xenbus_watch target_watch =
395{
396 .node = "memory/target"
397};
398
399/* React to a change in the target key */
400static void watch_target(struct xenbus_watch *watch,
401 const char **vec, unsigned int len)
402{
403 unsigned long long new_target;
404 int err;
405
406 err = xenbus_scanf(XBT_NIL, "memory", "target", "%llu", &new_target);
407 if (err != 1) {
408 /* This is ok (for domain0 at least) - so just return */
409 return;
410 }
411
412 /* The given memory/target value is in KiB, so it needs converting to
413 * pages. PAGE_SHIFT converts bytes to pages, hence PAGE_SHIFT - 10.
414 */
415 balloon_set_new_target(new_target >> (PAGE_SHIFT - 10));
416}
417
418static int balloon_init_watcher(struct notifier_block *notifier,
419 unsigned long event,
420 void *data)
421{
422 int err;
423
424 err = register_xenbus_watch(&target_watch);
425 if (err)
426 printk(KERN_ERR "Failed to set balloon watcher\n");
427
428 return NOTIFY_DONE;
429}
430
431static struct notifier_block xenstore_notifier;
432 368
433static int __init balloon_init(void) 369static int __init balloon_init(void)
434{ 370{
@@ -438,7 +374,7 @@ static int __init balloon_init(void)
438 if (!xen_pv_domain()) 374 if (!xen_pv_domain())
439 return -ENODEV; 375 return -ENODEV;
440 376
441 pr_info("xen_balloon: Initialising balloon driver.\n"); 377 pr_info("xen/balloon: Initialising balloon driver.\n");
442 378
443 balloon_stats.current_pages = min(xen_start_info->nr_pages, max_pfn); 379 balloon_stats.current_pages = min(xen_start_info->nr_pages, max_pfn);
444 balloon_stats.target_pages = balloon_stats.current_pages; 380 balloon_stats.target_pages = balloon_stats.current_pages;
@@ -450,8 +386,6 @@ static int __init balloon_init(void)
450 balloon_stats.retry_count = 1; 386 balloon_stats.retry_count = 1;
451 balloon_stats.max_retry_count = RETRY_UNLIMITED; 387 balloon_stats.max_retry_count = RETRY_UNLIMITED;
452 388
453 register_balloon(&balloon_sysdev);
454
455 /* 389 /*
456 * Initialise the balloon with excess memory space. We need 390 * Initialise the balloon with excess memory space. We need
457 * to make sure we don't add memory which doesn't exist or 391 * to make sure we don't add memory which doesn't exist or
@@ -472,160 +406,9 @@ static int __init balloon_init(void)
472 __balloon_append(page); 406 __balloon_append(page);
473 } 407 }
474 408
475 target_watch.callback = watch_target;
476 xenstore_notifier.notifier_call = balloon_init_watcher;
477
478 register_xenstore_notifier(&xenstore_notifier);
479
480 return 0; 409 return 0;
481} 410}
482 411
483subsys_initcall(balloon_init); 412subsys_initcall(balloon_init);
484 413
485static void balloon_exit(void)
486{
487 /* XXX - release balloon here */
488 return;
489}
490
491module_exit(balloon_exit);
492
493#define BALLOON_SHOW(name, format, args...) \
494 static ssize_t show_##name(struct sys_device *dev, \
495 struct sysdev_attribute *attr, \
496 char *buf) \
497 { \
498 return sprintf(buf, format, ##args); \
499 } \
500 static SYSDEV_ATTR(name, S_IRUGO, show_##name, NULL)
501
502BALLOON_SHOW(current_kb, "%lu\n", PAGES2KB(balloon_stats.current_pages));
503BALLOON_SHOW(low_kb, "%lu\n", PAGES2KB(balloon_stats.balloon_low));
504BALLOON_SHOW(high_kb, "%lu\n", PAGES2KB(balloon_stats.balloon_high));
505
506static SYSDEV_ULONG_ATTR(schedule_delay, 0444, balloon_stats.schedule_delay);
507static SYSDEV_ULONG_ATTR(max_schedule_delay, 0644, balloon_stats.max_schedule_delay);
508static SYSDEV_ULONG_ATTR(retry_count, 0444, balloon_stats.retry_count);
509static SYSDEV_ULONG_ATTR(max_retry_count, 0644, balloon_stats.max_retry_count);
510
511static ssize_t show_target_kb(struct sys_device *dev, struct sysdev_attribute *attr,
512 char *buf)
513{
514 return sprintf(buf, "%lu\n", PAGES2KB(balloon_stats.target_pages));
515}
516
517static ssize_t store_target_kb(struct sys_device *dev,
518 struct sysdev_attribute *attr,
519 const char *buf,
520 size_t count)
521{
522 char *endchar;
523 unsigned long long target_bytes;
524
525 if (!capable(CAP_SYS_ADMIN))
526 return -EPERM;
527
528 target_bytes = simple_strtoull(buf, &endchar, 0) * 1024;
529
530 balloon_set_new_target(target_bytes >> PAGE_SHIFT);
531
532 return count;
533}
534
535static SYSDEV_ATTR(target_kb, S_IRUGO | S_IWUSR,
536 show_target_kb, store_target_kb);
537
538
539static ssize_t show_target(struct sys_device *dev, struct sysdev_attribute *attr,
540 char *buf)
541{
542 return sprintf(buf, "%llu\n",
543 (unsigned long long)balloon_stats.target_pages
544 << PAGE_SHIFT);
545}
546
547static ssize_t store_target(struct sys_device *dev,
548 struct sysdev_attribute *attr,
549 const char *buf,
550 size_t count)
551{
552 char *endchar;
553 unsigned long long target_bytes;
554
555 if (!capable(CAP_SYS_ADMIN))
556 return -EPERM;
557
558 target_bytes = memparse(buf, &endchar);
559
560 balloon_set_new_target(target_bytes >> PAGE_SHIFT);
561
562 return count;
563}
564
565static SYSDEV_ATTR(target, S_IRUGO | S_IWUSR,
566 show_target, store_target);
567
568
569static struct sysdev_attribute *balloon_attrs[] = {
570 &attr_target_kb,
571 &attr_target,
572 &attr_schedule_delay.attr,
573 &attr_max_schedule_delay.attr,
574 &attr_retry_count.attr,
575 &attr_max_retry_count.attr
576};
577
578static struct attribute *balloon_info_attrs[] = {
579 &attr_current_kb.attr,
580 &attr_low_kb.attr,
581 &attr_high_kb.attr,
582 NULL
583};
584
585static struct attribute_group balloon_info_group = {
586 .name = "info",
587 .attrs = balloon_info_attrs,
588};
589
590static struct sysdev_class balloon_sysdev_class = {
591 .name = BALLOON_CLASS_NAME,
592};
593
594static int register_balloon(struct sys_device *sysdev)
595{
596 int i, error;
597
598 error = sysdev_class_register(&balloon_sysdev_class);
599 if (error)
600 return error;
601
602 sysdev->id = 0;
603 sysdev->cls = &balloon_sysdev_class;
604
605 error = sysdev_register(sysdev);
606 if (error) {
607 sysdev_class_unregister(&balloon_sysdev_class);
608 return error;
609 }
610
611 for (i = 0; i < ARRAY_SIZE(balloon_attrs); i++) {
612 error = sysdev_create_file(sysdev, balloon_attrs[i]);
613 if (error)
614 goto fail;
615 }
616
617 error = sysfs_create_group(&sysdev->kobj, &balloon_info_group);
618 if (error)
619 goto fail;
620
621 return 0;
622
623 fail:
624 while (--i >= 0)
625 sysdev_remove_file(sysdev, balloon_attrs[i]);
626 sysdev_unregister(sysdev);
627 sysdev_class_unregister(&balloon_sysdev_class);
628 return error;
629}
630
631MODULE_LICENSE("GPL"); 414MODULE_LICENSE("GPL");