common.h 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. /*
  2. * This program is free software; you can redistribute it and/or
  3. * modify it under the terms of the GNU General Public License version 2
  4. * as published by the Free Software Foundation; or, when distributed
  5. * separately from the Linux kernel or incorporated into other
  6. * software packages, subject to the following license:
  7. *
  8. * Permission is hereby granted, free of charge, to any person obtaining a copy
  9. * of this source file (the "Software"), to deal in the Software without
  10. * restriction, including without limitation the rights to use, copy, modify,
  11. * merge, publish, distribute, sublicense, and/or sell copies of the Software,
  12. * and to permit persons to whom the Software is furnished to do so, subject to
  13. * the following conditions:
  14. *
  15. * The above copyright notice and this permission notice shall be included in
  16. * all copies or substantial portions of the Software.
  17. *
  18. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  19. * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  20. * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  21. * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  22. * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  23. * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
  24. * IN THE SOFTWARE.
  25. */
  26. #ifndef __BLKIF__BACKEND__COMMON_H__
  27. #define __BLKIF__BACKEND__COMMON_H__
  28. #include <linux/version.h>
  29. #include <linux/module.h>
  30. #include <linux/interrupt.h>
  31. #include <linux/slab.h>
  32. #include <linux/blkdev.h>
  33. #include <linux/vmalloc.h>
  34. #include <linux/wait.h>
  35. #include <linux/io.h>
  36. #include <asm/setup.h>
  37. #include <asm/pgalloc.h>
  38. #include <asm/hypervisor.h>
  39. #include <xen/blkif.h>
  40. #include <xen/grant_table.h>
  41. #include <xen/xenbus.h>
  42. #define DRV_PFX "xen-blkback:"
  43. #define DPRINTK(fmt, args...) \
  44. pr_debug(DRV_PFX "(%s:%d) " fmt ".\n", \
  45. __func__, __LINE__, ##args)
  46. struct vbd {
  47. /* What the domain refers to this vbd as. */
  48. blkif_vdev_t handle;
  49. /* Non-zero -> read-only */
  50. unsigned char readonly;
  51. /* VDISK_xxx */
  52. unsigned char type;
  53. /* phys device that this vbd maps to. */
  54. u32 pdevice;
  55. struct block_device *bdev;
  56. /* Cached size parameter. */
  57. sector_t size;
  58. bool flush_support;
  59. };
  60. struct backend_info;
  61. struct blkif_st {
  62. /* Unique identifier for this interface. */
  63. domid_t domid;
  64. unsigned int handle;
  65. /* Physical parameters of the comms window. */
  66. unsigned int irq;
  67. /* Comms information. */
  68. enum blkif_protocol blk_protocol;
  69. union blkif_back_rings blk_rings;
  70. struct vm_struct *blk_ring_area;
  71. /* The VBD attached to this interface. */
  72. struct vbd vbd;
  73. /* Back pointer to the backend_info. */
  74. struct backend_info *be;
  75. /* Private fields. */
  76. spinlock_t blk_ring_lock;
  77. atomic_t refcnt;
  78. wait_queue_head_t wq;
  79. /* One thread per one blkif. */
  80. struct task_struct *xenblkd;
  81. unsigned int waiting_reqs;
  82. /* statistics */
  83. unsigned long st_print;
  84. int st_rd_req;
  85. int st_wr_req;
  86. int st_oo_req;
  87. int st_f_req;
  88. int st_rd_sect;
  89. int st_wr_sect;
  90. wait_queue_head_t waiting_to_free;
  91. grant_handle_t shmem_handle;
  92. grant_ref_t shmem_ref;
  93. };
  94. #define vbd_sz(_v) ((_v)->bdev->bd_part ? \
  95. (_v)->bdev->bd_part->nr_sects : \
  96. get_capacity((_v)->bdev->bd_disk))
  97. #define xen_blkif_get(_b) (atomic_inc(&(_b)->refcnt))
  98. #define xen_blkif_put(_b) \
  99. do { \
  100. if (atomic_dec_and_test(&(_b)->refcnt)) \
  101. wake_up(&(_b)->waiting_to_free);\
  102. } while (0)
  103. struct phys_req {
  104. unsigned short dev;
  105. unsigned short nr_sects;
  106. struct block_device *bdev;
  107. blkif_sector_t sector_number;
  108. };
  109. int xen_blkif_interface_init(void);
  110. int xen_blkif_xenbus_init(void);
  111. irqreturn_t xen_blkif_be_int(int irq, void *dev_id);
  112. int xen_blkif_schedule(void *arg);
  113. int xen_blkbk_flush_diskcache(struct xenbus_transaction xbt,
  114. struct backend_info *be, int state);
  115. struct xenbus_device *xen_blkbk_xenbus(struct backend_info *be);
  116. #endif /* __BLKIF__BACKEND__COMMON_H__ */