gup.c 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394
  1. /*
  2. * Lockless get_user_pages_fast for x86
  3. *
  4. * Copyright (C) 2008 Nick Piggin
  5. * Copyright (C) 2008 Novell Inc.
  6. */
  7. #include <linux/sched.h>
  8. #include <linux/mm.h>
  9. #include <linux/vmstat.h>
  10. #include <linux/highmem.h>
  11. #include <linux/swap.h>
  12. #include <asm/pgtable.h>
  13. static inline pte_t gup_get_pte(pte_t *ptep)
  14. {
  15. #ifndef CONFIG_X86_PAE
  16. return ACCESS_ONCE(*ptep);
  17. #else
  18. /*
  19. * With get_user_pages_fast, we walk down the pagetables without taking
  20. * any locks. For this we would like to load the pointers atomically,
  21. * but that is not possible (without expensive cmpxchg8b) on PAE. What
  22. * we do have is the guarantee that a pte will only either go from not
  23. * present to present, or present to not present or both -- it will not
  24. * switch to a completely different present page without a TLB flush in
  25. * between; something that we are blocking by holding interrupts off.
  26. *
  27. * Setting ptes from not present to present goes:
  28. * ptep->pte_high = h;
  29. * smp_wmb();
  30. * ptep->pte_low = l;
  31. *
  32. * And present to not present goes:
  33. * ptep->pte_low = 0;
  34. * smp_wmb();
  35. * ptep->pte_high = 0;
  36. *
  37. * We must ensure here that the load of pte_low sees l iff pte_high
  38. * sees h. We load pte_high *after* loading pte_low, which ensures we
  39. * don't see an older value of pte_high. *Then* we recheck pte_low,
  40. * which ensures that we haven't picked up a changed pte high. We might
  41. * have got rubbish values from pte_low and pte_high, but we are
  42. * guaranteed that pte_low will not have the present bit set *unless*
  43. * it is 'l'. And get_user_pages_fast only operates on present ptes, so
  44. * we're safe.
  45. *
  46. * gup_get_pte should not be used or copied outside gup.c without being
  47. * very careful -- it does not atomically load the pte or anything that
  48. * is likely to be useful for you.
  49. */
  50. pte_t pte;
  51. retry:
  52. pte.pte_low = ptep->pte_low;
  53. smp_rmb();
  54. pte.pte_high = ptep->pte_high;
  55. smp_rmb();
  56. if (unlikely(pte.pte_low != ptep->pte_low))
  57. goto retry;
  58. return pte;
  59. #endif
  60. }
  61. /*
  62. * The performance critical leaf functions are made noinline otherwise gcc
  63. * inlines everything into a single function which results in too much
  64. * register pressure.
  65. */
  66. static noinline int gup_pte_range(pmd_t pmd, unsigned long addr,
  67. unsigned long end, int write, struct page **pages, int *nr)
  68. {
  69. unsigned long mask;
  70. pte_t *ptep;
  71. mask = _PAGE_PRESENT|_PAGE_USER;
  72. if (write)
  73. mask |= _PAGE_RW;
  74. ptep = pte_offset_map(&pmd, addr);
  75. do {
  76. pte_t pte = gup_get_pte(ptep);
  77. struct page *page;
  78. if ((pte_flags(pte) & (mask | _PAGE_SPECIAL)) != mask) {
  79. pte_unmap(ptep);
  80. return 0;
  81. }
  82. VM_BUG_ON(!pfn_valid(pte_pfn(pte)));
  83. page = pte_page(pte);
  84. get_page(page);
  85. SetPageReferenced(page);
  86. pages[*nr] = page;
  87. (*nr)++;
  88. } while (ptep++, addr += PAGE_SIZE, addr != end);
  89. pte_unmap(ptep - 1);
  90. return 1;
  91. }
  92. static inline void get_head_page_multiple(struct page *page, int nr)
  93. {
  94. VM_BUG_ON(page != compound_head(page));
  95. VM_BUG_ON(page_count(page) == 0);
  96. atomic_add(nr, &page->_count);
  97. SetPageReferenced(page);
  98. }
  99. static noinline int gup_huge_pmd(pmd_t pmd, unsigned long addr,
  100. unsigned long end, int write, struct page **pages, int *nr)
  101. {
  102. unsigned long mask;
  103. pte_t pte = *(pte_t *)&pmd;
  104. struct page *head, *page;
  105. int refs;
  106. mask = _PAGE_PRESENT|_PAGE_USER;
  107. if (write)
  108. mask |= _PAGE_RW;
  109. if ((pte_flags(pte) & mask) != mask)
  110. return 0;
  111. /* hugepages are never "special" */
  112. VM_BUG_ON(pte_flags(pte) & _PAGE_SPECIAL);
  113. VM_BUG_ON(!pfn_valid(pte_pfn(pte)));
  114. refs = 0;
  115. head = pte_page(pte);
  116. page = head + ((addr & ~PMD_MASK) >> PAGE_SHIFT);
  117. do {
  118. VM_BUG_ON(compound_head(page) != head);
  119. pages[*nr] = page;
  120. if (PageTail(page))
  121. get_huge_page_tail(page);
  122. (*nr)++;
  123. page++;
  124. refs++;
  125. } while (addr += PAGE_SIZE, addr != end);
  126. get_head_page_multiple(head, refs);
  127. return 1;
  128. }
  129. static int gup_pmd_range(pud_t pud, unsigned long addr, unsigned long end,
  130. int write, struct page **pages, int *nr)
  131. {
  132. unsigned long next;
  133. pmd_t *pmdp;
  134. pmdp = pmd_offset(&pud, addr);
  135. do {
  136. pmd_t pmd = *pmdp;
  137. next = pmd_addr_end(addr, end);
  138. /*
  139. * The pmd_trans_splitting() check below explains why
  140. * pmdp_splitting_flush has to flush the tlb, to stop
  141. * this gup-fast code from running while we set the
  142. * splitting bit in the pmd. Returning zero will take
  143. * the slow path that will call wait_split_huge_page()
  144. * if the pmd is still in splitting state. gup-fast
  145. * can't because it has irq disabled and
  146. * wait_split_huge_page() would never return as the
  147. * tlb flush IPI wouldn't run.
  148. */
  149. if (pmd_none(pmd) || pmd_trans_splitting(pmd))
  150. return 0;
  151. if (unlikely(pmd_large(pmd))) {
  152. if (!gup_huge_pmd(pmd, addr, next, write, pages, nr))
  153. return 0;
  154. } else {
  155. if (!gup_pte_range(pmd, addr, next, write, pages, nr))
  156. return 0;
  157. }
  158. } while (pmdp++, addr = next, addr != end);
  159. return 1;
  160. }
  161. static noinline int gup_huge_pud(pud_t pud, unsigned long addr,
  162. unsigned long end, int write, struct page **pages, int *nr)
  163. {
  164. unsigned long mask;
  165. pte_t pte = *(pte_t *)&pud;
  166. struct page *head, *page;
  167. int refs;
  168. mask = _PAGE_PRESENT|_PAGE_USER;
  169. if (write)
  170. mask |= _PAGE_RW;
  171. if ((pte_flags(pte) & mask) != mask)
  172. return 0;
  173. /* hugepages are never "special" */
  174. VM_BUG_ON(pte_flags(pte) & _PAGE_SPECIAL);
  175. VM_BUG_ON(!pfn_valid(pte_pfn(pte)));
  176. refs = 0;
  177. head = pte_page(pte);
  178. page = head + ((addr & ~PUD_MASK) >> PAGE_SHIFT);
  179. do {
  180. VM_BUG_ON(compound_head(page) != head);
  181. pages[*nr] = page;
  182. if (PageTail(page))
  183. get_huge_page_tail(page);
  184. (*nr)++;
  185. page++;
  186. refs++;
  187. } while (addr += PAGE_SIZE, addr != end);
  188. get_head_page_multiple(head, refs);
  189. return 1;
  190. }
  191. static int gup_pud_range(pgd_t pgd, unsigned long addr, unsigned long end,
  192. int write, struct page **pages, int *nr)
  193. {
  194. unsigned long next;
  195. pud_t *pudp;
  196. pudp = pud_offset(&pgd, addr);
  197. do {
  198. pud_t pud = *pudp;
  199. next = pud_addr_end(addr, end);
  200. if (pud_none(pud))
  201. return 0;
  202. if (unlikely(pud_large(pud))) {
  203. if (!gup_huge_pud(pud, addr, next, write, pages, nr))
  204. return 0;
  205. } else {
  206. if (!gup_pmd_range(pud, addr, next, write, pages, nr))
  207. return 0;
  208. }
  209. } while (pudp++, addr = next, addr != end);
  210. return 1;
  211. }
  212. /*
  213. * Like get_user_pages_fast() except its IRQ-safe in that it won't fall
  214. * back to the regular GUP.
  215. */
  216. int __get_user_pages_fast(unsigned long start, int nr_pages, int write,
  217. struct page **pages)
  218. {
  219. struct mm_struct *mm = current->mm;
  220. unsigned long addr, len, end;
  221. unsigned long next;
  222. unsigned long flags;
  223. pgd_t *pgdp;
  224. int nr = 0;
  225. start &= PAGE_MASK;
  226. addr = start;
  227. len = (unsigned long) nr_pages << PAGE_SHIFT;
  228. end = start + len;
  229. if (unlikely(!access_ok(write ? VERIFY_WRITE : VERIFY_READ,
  230. (void __user *)start, len)))
  231. return 0;
  232. /*
  233. * XXX: batch / limit 'nr', to avoid large irq off latency
  234. * needs some instrumenting to determine the common sizes used by
  235. * important workloads (eg. DB2), and whether limiting the batch size
  236. * will decrease performance.
  237. *
  238. * It seems like we're in the clear for the moment. Direct-IO is
  239. * the main guy that batches up lots of get_user_pages, and even
  240. * they are limited to 64-at-a-time which is not so many.
  241. */
  242. /*
  243. * This doesn't prevent pagetable teardown, but does prevent
  244. * the pagetables and pages from being freed on x86.
  245. *
  246. * So long as we atomically load page table pointers versus teardown
  247. * (which we do on x86, with the above PAE exception), we can follow the
  248. * address down to the the page and take a ref on it.
  249. */
  250. local_irq_save(flags);
  251. pgdp = pgd_offset(mm, addr);
  252. do {
  253. pgd_t pgd = *pgdp;
  254. next = pgd_addr_end(addr, end);
  255. if (pgd_none(pgd))
  256. break;
  257. if (!gup_pud_range(pgd, addr, next, write, pages, &nr))
  258. break;
  259. } while (pgdp++, addr = next, addr != end);
  260. local_irq_restore(flags);
  261. return nr;
  262. }
  263. /**
  264. * get_user_pages_fast() - pin user pages in memory
  265. * @start: starting user address
  266. * @nr_pages: number of pages from start to pin
  267. * @write: whether pages will be written to
  268. * @pages: array that receives pointers to the pages pinned.
  269. * Should be at least nr_pages long.
  270. *
  271. * Attempt to pin user pages in memory without taking mm->mmap_sem.
  272. * If not successful, it will fall back to taking the lock and
  273. * calling get_user_pages().
  274. *
  275. * Returns number of pages pinned. This may be fewer than the number
  276. * requested. If nr_pages is 0 or negative, returns 0. If no pages
  277. * were pinned, returns -errno.
  278. */
  279. int get_user_pages_fast(unsigned long start, int nr_pages, int write,
  280. struct page **pages)
  281. {
  282. struct mm_struct *mm = current->mm;
  283. unsigned long addr, len, end;
  284. unsigned long next;
  285. pgd_t *pgdp;
  286. int nr = 0;
  287. start &= PAGE_MASK;
  288. addr = start;
  289. len = (unsigned long) nr_pages << PAGE_SHIFT;
  290. end = start + len;
  291. if (end < start)
  292. goto slow_irqon;
  293. #ifdef CONFIG_X86_64
  294. if (end >> __VIRTUAL_MASK_SHIFT)
  295. goto slow_irqon;
  296. #endif
  297. /*
  298. * XXX: batch / limit 'nr', to avoid large irq off latency
  299. * needs some instrumenting to determine the common sizes used by
  300. * important workloads (eg. DB2), and whether limiting the batch size
  301. * will decrease performance.
  302. *
  303. * It seems like we're in the clear for the moment. Direct-IO is
  304. * the main guy that batches up lots of get_user_pages, and even
  305. * they are limited to 64-at-a-time which is not so many.
  306. */
  307. /*
  308. * This doesn't prevent pagetable teardown, but does prevent
  309. * the pagetables and pages from being freed on x86.
  310. *
  311. * So long as we atomically load page table pointers versus teardown
  312. * (which we do on x86, with the above PAE exception), we can follow the
  313. * address down to the the page and take a ref on it.
  314. */
  315. local_irq_disable();
  316. pgdp = pgd_offset(mm, addr);
  317. do {
  318. pgd_t pgd = *pgdp;
  319. next = pgd_addr_end(addr, end);
  320. if (pgd_none(pgd))
  321. goto slow;
  322. if (!gup_pud_range(pgd, addr, next, write, pages, &nr))
  323. goto slow;
  324. } while (pgdp++, addr = next, addr != end);
  325. local_irq_enable();
  326. VM_BUG_ON(nr != (end - start) >> PAGE_SHIFT);
  327. return nr;
  328. {
  329. int ret;
  330. slow:
  331. local_irq_enable();
  332. slow_irqon:
  333. /* Try to get the remaining pages with get_user_pages */
  334. start += nr << PAGE_SHIFT;
  335. pages += nr;
  336. down_read(&mm->mmap_sem);
  337. ret = get_user_pages(current, mm, start,
  338. (end - start) >> PAGE_SHIFT, write, 0, pages, NULL);
  339. up_read(&mm->mmap_sem);
  340. /* Have to be a bit careful with return values */
  341. if (nr > 0) {
  342. if (ret < 0)
  343. ret = nr;
  344. else
  345. ret += nr;
  346. }
  347. return ret;
  348. }
  349. }