virtio_balloon.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727
  1. /*
  2. * Virtio balloon implementation, inspired by Dor Laor and Marcelo
  3. * Tosatti's implementations.
  4. *
  5. * Copyright 2008 Rusty Russell IBM Corporation
  6. *
  7. * This program is free software; you can redistribute it and/or modify
  8. * it under the terms of the GNU General Public License as published by
  9. * the Free Software Foundation; either version 2 of the License, or
  10. * (at your option) any later version.
  11. *
  12. * This program is distributed in the hope that it will be useful,
  13. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  15. * GNU General Public License for more details.
  16. *
  17. * You should have received a copy of the GNU General Public License
  18. * along with this program; if not, write to the Free Software
  19. * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  20. */
  21. #include <linux/virtio.h>
  22. #include <linux/virtio_balloon.h>
  23. #include <linux/swap.h>
  24. #include <linux/workqueue.h>
  25. #include <linux/delay.h>
  26. #include <linux/slab.h>
  27. #include <linux/module.h>
  28. #include <linux/balloon_compaction.h>
  29. #include <linux/wait.h>
  30. #include <linux/mm.h>
  31. #include <linux/mount.h>
  32. #include <linux/magic.h>
  33. /*
  34. * Balloon device works in 4K page units. So each page is pointed to by
  35. * multiple balloon pages. All memory counters in this driver are in balloon
  36. * page units.
  37. */
  38. #define VIRTIO_BALLOON_PAGES_PER_PAGE (unsigned)(PAGE_SIZE >> VIRTIO_BALLOON_PFN_SHIFT)
  39. #define VIRTIO_BALLOON_ARRAY_PFNS_MAX 256
  40. #define VIRTBALLOON_OOM_NOTIFY_PRIORITY 80
  41. #ifdef CONFIG_BALLOON_COMPACTION
  42. static struct vfsmount *balloon_mnt;
  43. #endif
  44. struct virtio_balloon {
  45. struct virtio_device *vdev;
  46. struct virtqueue *inflate_vq, *deflate_vq, *stats_vq;
  47. /* The balloon servicing is delegated to a freezable workqueue. */
  48. struct work_struct update_balloon_stats_work;
  49. struct work_struct update_balloon_size_work;
  50. /* Prevent updating balloon when it is being canceled. */
  51. spinlock_t stop_update_lock;
  52. bool stop_update;
  53. /* Waiting for host to ack the pages we released. */
  54. wait_queue_head_t acked;
  55. /* Number of balloon pages we've told the Host we're not using. */
  56. unsigned int num_pages;
  57. /*
  58. * The pages we've told the Host we're not using are enqueued
  59. * at vb_dev_info->pages list.
  60. * Each page on this list adds VIRTIO_BALLOON_PAGES_PER_PAGE
  61. * to num_pages above.
  62. */
  63. struct balloon_dev_info vb_dev_info;
  64. /* Synchronize access/update to this struct virtio_balloon elements */
  65. struct mutex balloon_lock;
  66. /* The array of pfns we tell the Host about. */
  67. unsigned int num_pfns;
  68. __virtio32 pfns[VIRTIO_BALLOON_ARRAY_PFNS_MAX];
  69. /* Memory statistics */
  70. struct virtio_balloon_stat stats[VIRTIO_BALLOON_S_NR];
  71. /* To register a shrinker to shrink memory upon memory pressure */
  72. struct shrinker shrinker;
  73. };
  74. static struct virtio_device_id id_table[] = {
  75. { VIRTIO_ID_BALLOON, VIRTIO_DEV_ANY_ID },
  76. { 0 },
  77. };
  78. static u32 page_to_balloon_pfn(struct page *page)
  79. {
  80. unsigned long pfn = page_to_pfn(page);
  81. BUILD_BUG_ON(PAGE_SHIFT < VIRTIO_BALLOON_PFN_SHIFT);
  82. /* Convert pfn from Linux page size to balloon page size. */
  83. return pfn * VIRTIO_BALLOON_PAGES_PER_PAGE;
  84. }
  85. static void balloon_ack(struct virtqueue *vq)
  86. {
  87. struct virtio_balloon *vb = vq->vdev->priv;
  88. wake_up(&vb->acked);
  89. }
  90. static void tell_host(struct virtio_balloon *vb, struct virtqueue *vq)
  91. {
  92. struct scatterlist sg;
  93. unsigned int len;
  94. sg_init_one(&sg, vb->pfns, sizeof(vb->pfns[0]) * vb->num_pfns);
  95. /* We should always be able to add one buffer to an empty queue. */
  96. virtqueue_add_outbuf(vq, &sg, 1, vb, GFP_KERNEL);
  97. virtqueue_kick(vq);
  98. /* When host has read buffer, this completes via balloon_ack */
  99. wait_event(vb->acked, virtqueue_get_buf(vq, &len));
  100. }
  101. static void set_page_pfns(struct virtio_balloon *vb,
  102. __virtio32 pfns[], struct page *page)
  103. {
  104. unsigned int i;
  105. /*
  106. * Set balloon pfns pointing at this page.
  107. * Note that the first pfn points at start of the page.
  108. */
  109. for (i = 0; i < VIRTIO_BALLOON_PAGES_PER_PAGE; i++)
  110. pfns[i] = cpu_to_virtio32(vb->vdev,
  111. page_to_balloon_pfn(page) + i);
  112. }
  113. static unsigned fill_balloon(struct virtio_balloon *vb, size_t num)
  114. {
  115. unsigned num_allocated_pages;
  116. unsigned num_pfns;
  117. struct page *page;
  118. LIST_HEAD(pages);
  119. /* We can only do one array worth at a time. */
  120. num = min(num, ARRAY_SIZE(vb->pfns));
  121. for (num_pfns = 0; num_pfns < num;
  122. num_pfns += VIRTIO_BALLOON_PAGES_PER_PAGE) {
  123. struct page *page = balloon_page_alloc();
  124. if (!page) {
  125. dev_info_ratelimited(&vb->vdev->dev,
  126. "Out of puff! Can't get %u pages\n",
  127. VIRTIO_BALLOON_PAGES_PER_PAGE);
  128. /* Sleep for at least 1/5 of a second before retry. */
  129. msleep(200);
  130. break;
  131. }
  132. balloon_page_push(&pages, page);
  133. }
  134. mutex_lock(&vb->balloon_lock);
  135. vb->num_pfns = 0;
  136. while ((page = balloon_page_pop(&pages))) {
  137. balloon_page_enqueue(&vb->vb_dev_info, page);
  138. set_page_pfns(vb, vb->pfns + vb->num_pfns, page);
  139. vb->num_pages += VIRTIO_BALLOON_PAGES_PER_PAGE;
  140. if (!virtio_has_feature(vb->vdev,
  141. VIRTIO_BALLOON_F_DEFLATE_ON_OOM))
  142. adjust_managed_page_count(page, -1);
  143. vb->num_pfns += VIRTIO_BALLOON_PAGES_PER_PAGE;
  144. }
  145. num_allocated_pages = vb->num_pfns;
  146. /* Did we get any? */
  147. if (vb->num_pfns != 0)
  148. tell_host(vb, vb->inflate_vq);
  149. mutex_unlock(&vb->balloon_lock);
  150. return num_allocated_pages;
  151. }
  152. static void release_pages_balloon(struct virtio_balloon *vb,
  153. struct list_head *pages)
  154. {
  155. struct page *page, *next;
  156. list_for_each_entry_safe(page, next, pages, lru) {
  157. if (!virtio_has_feature(vb->vdev,
  158. VIRTIO_BALLOON_F_DEFLATE_ON_OOM))
  159. adjust_managed_page_count(page, 1);
  160. list_del(&page->lru);
  161. put_page(page); /* balloon reference */
  162. }
  163. }
  164. static unsigned leak_balloon(struct virtio_balloon *vb, size_t num)
  165. {
  166. unsigned num_freed_pages;
  167. struct page *page;
  168. struct balloon_dev_info *vb_dev_info = &vb->vb_dev_info;
  169. LIST_HEAD(pages);
  170. /* We can only do one array worth at a time. */
  171. num = min(num, ARRAY_SIZE(vb->pfns));
  172. mutex_lock(&vb->balloon_lock);
  173. /* We can't release more pages than taken */
  174. num = min(num, (size_t)vb->num_pages);
  175. for (vb->num_pfns = 0; vb->num_pfns < num;
  176. vb->num_pfns += VIRTIO_BALLOON_PAGES_PER_PAGE) {
  177. page = balloon_page_dequeue(vb_dev_info);
  178. if (!page)
  179. break;
  180. set_page_pfns(vb, vb->pfns + vb->num_pfns, page);
  181. list_add(&page->lru, &pages);
  182. vb->num_pages -= VIRTIO_BALLOON_PAGES_PER_PAGE;
  183. }
  184. num_freed_pages = vb->num_pfns;
  185. /*
  186. * Note that if
  187. * virtio_has_feature(vdev, VIRTIO_BALLOON_F_MUST_TELL_HOST);
  188. * is true, we *have* to do it in this order
  189. */
  190. if (vb->num_pfns != 0)
  191. tell_host(vb, vb->deflate_vq);
  192. release_pages_balloon(vb, &pages);
  193. mutex_unlock(&vb->balloon_lock);
  194. return num_freed_pages;
  195. }
  196. static inline void update_stat(struct virtio_balloon *vb, int idx,
  197. u16 tag, u64 val)
  198. {
  199. BUG_ON(idx >= VIRTIO_BALLOON_S_NR);
  200. vb->stats[idx].tag = cpu_to_virtio16(vb->vdev, tag);
  201. vb->stats[idx].val = cpu_to_virtio64(vb->vdev, val);
  202. }
  203. #define pages_to_bytes(x) ((u64)(x) << PAGE_SHIFT)
  204. static unsigned int update_balloon_stats(struct virtio_balloon *vb)
  205. {
  206. unsigned long events[NR_VM_EVENT_ITEMS];
  207. struct sysinfo i;
  208. unsigned int idx = 0;
  209. long available;
  210. unsigned long caches;
  211. all_vm_events(events);
  212. si_meminfo(&i);
  213. available = si_mem_available();
  214. caches = global_node_page_state(NR_FILE_PAGES);
  215. #ifdef CONFIG_VM_EVENT_COUNTERS
  216. update_stat(vb, idx++, VIRTIO_BALLOON_S_SWAP_IN,
  217. pages_to_bytes(events[PSWPIN]));
  218. update_stat(vb, idx++, VIRTIO_BALLOON_S_SWAP_OUT,
  219. pages_to_bytes(events[PSWPOUT]));
  220. update_stat(vb, idx++, VIRTIO_BALLOON_S_MAJFLT, events[PGMAJFAULT]);
  221. update_stat(vb, idx++, VIRTIO_BALLOON_S_MINFLT, events[PGFAULT]);
  222. #ifdef CONFIG_HUGETLB_PAGE
  223. update_stat(vb, idx++, VIRTIO_BALLOON_S_HTLB_PGALLOC,
  224. events[HTLB_BUDDY_PGALLOC]);
  225. update_stat(vb, idx++, VIRTIO_BALLOON_S_HTLB_PGFAIL,
  226. events[HTLB_BUDDY_PGALLOC_FAIL]);
  227. #endif
  228. #endif
  229. update_stat(vb, idx++, VIRTIO_BALLOON_S_MEMFREE,
  230. pages_to_bytes(i.freeram));
  231. update_stat(vb, idx++, VIRTIO_BALLOON_S_MEMTOT,
  232. pages_to_bytes(i.totalram));
  233. update_stat(vb, idx++, VIRTIO_BALLOON_S_AVAIL,
  234. pages_to_bytes(available));
  235. update_stat(vb, idx++, VIRTIO_BALLOON_S_CACHES,
  236. pages_to_bytes(caches));
  237. return idx;
  238. }
  239. /*
  240. * While most virtqueues communicate guest-initiated requests to the hypervisor,
  241. * the stats queue operates in reverse. The driver initializes the virtqueue
  242. * with a single buffer. From that point forward, all conversations consist of
  243. * a hypervisor request (a call to this function) which directs us to refill
  244. * the virtqueue with a fresh stats buffer. Since stats collection can sleep,
  245. * we delegate the job to a freezable workqueue that will do the actual work via
  246. * stats_handle_request().
  247. */
  248. static void stats_request(struct virtqueue *vq)
  249. {
  250. struct virtio_balloon *vb = vq->vdev->priv;
  251. spin_lock(&vb->stop_update_lock);
  252. if (!vb->stop_update)
  253. queue_work(system_freezable_wq, &vb->update_balloon_stats_work);
  254. spin_unlock(&vb->stop_update_lock);
  255. }
  256. static void stats_handle_request(struct virtio_balloon *vb)
  257. {
  258. struct virtqueue *vq;
  259. struct scatterlist sg;
  260. unsigned int len, num_stats;
  261. num_stats = update_balloon_stats(vb);
  262. vq = vb->stats_vq;
  263. if (!virtqueue_get_buf(vq, &len))
  264. return;
  265. sg_init_one(&sg, vb->stats, sizeof(vb->stats[0]) * num_stats);
  266. virtqueue_add_outbuf(vq, &sg, 1, vb, GFP_KERNEL);
  267. virtqueue_kick(vq);
  268. }
  269. static void virtballoon_changed(struct virtio_device *vdev)
  270. {
  271. struct virtio_balloon *vb = vdev->priv;
  272. unsigned long flags;
  273. spin_lock_irqsave(&vb->stop_update_lock, flags);
  274. if (!vb->stop_update)
  275. queue_work(system_freezable_wq, &vb->update_balloon_size_work);
  276. spin_unlock_irqrestore(&vb->stop_update_lock, flags);
  277. }
  278. static inline s64 towards_target(struct virtio_balloon *vb)
  279. {
  280. s64 target;
  281. u32 num_pages;
  282. virtio_cread(vb->vdev, struct virtio_balloon_config, num_pages,
  283. &num_pages);
  284. /* Legacy balloon config space is LE, unlike all other devices. */
  285. if (!virtio_has_feature(vb->vdev, VIRTIO_F_VERSION_1))
  286. num_pages = le32_to_cpu((__force __le32)num_pages);
  287. target = num_pages;
  288. return target - vb->num_pages;
  289. }
  290. static void update_balloon_size(struct virtio_balloon *vb)
  291. {
  292. u32 actual = vb->num_pages;
  293. /* Legacy balloon config space is LE, unlike all other devices. */
  294. if (!virtio_has_feature(vb->vdev, VIRTIO_F_VERSION_1))
  295. actual = (__force u32)cpu_to_le32(actual);
  296. virtio_cwrite(vb->vdev, struct virtio_balloon_config, actual,
  297. &actual);
  298. }
  299. static void update_balloon_stats_func(struct work_struct *work)
  300. {
  301. struct virtio_balloon *vb;
  302. vb = container_of(work, struct virtio_balloon,
  303. update_balloon_stats_work);
  304. stats_handle_request(vb);
  305. }
  306. static void update_balloon_size_func(struct work_struct *work)
  307. {
  308. struct virtio_balloon *vb;
  309. s64 diff;
  310. vb = container_of(work, struct virtio_balloon,
  311. update_balloon_size_work);
  312. diff = towards_target(vb);
  313. if (diff > 0)
  314. diff -= fill_balloon(vb, diff);
  315. else if (diff < 0)
  316. diff += leak_balloon(vb, -diff);
  317. update_balloon_size(vb);
  318. if (diff)
  319. queue_work(system_freezable_wq, work);
  320. }
  321. static int init_vqs(struct virtio_balloon *vb)
  322. {
  323. struct virtqueue *vqs[3];
  324. vq_callback_t *callbacks[] = { balloon_ack, balloon_ack, stats_request };
  325. static const char * const names[] = { "inflate", "deflate", "stats" };
  326. int err, nvqs;
  327. /*
  328. * We expect two virtqueues: inflate and deflate, and
  329. * optionally stat.
  330. */
  331. nvqs = virtio_has_feature(vb->vdev, VIRTIO_BALLOON_F_STATS_VQ) ? 3 : 2;
  332. err = virtio_find_vqs(vb->vdev, nvqs, vqs, callbacks, names, NULL);
  333. if (err)
  334. return err;
  335. vb->inflate_vq = vqs[0];
  336. vb->deflate_vq = vqs[1];
  337. if (virtio_has_feature(vb->vdev, VIRTIO_BALLOON_F_STATS_VQ)) {
  338. struct scatterlist sg;
  339. unsigned int num_stats;
  340. vb->stats_vq = vqs[2];
  341. /*
  342. * Prime this virtqueue with one buffer so the hypervisor can
  343. * use it to signal us later (it can't be broken yet!).
  344. */
  345. num_stats = update_balloon_stats(vb);
  346. sg_init_one(&sg, vb->stats, sizeof(vb->stats[0]) * num_stats);
  347. err = virtqueue_add_outbuf(vb->stats_vq, &sg, 1, vb,
  348. GFP_KERNEL);
  349. if (err) {
  350. dev_warn(&vb->vdev->dev, "%s: add stat_vq failed\n",
  351. __func__);
  352. return err;
  353. }
  354. virtqueue_kick(vb->stats_vq);
  355. }
  356. return 0;
  357. }
  358. #ifdef CONFIG_BALLOON_COMPACTION
  359. /*
  360. * virtballoon_migratepage - perform the balloon page migration on behalf of
  361. * a compation thread. (called under page lock)
  362. * @vb_dev_info: the balloon device
  363. * @newpage: page that will replace the isolated page after migration finishes.
  364. * @page : the isolated (old) page that is about to be migrated to newpage.
  365. * @mode : compaction mode -- not used for balloon page migration.
  366. *
  367. * After a ballooned page gets isolated by compaction procedures, this is the
  368. * function that performs the page migration on behalf of a compaction thread
  369. * The page migration for virtio balloon is done in a simple swap fashion which
  370. * follows these two macro steps:
  371. * 1) insert newpage into vb->pages list and update the host about it;
  372. * 2) update the host about the old page removed from vb->pages list;
  373. *
  374. * This function preforms the balloon page migration task.
  375. * Called through balloon_mapping->a_ops->migratepage
  376. */
  377. static int virtballoon_migratepage(struct balloon_dev_info *vb_dev_info,
  378. struct page *newpage, struct page *page, enum migrate_mode mode)
  379. {
  380. struct virtio_balloon *vb = container_of(vb_dev_info,
  381. struct virtio_balloon, vb_dev_info);
  382. unsigned long flags;
  383. /*
  384. * In order to avoid lock contention while migrating pages concurrently
  385. * to leak_balloon() or fill_balloon() we just give up the balloon_lock
  386. * this turn, as it is easier to retry the page migration later.
  387. * This also prevents fill_balloon() getting stuck into a mutex
  388. * recursion in the case it ends up triggering memory compaction
  389. * while it is attempting to inflate the ballon.
  390. */
  391. if (!mutex_trylock(&vb->balloon_lock))
  392. return -EAGAIN;
  393. get_page(newpage); /* balloon reference */
  394. /* balloon's page migration 1st step -- inflate "newpage" */
  395. spin_lock_irqsave(&vb_dev_info->pages_lock, flags);
  396. balloon_page_insert(vb_dev_info, newpage);
  397. vb_dev_info->isolated_pages--;
  398. __count_vm_event(BALLOON_MIGRATE);
  399. spin_unlock_irqrestore(&vb_dev_info->pages_lock, flags);
  400. vb->num_pfns = VIRTIO_BALLOON_PAGES_PER_PAGE;
  401. set_page_pfns(vb, vb->pfns, newpage);
  402. tell_host(vb, vb->inflate_vq);
  403. /* balloon's page migration 2nd step -- deflate "page" */
  404. spin_lock_irqsave(&vb_dev_info->pages_lock, flags);
  405. balloon_page_delete(page);
  406. spin_unlock_irqrestore(&vb_dev_info->pages_lock, flags);
  407. vb->num_pfns = VIRTIO_BALLOON_PAGES_PER_PAGE;
  408. set_page_pfns(vb, vb->pfns, page);
  409. tell_host(vb, vb->deflate_vq);
  410. mutex_unlock(&vb->balloon_lock);
  411. put_page(page); /* balloon reference */
  412. return MIGRATEPAGE_SUCCESS;
  413. }
  414. static struct dentry *balloon_mount(struct file_system_type *fs_type,
  415. int flags, const char *dev_name, void *data)
  416. {
  417. static const struct dentry_operations ops = {
  418. .d_dname = simple_dname,
  419. };
  420. return mount_pseudo(fs_type, "balloon-kvm:", NULL, &ops,
  421. BALLOON_KVM_MAGIC);
  422. }
  423. static struct file_system_type balloon_fs = {
  424. .name = "balloon-kvm",
  425. .mount = balloon_mount,
  426. .kill_sb = kill_anon_super,
  427. };
  428. #endif /* CONFIG_BALLOON_COMPACTION */
  429. static unsigned long virtio_balloon_shrinker_scan(struct shrinker *shrinker,
  430. struct shrink_control *sc)
  431. {
  432. unsigned long pages_to_free, pages_freed = 0;
  433. struct virtio_balloon *vb = container_of(shrinker,
  434. struct virtio_balloon, shrinker);
  435. pages_to_free = sc->nr_to_scan * VIRTIO_BALLOON_PAGES_PER_PAGE;
  436. /*
  437. * One invocation of leak_balloon can deflate at most
  438. * VIRTIO_BALLOON_ARRAY_PFNS_MAX balloon pages, so we call it
  439. * multiple times to deflate pages till reaching pages_to_free.
  440. */
  441. while (vb->num_pages && pages_to_free) {
  442. pages_to_free -= pages_freed;
  443. pages_freed += leak_balloon(vb, pages_to_free);
  444. }
  445. update_balloon_size(vb);
  446. return pages_freed / VIRTIO_BALLOON_PAGES_PER_PAGE;
  447. }
  448. static unsigned long virtio_balloon_shrinker_count(struct shrinker *shrinker,
  449. struct shrink_control *sc)
  450. {
  451. struct virtio_balloon *vb = container_of(shrinker,
  452. struct virtio_balloon, shrinker);
  453. return vb->num_pages / VIRTIO_BALLOON_PAGES_PER_PAGE;
  454. }
  455. static void virtio_balloon_unregister_shrinker(struct virtio_balloon *vb)
  456. {
  457. unregister_shrinker(&vb->shrinker);
  458. }
  459. static int virtio_balloon_register_shrinker(struct virtio_balloon *vb)
  460. {
  461. vb->shrinker.scan_objects = virtio_balloon_shrinker_scan;
  462. vb->shrinker.count_objects = virtio_balloon_shrinker_count;
  463. vb->shrinker.seeks = DEFAULT_SEEKS;
  464. return register_shrinker(&vb->shrinker);
  465. }
  466. static int virtballoon_probe(struct virtio_device *vdev)
  467. {
  468. struct virtio_balloon *vb;
  469. int err;
  470. if (!vdev->config->get) {
  471. dev_err(&vdev->dev, "%s failure: config access disabled\n",
  472. __func__);
  473. return -EINVAL;
  474. }
  475. vdev->priv = vb = kzalloc(sizeof(*vb), GFP_KERNEL);
  476. if (!vb) {
  477. err = -ENOMEM;
  478. goto out;
  479. }
  480. INIT_WORK(&vb->update_balloon_stats_work, update_balloon_stats_func);
  481. INIT_WORK(&vb->update_balloon_size_work, update_balloon_size_func);
  482. spin_lock_init(&vb->stop_update_lock);
  483. mutex_init(&vb->balloon_lock);
  484. init_waitqueue_head(&vb->acked);
  485. vb->vdev = vdev;
  486. balloon_devinfo_init(&vb->vb_dev_info);
  487. err = init_vqs(vb);
  488. if (err)
  489. goto out_free_vb;
  490. #ifdef CONFIG_BALLOON_COMPACTION
  491. balloon_mnt = kern_mount(&balloon_fs);
  492. if (IS_ERR(balloon_mnt)) {
  493. err = PTR_ERR(balloon_mnt);
  494. goto out_del_vqs;
  495. }
  496. vb->vb_dev_info.migratepage = virtballoon_migratepage;
  497. vb->vb_dev_info.inode = alloc_anon_inode(balloon_mnt->mnt_sb);
  498. if (IS_ERR(vb->vb_dev_info.inode)) {
  499. err = PTR_ERR(vb->vb_dev_info.inode);
  500. kern_unmount(balloon_mnt);
  501. goto out_del_vqs;
  502. }
  503. vb->vb_dev_info.inode->i_mapping->a_ops = &balloon_aops;
  504. #endif
  505. /*
  506. * We continue to use VIRTIO_BALLOON_F_DEFLATE_ON_OOM to decide if a
  507. * shrinker needs to be registered to relieve memory pressure.
  508. */
  509. if (virtio_has_feature(vb->vdev, VIRTIO_BALLOON_F_DEFLATE_ON_OOM)) {
  510. err = virtio_balloon_register_shrinker(vb);
  511. if (err)
  512. goto out_del_vqs;
  513. }
  514. virtio_device_ready(vdev);
  515. if (towards_target(vb))
  516. virtballoon_changed(vdev);
  517. return 0;
  518. out_del_vqs:
  519. vdev->config->del_vqs(vdev);
  520. out_free_vb:
  521. kfree(vb);
  522. out:
  523. return err;
  524. }
  525. static void remove_common(struct virtio_balloon *vb)
  526. {
  527. /* There might be pages left in the balloon: free them. */
  528. while (vb->num_pages)
  529. leak_balloon(vb, vb->num_pages);
  530. update_balloon_size(vb);
  531. /* Now we reset the device so we can clean up the queues. */
  532. vb->vdev->config->reset(vb->vdev);
  533. vb->vdev->config->del_vqs(vb->vdev);
  534. }
  535. static void virtballoon_remove(struct virtio_device *vdev)
  536. {
  537. struct virtio_balloon *vb = vdev->priv;
  538. if (virtio_has_feature(vb->vdev, VIRTIO_BALLOON_F_DEFLATE_ON_OOM))
  539. virtio_balloon_unregister_shrinker(vb);
  540. spin_lock_irq(&vb->stop_update_lock);
  541. vb->stop_update = true;
  542. spin_unlock_irq(&vb->stop_update_lock);
  543. cancel_work_sync(&vb->update_balloon_size_work);
  544. cancel_work_sync(&vb->update_balloon_stats_work);
  545. remove_common(vb);
  546. #ifdef CONFIG_BALLOON_COMPACTION
  547. if (vb->vb_dev_info.inode)
  548. iput(vb->vb_dev_info.inode);
  549. kern_unmount(balloon_mnt);
  550. #endif
  551. kfree(vb);
  552. }
  553. #ifdef CONFIG_PM_SLEEP
  554. static int virtballoon_freeze(struct virtio_device *vdev)
  555. {
  556. struct virtio_balloon *vb = vdev->priv;
  557. /*
  558. * The workqueue is already frozen by the PM core before this
  559. * function is called.
  560. */
  561. remove_common(vb);
  562. return 0;
  563. }
  564. static int virtballoon_restore(struct virtio_device *vdev)
  565. {
  566. struct virtio_balloon *vb = vdev->priv;
  567. int ret;
  568. ret = init_vqs(vdev->priv);
  569. if (ret)
  570. return ret;
  571. virtio_device_ready(vdev);
  572. if (towards_target(vb))
  573. virtballoon_changed(vdev);
  574. update_balloon_size(vb);
  575. return 0;
  576. }
  577. #endif
  578. static int virtballoon_validate(struct virtio_device *vdev)
  579. {
  580. __virtio_clear_bit(vdev, VIRTIO_F_IOMMU_PLATFORM);
  581. return 0;
  582. }
  583. static unsigned int features[] = {
  584. VIRTIO_BALLOON_F_MUST_TELL_HOST,
  585. VIRTIO_BALLOON_F_STATS_VQ,
  586. VIRTIO_BALLOON_F_DEFLATE_ON_OOM,
  587. };
  588. static struct virtio_driver virtio_balloon_driver = {
  589. .feature_table = features,
  590. .feature_table_size = ARRAY_SIZE(features),
  591. .driver.name = KBUILD_MODNAME,
  592. .driver.owner = THIS_MODULE,
  593. .id_table = id_table,
  594. .validate = virtballoon_validate,
  595. .probe = virtballoon_probe,
  596. .remove = virtballoon_remove,
  597. .config_changed = virtballoon_changed,
  598. #ifdef CONFIG_PM_SLEEP
  599. .freeze = virtballoon_freeze,
  600. .restore = virtballoon_restore,
  601. #endif
  602. };
  603. module_virtio_driver(virtio_balloon_driver);
  604. MODULE_DEVICE_TABLE(virtio, id_table);
  605. MODULE_DESCRIPTION("Virtio balloon driver");
  606. MODULE_LICENSE("GPL");