async-thread.h 3.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. /*
  2. * Copyright (C) 2007 Oracle. All rights reserved.
  3. * Copyright (C) 2014 Fujitsu. All rights reserved.
  4. *
  5. * This program is free software; you can redistribute it and/or
  6. * modify it under the terms of the GNU General Public
  7. * License v2 as published by the Free Software Foundation.
  8. *
  9. * This program is distributed in the hope that it will be useful,
  10. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  12. * General Public License for more details.
  13. *
  14. * You should have received a copy of the GNU General Public
  15. * License along with this program; if not, write to the
  16. * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  17. * Boston, MA 021110-1307, USA.
  18. */
  19. #ifndef __BTRFS_ASYNC_THREAD_
  20. #define __BTRFS_ASYNC_THREAD_
  21. #include <linux/workqueue.h>
  22. struct btrfs_fs_info;
  23. struct btrfs_workqueue;
  24. /* Internal use only */
  25. struct __btrfs_workqueue;
  26. struct btrfs_work;
  27. typedef void (*btrfs_func_t)(struct btrfs_work *arg);
  28. typedef void (*btrfs_work_func_t)(struct work_struct *arg);
  29. struct btrfs_work {
  30. btrfs_func_t func;
  31. btrfs_func_t ordered_func;
  32. btrfs_func_t ordered_free;
  33. /* Don't touch things below */
  34. struct work_struct normal_work;
  35. struct list_head ordered_list;
  36. struct __btrfs_workqueue *wq;
  37. unsigned long flags;
  38. };
  39. #define BTRFS_WORK_HELPER_PROTO(name) \
  40. void btrfs_##name(struct work_struct *arg)
  41. BTRFS_WORK_HELPER_PROTO(worker_helper);
  42. BTRFS_WORK_HELPER_PROTO(delalloc_helper);
  43. BTRFS_WORK_HELPER_PROTO(flush_delalloc_helper);
  44. BTRFS_WORK_HELPER_PROTO(cache_helper);
  45. BTRFS_WORK_HELPER_PROTO(submit_helper);
  46. BTRFS_WORK_HELPER_PROTO(fixup_helper);
  47. BTRFS_WORK_HELPER_PROTO(endio_helper);
  48. BTRFS_WORK_HELPER_PROTO(endio_meta_helper);
  49. BTRFS_WORK_HELPER_PROTO(endio_meta_write_helper);
  50. BTRFS_WORK_HELPER_PROTO(endio_raid56_helper);
  51. BTRFS_WORK_HELPER_PROTO(endio_repair_helper);
  52. BTRFS_WORK_HELPER_PROTO(rmw_helper);
  53. BTRFS_WORK_HELPER_PROTO(endio_write_helper);
  54. BTRFS_WORK_HELPER_PROTO(freespace_write_helper);
  55. BTRFS_WORK_HELPER_PROTO(delayed_meta_helper);
  56. BTRFS_WORK_HELPER_PROTO(readahead_helper);
  57. BTRFS_WORK_HELPER_PROTO(qgroup_rescan_helper);
  58. BTRFS_WORK_HELPER_PROTO(extent_refs_helper);
  59. BTRFS_WORK_HELPER_PROTO(scrub_helper);
  60. BTRFS_WORK_HELPER_PROTO(scrubwrc_helper);
  61. BTRFS_WORK_HELPER_PROTO(scrubnc_helper);
  62. BTRFS_WORK_HELPER_PROTO(scrubparity_helper);
  63. struct btrfs_workqueue *btrfs_alloc_workqueue(struct btrfs_fs_info *fs_info,
  64. const char *name,
  65. unsigned int flags,
  66. int limit_active,
  67. int thresh);
  68. void btrfs_init_work(struct btrfs_work *work, btrfs_work_func_t helper,
  69. btrfs_func_t func,
  70. btrfs_func_t ordered_func,
  71. btrfs_func_t ordered_free);
  72. void btrfs_queue_work(struct btrfs_workqueue *wq,
  73. struct btrfs_work *work);
  74. void btrfs_destroy_workqueue(struct btrfs_workqueue *wq);
  75. void btrfs_workqueue_set_max(struct btrfs_workqueue *wq, int max);
  76. void btrfs_set_work_high_priority(struct btrfs_work *work);
  77. struct btrfs_fs_info *btrfs_work_owner(struct btrfs_work *work);
  78. struct btrfs_fs_info *btrfs_workqueue_owner(struct __btrfs_workqueue *wq);
  79. bool btrfs_workqueue_normal_congested(struct btrfs_workqueue *wq);
  80. #endif