search for: balloon_work

...vers/xen/balloon.c index 952cfe2..4223f64 100644 --- a/drivers/xen/balloon.c +++ b/drivers/xen/balloon.c @@ -99,8 +99,7 @@ static LIST_HEAD(ballooned_pages); /* Main work function, always executed in process context. */ static void balloon_process(struct work_struct *work); -static DECLARE_WORK(balloon_worker, balloon_process); -static struct timer_list balloon_timer; +static DECLARE_DELAYED_WORK(balloon_worker, balloon_process); /* When ballooning out (allocating memory to return to Xen) we don''t really want the kernel to try too hard since that can trigger the oom killer. */ @@ -172,...

...E_LICENSE("GPL"); +MODULE_VERSION("1"); + +static int kvm_balloon_debug; + +#define dprintk(dev, str...) if (kvm_balloon_debug) dev_dbg(dev, str) + +#define BALLOON_DATA_SIZE 200 + +struct balloon_buf { + struct virtio_balloon_hdr hdr; + u8 data[BALLOON_DATA_SIZE]; +}; + +struct balloon_work { + struct balloon_buf *buf; + struct list_head list; +}; + +#define VIRTIO_MAX_SG 2 + +struct virtballoon { + struct virtio_device *vdev; + struct virtqueue *vq; + struct task_struct *balloon_thread; + wait_queue_head_t balloon_wait; + wait_queue_head_t rmmod_wait; + uint32_t target_nrpages; + ato...

...E_LICENSE("GPL"); +MODULE_VERSION("1"); + +static int kvm_balloon_debug; + +#define dprintk(dev, str...) if (kvm_balloon_debug) dev_dbg(dev, str) + +#define BALLOON_DATA_SIZE 200 + +struct balloon_buf { + struct virtio_balloon_hdr hdr; + u8 data[BALLOON_DATA_SIZE]; +}; + +struct balloon_work { + struct balloon_buf *buf; + struct list_head list; +}; + +#define VIRTIO_MAX_SG 2 + +struct virtballoon { + struct virtio_device *vdev; + struct virtqueue *vq; + struct task_struct *balloon_thread; + wait_queue_head_t balloon_wait; + wait_queue_head_t rmmod_wait; + uint32_t target_nrpages; + ato...

...uot;1"); + +#define CMD_BALLOON_INFLATE 0x1 +#define CMD_BALLOON_DEFLATE 0x2 + +static int kvm_balloon_debug; + +#define DEBUG +#ifdef DEBUG +#define dprintk(str...) if (kvm_balloon_debug) printk(str) +#else +#define dprintk(str...) +#endif + +static LIST_HEAD(balloon_plist); +static LIST_HEAD(balloon_work); +static int balloon_size = 0; +static DEFINE_SPINLOCK(balloon_plist_lock); +static DEFINE_SPINLOCK(balloon_queue_lock); + +struct virtio_balloon_hdr { + uint8_t cmd; + uint8_t status; +}; + +#define BALLOON_DATA_SIZE 200 + +struct balloon_buf { + struct virtio_balloon_hdr hdr; + u8 data[BALLOON_D...

...uot;1"); + +#define CMD_BALLOON_INFLATE 0x1 +#define CMD_BALLOON_DEFLATE 0x2 + +static int kvm_balloon_debug; + +#define DEBUG +#ifdef DEBUG +#define dprintk(str...) if (kvm_balloon_debug) printk(str) +#else +#define dprintk(str...) +#endif + +static LIST_HEAD(balloon_plist); +static LIST_HEAD(balloon_work); +static int balloon_size = 0; +static DEFINE_SPINLOCK(balloon_plist_lock); +static DEFINE_SPINLOCK(balloon_queue_lock); + +struct virtio_balloon_hdr { + uint8_t cmd; + uint8_t status; +}; + +#define BALLOON_DATA_SIZE 200 + +struct balloon_buf { + struct virtio_balloon_hdr hdr; + u8 data[BALLOON_D...

...ak; @@ -290,7 +290,7 @@ static int decrease_reservation(unsigned long nr_pages) (unsigned long)__va(pfn << PAGE_SHIFT), __pte_ma(0), 0); BUG_ON(ret); - } + } } @@ -360,8 +360,7 @@ static void balloon_set_new_target(unsigned long target) schedule_work(&balloon_worker); } -static struct xenbus_watch target_watch = -{ +static struct xenbus_watch target_watch = { .node = "memory/target" }; @@ -460,8 +459,8 @@ BALLOON_SHOW(low_kb, "%lu\n", PAGES2KB(balloon_stats.balloon_low)); BALLOON_SHOW(high_kb, "%lu\n", PAGES2KB(balloon_...

...ak; @@ -290,7 +290,7 @@ static int decrease_reservation(unsigned long nr_pages) (unsigned long)__va(pfn << PAGE_SHIFT), __pte_ma(0), 0); BUG_ON(ret); - } + } } @@ -360,8 +360,7 @@ static void balloon_set_new_target(unsigned long target) schedule_work(&balloon_worker); } -static struct xenbus_watch target_watch = -{ +static struct xenbus_watch target_watch = { .node = "memory/target" }; @@ -460,8 +459,8 @@ BALLOON_SHOW(low_kb, "%lu\n", PAGES2KB(balloon_stats.balloon_low)); BALLOON_SHOW(high_kb, "%lu\n", PAGES2KB(balloon_...

...ak; @@ -290,7 +290,7 @@ static int decrease_reservation(unsigned long nr_pages) (unsigned long)__va(pfn << PAGE_SHIFT), __pte_ma(0), 0); BUG_ON(ret); - } + } } @@ -360,8 +360,7 @@ static void balloon_set_new_target(unsigned long target) schedule_work(&balloon_worker); } -static struct xenbus_watch target_watch = -{ +static struct xenbus_watch target_watch = { .node = "memory/target" }; @@ -460,8 +459,8 @@ BALLOON_SHOW(low_kb, "%lu\n", PAGES2KB(balloon_stats.balloon_low)); BALLOON_SHOW(high_kb, "%lu\n", PAGES2KB(balloon_...

...#ifdef CONFIG_XEN_MEMORY_HOTPLUG - -/* Resets the Xen limit, sets new target, and kicks off processing. */ -static void balloon_set_new_target(unsigned long target) -{ - mutex_lock(&balloon_mutex); - balloon_stats.target_pages = target; - mutex_unlock(&balloon_mutex); - - schedule_work(&balloon_worker); -} - -void balloon_update_stats(long nr_pages) -{ - mutex_lock(&balloon_mutex); - - balloon_stats.current_pages += nr_pages; - balloon_stats.target_pages += nr_pages; - - xenbus_printf(XBT_NIL, "memory", "target", "%llu", - (unsigned long long)balloon_stats.t...

Hi, Here is the third version of memory hotplug support for Xen guests patch. This one cleanly applies to git://git.kernel.org/pub/scm/linux/kernel/git/jeremy/xen.git repository, xen/memory-hotplug head. On Fri, Aug 06, 2010 at 04:03:18PM +0400, Vasiliy G Tolstov wrote: [...] > Testing on sles 11 sp1 and opensuse 11.3. On results - send e-mail.. Thx. On Fri, Aug 06, 2010 at 12:34:08PM