gup.c 7.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303
  1. // SPDX-License-Identifier: GPL-2.0
  2. /*
  3. * Lockless get_user_pages_fast for MIPS
  4. *
  5. * Copyright (C) 2008 Nick Piggin
  6. * Copyright (C) 2008 Novell Inc.
  7. * Copyright (C) 2011 Ralf Baechle
  8. */
  9. #include <linux/sched.h>
  10. #include <linux/mm.h>
  11. #include <linux/vmstat.h>
  12. #include <linux/highmem.h>
  13. #include <linux/swap.h>
  14. #include <linux/hugetlb.h>
  15. #include <asm/cpu-features.h>
  16. #include <asm/pgtable.h>
  17. static inline pte_t gup_get_pte(pte_t *ptep)
  18. {
  19. #if defined(CONFIG_PHYS_ADDR_T_64BIT) && defined(CONFIG_CPU_MIPS32)
  20. pte_t pte;
  21. retry:
  22. pte.pte_low = ptep->pte_low;
  23. smp_rmb();
  24. pte.pte_high = ptep->pte_high;
  25. smp_rmb();
  26. if (unlikely(pte.pte_low != ptep->pte_low))
  27. goto retry;
  28. return pte;
  29. #else
  30. return READ_ONCE(*ptep);
  31. #endif
  32. }
  33. static int gup_pte_range(pmd_t pmd, unsigned long addr, unsigned long end,
  34. int write, struct page **pages, int *nr)
  35. {
  36. pte_t *ptep = pte_offset_map(&pmd, addr);
  37. do {
  38. pte_t pte = gup_get_pte(ptep);
  39. struct page *page;
  40. if (!pte_present(pte) ||
  41. pte_special(pte) || (write && !pte_write(pte))) {
  42. pte_unmap(ptep);
  43. return 0;
  44. }
  45. VM_BUG_ON(!pfn_valid(pte_pfn(pte)));
  46. page = pte_page(pte);
  47. get_page(page);
  48. SetPageReferenced(page);
  49. pages[*nr] = page;
  50. (*nr)++;
  51. } while (ptep++, addr += PAGE_SIZE, addr != end);
  52. pte_unmap(ptep - 1);
  53. return 1;
  54. }
  55. static inline void get_head_page_multiple(struct page *page, int nr)
  56. {
  57. VM_BUG_ON(page != compound_head(page));
  58. VM_BUG_ON(page_count(page) == 0);
  59. page_ref_add(page, nr);
  60. SetPageReferenced(page);
  61. }
  62. static int gup_huge_pmd(pmd_t pmd, unsigned long addr, unsigned long end,
  63. int write, struct page **pages, int *nr)
  64. {
  65. pte_t pte = *(pte_t *)&pmd;
  66. struct page *head, *page;
  67. int refs;
  68. if (write && !pte_write(pte))
  69. return 0;
  70. /* hugepages are never "special" */
  71. VM_BUG_ON(pte_special(pte));
  72. VM_BUG_ON(!pfn_valid(pte_pfn(pte)));
  73. refs = 0;
  74. head = pte_page(pte);
  75. page = head + ((addr & ~PMD_MASK) >> PAGE_SHIFT);
  76. do {
  77. VM_BUG_ON(compound_head(page) != head);
  78. pages[*nr] = page;
  79. (*nr)++;
  80. page++;
  81. refs++;
  82. } while (addr += PAGE_SIZE, addr != end);
  83. get_head_page_multiple(head, refs);
  84. return 1;
  85. }
  86. static int gup_pmd_range(pud_t pud, unsigned long addr, unsigned long end,
  87. int write, struct page **pages, int *nr)
  88. {
  89. unsigned long next;
  90. pmd_t *pmdp;
  91. pmdp = pmd_offset(&pud, addr);
  92. do {
  93. pmd_t pmd = *pmdp;
  94. next = pmd_addr_end(addr, end);
  95. if (pmd_none(pmd))
  96. return 0;
  97. if (unlikely(pmd_huge(pmd))) {
  98. if (!gup_huge_pmd(pmd, addr, next, write, pages,nr))
  99. return 0;
  100. } else {
  101. if (!gup_pte_range(pmd, addr, next, write, pages,nr))
  102. return 0;
  103. }
  104. } while (pmdp++, addr = next, addr != end);
  105. return 1;
  106. }
  107. static int gup_huge_pud(pud_t pud, unsigned long addr, unsigned long end,
  108. int write, struct page **pages, int *nr)
  109. {
  110. pte_t pte = *(pte_t *)&pud;
  111. struct page *head, *page;
  112. int refs;
  113. if (write && !pte_write(pte))
  114. return 0;
  115. /* hugepages are never "special" */
  116. VM_BUG_ON(pte_special(pte));
  117. VM_BUG_ON(!pfn_valid(pte_pfn(pte)));
  118. refs = 0;
  119. head = pte_page(pte);
  120. page = head + ((addr & ~PUD_MASK) >> PAGE_SHIFT);
  121. do {
  122. VM_BUG_ON(compound_head(page) != head);
  123. pages[*nr] = page;
  124. (*nr)++;
  125. page++;
  126. refs++;
  127. } while (addr += PAGE_SIZE, addr != end);
  128. get_head_page_multiple(head, refs);
  129. return 1;
  130. }
  131. static int gup_pud_range(pgd_t pgd, unsigned long addr, unsigned long end,
  132. int write, struct page **pages, int *nr)
  133. {
  134. unsigned long next;
  135. pud_t *pudp;
  136. pudp = pud_offset(&pgd, addr);
  137. do {
  138. pud_t pud = *pudp;
  139. next = pud_addr_end(addr, end);
  140. if (pud_none(pud))
  141. return 0;
  142. if (unlikely(pud_huge(pud))) {
  143. if (!gup_huge_pud(pud, addr, next, write, pages,nr))
  144. return 0;
  145. } else {
  146. if (!gup_pmd_range(pud, addr, next, write, pages,nr))
  147. return 0;
  148. }
  149. } while (pudp++, addr = next, addr != end);
  150. return 1;
  151. }
  152. /*
  153. * Like get_user_pages_fast() except its IRQ-safe in that it won't fall
  154. * back to the regular GUP.
  155. * Note a difference with get_user_pages_fast: this always returns the
  156. * number of pages pinned, 0 if no pages were pinned.
  157. */
  158. int __get_user_pages_fast(unsigned long start, int nr_pages, int write,
  159. struct page **pages)
  160. {
  161. struct mm_struct *mm = current->mm;
  162. unsigned long addr, len, end;
  163. unsigned long next;
  164. unsigned long flags;
  165. pgd_t *pgdp;
  166. int nr = 0;
  167. start &= PAGE_MASK;
  168. addr = start;
  169. len = (unsigned long) nr_pages << PAGE_SHIFT;
  170. end = start + len;
  171. if (unlikely(!access_ok(write ? VERIFY_WRITE : VERIFY_READ,
  172. (void __user *)start, len)))
  173. return 0;
  174. /*
  175. * XXX: batch / limit 'nr', to avoid large irq off latency
  176. * needs some instrumenting to determine the common sizes used by
  177. * important workloads (eg. DB2), and whether limiting the batch
  178. * size will decrease performance.
  179. *
  180. * It seems like we're in the clear for the moment. Direct-IO is
  181. * the main guy that batches up lots of get_user_pages, and even
  182. * they are limited to 64-at-a-time which is not so many.
  183. */
  184. /*
  185. * This doesn't prevent pagetable teardown, but does prevent
  186. * the pagetables and pages from being freed.
  187. *
  188. * So long as we atomically load page table pointers versus teardown,
  189. * we can follow the address down to the page and take a ref on it.
  190. */
  191. local_irq_save(flags);
  192. pgdp = pgd_offset(mm, addr);
  193. do {
  194. pgd_t pgd = *pgdp;
  195. next = pgd_addr_end(addr, end);
  196. if (pgd_none(pgd))
  197. break;
  198. if (!gup_pud_range(pgd, addr, next, write, pages, &nr))
  199. break;
  200. } while (pgdp++, addr = next, addr != end);
  201. local_irq_restore(flags);
  202. return nr;
  203. }
  204. /**
  205. * get_user_pages_fast() - pin user pages in memory
  206. * @start: starting user address
  207. * @nr_pages: number of pages from start to pin
  208. * @write: whether pages will be written to
  209. * @pages: array that receives pointers to the pages pinned.
  210. * Should be at least nr_pages long.
  211. *
  212. * Attempt to pin user pages in memory without taking mm->mmap_sem.
  213. * If not successful, it will fall back to taking the lock and
  214. * calling get_user_pages().
  215. *
  216. * Returns number of pages pinned. This may be fewer than the number
  217. * requested. If nr_pages is 0 or negative, returns 0. If no pages
  218. * were pinned, returns -errno.
  219. */
  220. int get_user_pages_fast(unsigned long start, int nr_pages, int write,
  221. struct page **pages)
  222. {
  223. struct mm_struct *mm = current->mm;
  224. unsigned long addr, len, end;
  225. unsigned long next;
  226. pgd_t *pgdp;
  227. int ret, nr = 0;
  228. start &= PAGE_MASK;
  229. addr = start;
  230. len = (unsigned long) nr_pages << PAGE_SHIFT;
  231. end = start + len;
  232. if (end < start || cpu_has_dc_aliases)
  233. goto slow_irqon;
  234. /* XXX: batch / limit 'nr' */
  235. local_irq_disable();
  236. pgdp = pgd_offset(mm, addr);
  237. do {
  238. pgd_t pgd = *pgdp;
  239. next = pgd_addr_end(addr, end);
  240. if (pgd_none(pgd))
  241. goto slow;
  242. if (!gup_pud_range(pgd, addr, next, write, pages, &nr))
  243. goto slow;
  244. } while (pgdp++, addr = next, addr != end);
  245. local_irq_enable();
  246. VM_BUG_ON(nr != (end - start) >> PAGE_SHIFT);
  247. return nr;
  248. slow:
  249. local_irq_enable();
  250. slow_irqon:
  251. /* Try to get the remaining pages with get_user_pages */
  252. start += nr << PAGE_SHIFT;
  253. pages += nr;
  254. ret = get_user_pages_unlocked(start, (end - start) >> PAGE_SHIFT,
  255. pages, write ? FOLL_WRITE : 0);
  256. /* Have to be a bit careful with return values */
  257. if (nr > 0) {
  258. if (ret < 0)
  259. ret = nr;
  260. else
  261. ret += nr;
  262. }
  263. return ret;
  264. }